airflow常用命令

Posted cord

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了airflow常用命令相关的知识,希望对你有一定的参考价值。

airflow中常用命令

airflow test dag_id task_id execution_date   测试task
示例: airflow test example_hello_world_dag hello_task 20180516

airflow run dag_id task_id execution_date 运行task

airflow run -A dag_id task_id execution_date 忽略依赖task运行task

airflow webserver -D  守护进程运行webserver

airflow scheduler -D  守护进程运行调度

airflow worker -D 守护进程运行celery worker

airflow worker -c 1 -D 守护进程运行celery worker并指定任务并发数为1

airflow pause dag_id  暂停任务

airflow unpause dag_id 取消暂停,等同于在管理界面打开off按钮

airflow list_tasks dag_id 查看task列表

 




















以上是关于airflow常用命令的主要内容,如果未能解决你的问题,请参考以下文章

代码走读 airflow

(Django)气流中的 ORM - 有可能吗?

提效小技巧——记录那些不常用的代码片段

Airflow使用技巧之-清理元数据库

在Conda环境中安装Apache-Airflow

使用 Airflow PUT 命令将 S3 文件移动到 Snowflake 阶段