ThinkChat🤖让你学习和工作更高效,注册即送10W Token,即刻开启你的AI之旅 广告
# 命令行界面 Airflow具有非常丰富的命令行界面,允许在DAG上执行多种类型的操作,启动服务以及支持开发和测试。 ``` usage : airflow [ - h ] { resetdb , render , variables , connections , create_user , pause , task_failed_deps , version , trigger_dag , initdb , test , unpause , dag_state , run , list_tasks , backfill , list_dags , kerberos , worker , webserver , flower , scheduler , task_state , pool , serve_logs , clear , upgradedb , delete_dag } ... ``` ## 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;子&lt;/kbd&gt; | 可能的选择:resetdb,render,variables,connections,create_user,pause,task_failed_deps,version,trigger_dag,initdb,test,unpause,dag_state,run,list_tasks,backfill,list_dags,kerberos,worker,webserver,flower,scheduler,task_state,pool ,serve_logs,clear,upgrab,delete_dag子命令帮助 | ## 子命令: ### resetdb 烧毁并重建元数据数据库 ``` airflow resetdb [ - h ] [ - y ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-y, - 是的&lt;/kbd&gt; | 不要提示确认重置。 小心使用!默认值:False | ### 给予 渲染任务实例的模板 ``` airflow render [ - h ] [ - sd SUBDIR ] dag_id task_id execution_date ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任务的id | | &lt;kbd&gt;执行日期&lt;/kbd&gt; | DAG的执行日期 | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | ### 变量 对变量的CRUD操作 ``` airflow variables [ - h ] [ - s KEY VAL ] [ - g KEY ] [ - j ] [ - d VAL ] [ - i FILEPATH ] [ - e FILEPATH ] [ - x KEY ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-s, - set&lt;/kbd&gt; | 设置变量 | | &lt;kbd&gt;-g, - get&lt;/kbd&gt; | 获取变量的值 | | &lt;kbd&gt;-j, - json&lt;/kbd&gt; | 反序列化JSON变量默认值:False | | &lt;kbd&gt;-d, - 默认&lt;/kbd&gt; | 如果变量不存在,则返回默认值 | | &lt;kbd&gt;-i, - 进口&lt;/kbd&gt; | 从JSON文件导入变量 | | &lt;kbd&gt;-e, - 出口&lt;/kbd&gt; | 将变量导出到JSON文件 | | &lt;kbd&gt;-x, - 删除&lt;/kbd&gt; | 删除变量 | ### 连接 列表/添加/删除连接 ``` airflow connections [ - h ] [ - l ] [ - a ] [ - d ] [ -- conn_id CONN_ID ] [ -- conn_uri CONN_URI ] [ -- conn_extra CONN_EXTRA ] [ -- conn_type CONN_TYPE ] [ -- conn_host CONN_HOST ] [ -- conn_login CONN_LOGIN ] [ -- conn_password CONN_PASSWORD ] [ -- conn_schema CONN_SCHEMA ] [ -- conn_port CONN_PORT ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-l, - list&lt;/kbd&gt; | 列出所有连接默认值:False | | &lt;kbd&gt;-a, - add&lt;/kbd&gt; | 添加连接默认值:False | | &lt;kbd&gt;-d, - 删除&lt;/kbd&gt; | 删除连接默认值:False | | &lt;kbd&gt;--conn_id&lt;/kbd&gt; | 添加/删除连接所需的连接ID | | &lt;kbd&gt;--conn_uri&lt;/kbd&gt; | 连接URI,添加没有conn_type的连接所需 | | &lt;kbd&gt;--conn_extra&lt;/kbd&gt; | 连接&lt;cite&gt;额外&lt;/cite&gt;字段,添加连接时可选 | | &lt;kbd&gt;--conn_type&lt;/kbd&gt; | 连接类型,无需conn_uri即可添加连接 | | &lt;kbd&gt;--conn_host&lt;/kbd&gt; | 连接主机,添加连接时可选 | | &lt;kbd&gt;--conn_login&lt;/kbd&gt; | 连接登录,添加连接时可选 | | &lt;kbd&gt;--conn_password&lt;/kbd&gt; | | | 连接密码,添加连接时可选 | | &lt;kbd&gt;--conn_schema&lt;/kbd&gt; | 连接架构,添加连接时可选 | | &lt;kbd&gt;--conn_port&lt;/kbd&gt; | 连接端口,添加连接时可选 | ### 创建用户 创建管理员帐户 ``` airflow create_user [ - h ] [ - r ROLE ] [ - u USERNAME ] [ - e EMAIL ] [ - f FIRSTNAME ] [ - l LASTNAME ] [ - p PASSWORD ] [ -- use_random_password ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-r,--role&lt;/kbd&gt; | 用户的角色。 现有角色包括Admin,User,Op,Viewer和Public | | &lt;kbd&gt;-u, - username&lt;/kbd&gt; | 用户的用户名 | | &lt;kbd&gt;-e, - 电子邮件&lt;/kbd&gt; | 用户的电子邮件 | | &lt;kbd&gt;-f, - firstname&lt;/kbd&gt; | | | 用户的名字 | | &lt;kbd&gt;-l,--lastname&lt;/kbd&gt; | 用户的姓氏 | | &lt;kbd&gt;-p, - 密码&lt;/kbd&gt; | 用户密码 | | &lt;kbd&gt;--use_random_password&lt;/kbd&gt; | | | 不要提示输入密码。 改为使用随机字符串默认值:False | ### 暂停 暂停DAG ``` airflow pause [ - h ] [ - sd SUBDIR ] dag_id ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | ### task_failed_deps 从调度程序的角度返回任务实例的未满足的依赖项。 换句话说,为什么任务实例不会被调度程序调度然后排队,然后由执行程序运行。 ``` airflow task_failed_deps [ - h ] [ - sd SUBDIR ] dag_id task_id execution_date ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任务的id | | &lt;kbd&gt;执行日期&lt;/kbd&gt; | DAG的执行日期 | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | ### 版 显示版本 ``` airflow version [ - h ] ``` ### trigger_dag 触发DAG运行 ``` airflow trigger_dag [ - h ] [ - sd SUBDIR ] [ - r RUN_ID ] [ - c CONF ] [ - e EXEC_DATE ] dag_id ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-r, - run_id&lt;/kbd&gt; | 帮助识别此次运行 | | &lt;kbd&gt;-c, - conf&lt;/kbd&gt; | JSON字符串被腌制到DagRun的conf属性中 | | &lt;kbd&gt;-e, - exec_date&lt;/kbd&gt; | | | DAG的执行日期 | ### 在initdb 初始化元数据数据库 ``` airflow initdb [ - h ] ``` ### 测试 测试任务实例。 这将在不检查依赖关系或在数据库中记录其状态的情况下运行任务。 ``` airflow test [ - h ] [ - sd SUBDIR ] [ - dr ] [ - tp TASK_PARAMS ] dag_id task_id execution_date ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任务的id | | &lt;kbd&gt;执行日期&lt;/kbd&gt; | DAG的执行日期 | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-dr, - dr_run&lt;/kbd&gt; | 进行干运行默认值:False | | &lt;kbd&gt;-tp, - task_params&lt;/kbd&gt; | | | 向任务发送JSON params dict | ### 取消暂停 恢复暂停的DAG ``` airflow unpause [ - h ] [ - sd SUBDIR ] dag_id ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | ### dag_state 获取dag run的状态 ``` airflow dag_state [ - h ] [ - sd SUBDIR ] dag_id execution_date ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;执行日期&lt;/kbd&gt; | DAG的执行日期 | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | ### 跑 运行单个任务实例 ``` airflow run [ - h ] [ - sd SUBDIR ] [ - m ] [ - f ] [ -- pool POOL ] [ -- cfg_path CFG_PATH ] [ - l ] [ - A ] [ - i ] [ - I ] [ -- ship_dag ] [ - p PICKLE ] [ - int ] dag_id task_id execution_date ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任务的id | | &lt;kbd&gt;执行日期&lt;/kbd&gt; | DAG的执行日期 | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-m, - mark_success&lt;/kbd&gt; | | | 将作业标记为成功而不运行它们默认值:False | | &lt;kbd&gt;-f, - force&lt;/kbd&gt; | 忽略先前的任务实例状态,无论任务是否已成功/失败,都重新运行默认值:False | | &lt;kbd&gt;--pool&lt;/kbd&gt; | 要使用的资源池 | | &lt;kbd&gt;--cfg_path&lt;/kbd&gt; | 要使用的配置文件的路径而不是airflow.cfg | | &lt;kbd&gt;-l, - 本地&lt;/kbd&gt; | 使用LocalExecutor运行任务默认值:False | | &lt;kbd&gt;-A, - ignore_all_dependencies&lt;/kbd&gt; | | | 忽略所有非关键依赖项,包括ignore_ti_state和ignore_task_deps默认值:False | | &lt;kbd&gt;-i,--ignore_dependencies&lt;/kbd&gt; | | | 忽略特定于任务的依赖项,例如upstream,depends_on_past和重试延迟依赖项默认值:False | | &lt;kbd&gt;-I, - signore_depends_on_past&lt;/kbd&gt; | | | 忽略depends_on_past依赖项(但尊重上游依赖项)默认值:False | | &lt;kbd&gt;--ship_dag&lt;/kbd&gt; | 泡菜(序列化)DAG并将其运送给工人默认值:False | | &lt;kbd&gt;-p, - pickle&lt;/kbd&gt; | 整个dag的序列化pickle对象(内部使用) | | &lt;kbd&gt;-int, - interactive&lt;/kbd&gt; | | | 不捕获标准输出和错误流(对交互式调试很有用)默认值:False | ### list_tasks 列出DAG中的任务 ``` airflow list_tasks [ - h ] [ - t ] [ - sd SUBDIR ] dag_id ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-t, - 树&lt;/kbd&gt; | 树视图默认值:False | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | ### 回填 在指定的日期范围内运行DAG的子部分。 如果使用reset_dag_run选项,则回填将首先提示用户气流是否应清除回填日期范围内的所有先前dag_run和task_instances。如果使用rerun_failed_tasks,则回填将自动重新运行回填日期范围内的先前失败的任务实例。 ``` airflow backfill [ - h ] [ - t TASK_REGEX ] [ - s START_DATE ] [ - e END_DATE ] [ - m ] [ - l ] [ - x ] [ - i ] [ - I ] [ - sd SUBDIR ] [ -- pool POOL ] [ -- delay_on_limit DELAY_ON_LIMIT ] [ - dr ] [ - v ] [ - c CONF ] [ -- reset_dagruns ] [ -- rerun_failed_tasks ] dag_id ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-t, - task_regex&lt;/kbd&gt; | | | 用于过滤特定task_ids以回填的正则表达式(可选) | | &lt;kbd&gt;-s, - start_date&lt;/kbd&gt; | | | 覆盖start_date YYYY-MM-DD | | &lt;kbd&gt;-e, - end_date&lt;/kbd&gt; | 覆盖end_date YYYY-MM-DD | | &lt;kbd&gt;-m, - mark_success&lt;/kbd&gt; | | | 将作业标记为成功而不运行它们默认值:False | | &lt;kbd&gt;-l, - 本地&lt;/kbd&gt; | 使用LocalExecutor运行任务默认值:False | | &lt;kbd&gt;-x, - donot_pickle&lt;/kbd&gt; | | | 不要试图挑选DAG对象发送给工人,只要告诉工人运行他们的代码版本。默认值:False | | &lt;kbd&gt;-i,--ignore_dependencies&lt;/kbd&gt; | | | 跳过上游任务,仅运行与正则表达式匹配的任务。 仅适用于task_regex默认值:False | | &lt;kbd&gt;-I, - signore_first_depends_on_past&lt;/kbd&gt; | | | 仅忽略第一组任务的depends_on_past依赖关系(回填DO中的后续执行依赖depends_on_past)。默认值:False | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;--pool&lt;/kbd&gt; | 要使用的资源池 | | &lt;kbd&gt;--delay_on_limit&lt;/kbd&gt; | | | 在尝试再次执行dag运行之前达到最大活动dag运行限制(max_active_runs)时等待的时间(以秒为单位)。默认值:1.0 | | &lt;kbd&gt;-dr, - dr_run&lt;/kbd&gt; | 进行干运行默认值:False | | &lt;kbd&gt;-v, - verbose&lt;/kbd&gt; | 使日志输出更详细默认值:False | | &lt;kbd&gt;-c, - conf&lt;/kbd&gt; | JSON字符串被腌制到DagRun的conf属性中 | | &lt;kbd&gt;--reset_dagruns&lt;/kbd&gt; | | | 如果设置,则回填将删除现有的与回填相关的DAG运行,并重新开始运行新的DAG运行默认值:False | | &lt;kbd&gt;--rerun_failed_tasks&lt;/kbd&gt; | | | 如果设置,则回填将自动重新运行回填日期范围的所有失败任务,而不是抛出异常默认值:False | ### list_dags 列出所有DAG ``` airflow list_dags [ - h ] [ - sd SUBDIR ] [ - r ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-r, - 报告&lt;/kbd&gt; | 显示DagBag加载报告默认值:False | ### Kerberos的 启动kerberos票证续订 ``` airflow kerberos [ - h ] [ - kt [ KEYTAB ]] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] [ principal ] ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;主要&lt;/kbd&gt; | 凯伯罗斯校长默认值:气流 | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-kt, - keytab&lt;/kbd&gt; | 密钥表默认值:airflow.keytab | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守护进程而不是在前台运行默认值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 将stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 将stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### 工人 启动Celery工作节点 ``` airflow worker [ - h ] [ - p ] [ - q QUEUES ] [ - c CONCURRENCY ] [ - cn CELERY_HOSTNAME ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-p, - do_pickle&lt;/kbd&gt; | | | 尝试将DAG对象发送给工作人员,而不是让工作人员运行他们的代码版本。默认值:False | | &lt;kbd&gt;-q, - 队列&lt;/kbd&gt; | 以逗号分隔的队列列表默认值:默认值 | | &lt;kbd&gt;-c, - 并发&lt;/kbd&gt; | | | 工作进程的数量默认值:16 | | &lt;kbd&gt;-cn, - slowry_hostname&lt;/kbd&gt; | | | 如果一台计算机上有多个worker,请设置芹菜工作者的主机名。 | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守护进程而不是在前台运行默认值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 将stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 将stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### 网络服务器 启动Airflow网络服务器实例 ``` airflow webserver [ - h ] [ - p PORT ] [ - w WORKERS ] [ - k { sync , eventlet , gevent , tornado }] [ - t WORKER_TIMEOUT ] [ - hn HOSTNAME ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - A ACCESS_LOGFILE ] [ - E ERROR_LOGFILE ] [ - l LOG_FILE ] [ -- ssl_cert SSL_CERT ] [ -- ssl_key SSL_KEY ] [ - d ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-p, - port&lt;/kbd&gt; | 运行服务器的端口默认值:8080 | | &lt;kbd&gt;-w, - 工作人员&lt;/kbd&gt; | 运行Web服务器的工作者数量默认值:4 | | &lt;kbd&gt;-k, - workerclass&lt;/kbd&gt; | | | 可能的选择:同步,eventlet,gevent,龙卷风用于Gunicorn的工人阶级默认值:同步 | | &lt;kbd&gt;-t, - worker_timeout&lt;/kbd&gt; | | | 等待Web服务器工作者的超时时间默认值:120 | | &lt;kbd&gt;-hn, - hostname&lt;/kbd&gt; | | | 设置运行Web服务器的主机名默认值:0.0.0.0 | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守护进程而不是在前台运行默认值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 将stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 将stderr重定向到此文件 | | &lt;kbd&gt;-A, - access_logfile&lt;/kbd&gt; | | | 用于存储Web服务器访问日志的日志文件。 使用' - '打印到stderr。默认值: - | | &lt;kbd&gt;-E, - error_logfile&lt;/kbd&gt; | | | 用于存储Web服务器错误日志的日志文件。 使用' - '打印到stderr。默认值: - | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | | &lt;kbd&gt;--ssl_cert&lt;/kbd&gt; | Web服务器的SSL证书的路径 | | &lt;kbd&gt;--ssl_key&lt;/kbd&gt; | 用于SSL证书的密钥的路径 | | &lt;kbd&gt;-d, - debug&lt;/kbd&gt; | 在调试模式下使用Flask附带的服务器默认值:False | ### 花 开始芹菜花 ``` airflow flower [ - h ] [ - hn HOSTNAME ] [ - p PORT ] [ - fc FLOWER_CONF ] [ - u URL_PREFIX ] [ - a BROKER_API ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-hn, - hostname&lt;/kbd&gt; | | | 设置运行服务器的主机名默认值:0.0.0.0 | | &lt;kbd&gt;-p, - port&lt;/kbd&gt; | 运行服务器的端口默认值:5555 | | &lt;kbd&gt;-fc, - flowers_conf&lt;/kbd&gt; | | | 花的配置文件 | | &lt;kbd&gt;-u, - url_prefix&lt;/kbd&gt; | | | Flower的URL前缀 | | &lt;kbd&gt;-a, - broker_api&lt;/kbd&gt; | | | 经纪人api | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守护进程而不是在前台运行默认值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 将stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 将stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### 调度 启动调度程序实例 ``` airflow scheduler [ - h ] [ - d DAG_ID ] [ - sd SUBDIR ] [ - r RUN_DURATION ] [ - n NUM_RUNS ] [ - p ] [ -- pid [ PID ]] [ - D ] [ -- stdout STDOUT ] [ -- stderr STDERR ] [ - l LOG_FILE ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-d, - dag_id&lt;/kbd&gt; | 要运行的dag的id | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-r, - 运行时间&lt;/kbd&gt; | | | 设置退出前执行的秒数 | | &lt;kbd&gt;-n, - num_runs&lt;/kbd&gt; | 设置退出前要执行的运行次数默认值:-1 | | &lt;kbd&gt;-p, - do_pickle&lt;/kbd&gt; | | | 尝试将DAG对象发送给工作人员,而不是让工作人员运行他们的代码版本。默认值:False | | &lt;kbd&gt;--pid&lt;/kbd&gt; | PID文件位置 | | &lt;kbd&gt;-D, - damon&lt;/kbd&gt; | 守护进程而不是在前台运行默认值:False | | &lt;kbd&gt;--stdout&lt;/kbd&gt; | 将stdout重定向到此文件 | | &lt;kbd&gt;--stderr&lt;/kbd&gt; | 将stderr重定向到此文件 | | &lt;kbd&gt;-l, - log-file&lt;/kbd&gt; | 日志文件的位置 | ### task_state 获取任务实例的状态 ``` airflow task_state [ - h ] [ - sd SUBDIR ] dag_id task_id execution_date ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | | &lt;kbd&gt;TASK_ID&lt;/kbd&gt; | 任务的id | | &lt;kbd&gt;执行日期&lt;/kbd&gt; | DAG的执行日期 | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | ### 池 池上的CRUD操作 ``` airflow pool [ - h ] [ - s NAME SLOT_COUNT POOL_DESCRIPTION ] [ - g NAME ] [ - x NAME ] ``` #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-s, - set&lt;/kbd&gt; | 分别设置池槽数和描述 | | &lt;kbd&gt;-g, - get&lt;/kbd&gt; | 获取泳池信息 | | &lt;kbd&gt;-x, - 删除&lt;/kbd&gt; | 删除池 | ### serve_logs 由工人生成的服务日志 ``` airflow serve_logs [ - h ] ``` ### 明确 清除一组任务实例,就好像它们从未运行过一样 ``` airflow clear [ - h ] [ - t TASK_REGEX ] [ - s START_DATE ] [ - e END_DATE ] [ - sd SUBDIR ] [ - u ] [ - d ] [ - c ] [ - f ] [ - r ] [ - x ] [ - dx ] dag_id ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-t, - task_regex&lt;/kbd&gt; | | | 用于过滤特定task_ids以回填的正则表达式(可选) | | &lt;kbd&gt;-s, - start_date&lt;/kbd&gt; | | | 覆盖start_date YYYY-MM-DD | | &lt;kbd&gt;-e, - end_date&lt;/kbd&gt; | 覆盖end_date YYYY-MM-DD | | &lt;kbd&gt;-sd, - subdir&lt;/kbd&gt; | 从中查找dag的文件位置或目录默认值:/ Users / kaxil / airflow / dags | | &lt;kbd&gt;-u, - upstream&lt;/kbd&gt; | 包括上游任务默认值:False | | &lt;kbd&gt;-d, - downstream&lt;/kbd&gt; | | | 包括下游任务默认值:False | | &lt;kbd&gt;-c, - no_confirm&lt;/kbd&gt; | | | 请勿要求确认默认值:False | | &lt;kbd&gt;-f, - only_failed&lt;/kbd&gt; | | | 只有失败的工作默认值:False | | &lt;kbd&gt;-r, - only_running&lt;/kbd&gt; | | | 只运行工作默认值:False | | &lt;kbd&gt;-x, - exclude_subdags&lt;/kbd&gt; | | | 排除子标记默认值:False | | &lt;kbd&gt;-dx, - dag_regex&lt;/kbd&gt; | | | 将dag_id搜索为正则表达式而不是精确字符串默认值:False | ### UPGRADEDB 将元数据数据库升级到最新版本 ``` airflow upgradedb [ - h ] ``` ### delete_dag 删除与指定DAG相关的所有DB记录 ``` airflow delete_dag [ - h ] [ - y ] dag_id ``` #### 位置参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;dag_id&lt;/kbd&gt; | dag的id | #### 命名参数 <colgroup><col class="option"><col class="description"></colgroup> | &lt;kbd&gt;-y, - 是的&lt;/kbd&gt; | 不要提示确认重置。 小心使用!默认值:False |