我知道有 PythonOperator 在气流中,但我想知道是否有任何类似于 RecipeOperator 在DAG中运行配方。如果没有,我怎么能创建一个?
PythonOperator
RecipeOperator
没有一个内置的RecipeOperator。然而,你确实可以用Airflow创建你自己的操作员。https:/airflow.apache.orgdocsstablehowtocustom-operator.html。
你可以创建运营商你常用的配方,然后按照你刚才的描述调用它们。