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 trigger_dag dag_id -r RUN_ID -e EXEC_DATE  運行整個dag文件

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 clear dag_id 清空任務實例

使用REST API遠程調用執行airflow的命令:

• airflow trigger_dag

http://localhost:8080/admin/airflow/trigger?dag_id=example_hello_world_dag

• airflow run

http://localhost:8080/admin/airflow/run?dag_id=example_hello_world_dag&task_id=sleep_task&execution_date=20180807&ignore_all_deps=true&origin=/admin