如何在气流中创建自定义运算符并将其用于通过云编写器运行的气流模板(在Google云平台中)

sai*_*ran 5 python apache google-cloud-platform airflow google-cloud-composer

我需要创建一个自定义气流操作符,我应该能够在云编写器中运行的气流模板(写在python中)中使用...

如果我创建自定义气流运算符,我如何在云上运行的模板中使用它(如何使其可供所有人使用,以便他们可以使用该运算符)

kax*_*xil 6

您需要使用Airflow插件.https://airflow.apache.org/plugins.html

Airflow内置了一个简单的插件管理器,可以通过简单地删除$ AIRFLOW_HOME/plugins文件夹中的文件将外部功能集成到其核心.插件文件夹中的python模块将被导入,钩子,操作符,传感器,宏,执行器和Web视图将集成到Airflow的主要集合中,并可供使用.

看看这里的例子:https://github.com/airflow-plugins