airflow Operators 20190927 一、 Dag 编写步骤 import DAG类和若干operater类以及必要的Python模块 设定默认参数,创建DAG对象 提供必要的参数(比如task_id和dag),创建Task(即Operator对象) 设定Task的上下游依赖关系 1. import DAG类 import airflow from airflow import DAG from airflow.operators.bash_operator import BashOperator …