Airflow的bitshift composition
特征返回的类型是airflow.operators.bitshiftcomposer.BitshiftComposer
。可以使用以下代码示例创建一个简单的DAG来测试该特性:
from airflow import DAG
from airflow.operators.bitshiftcomposer import BitshiftComposer
from datetime import datetime
default_args = {
'start_date': datetime(2021, 1, 1),
'owner': 'airflow',
}
dag = DAG(
'bitshift_composition_dag',
default_args=default_args,
schedule_interval='@daily'
)
# 创建三个算子
operator_1 = BitshiftComposer(task_id='operator_1', argument='foo >> 2', dag=dag)
operator_2 = BitshiftComposer(task_id='operator_2', argument='bar << 4', dag=dag)
operator_3 = BitshiftComposer(task_id='operator_3', argument='(baz | qux) & 3', dag=dag)
# 设置算子依赖关系
operator_1 >> operator_2 >> operator_3