Golang 客户端库支持 Apache Airflow



我正在使用Google云作曲家,它基本上为您提供了一个Apache Airflow环境。由于我的应用程序是用 Golang 编写的,因此我一直在寻找一个 golang 客户端库来在 Cloud Composer Airflow 环境中创建和执行 DAG。如果有的话,请告诉我。

多亏了你的澄清,你不能!事实上,Composer是Apache Airflow的托管版本,其中dags在Python和Python中描述。

您可以使用Go访问Composer/Airflow API,可以使用Go和Go模板生成Python代码。您还可以在 Airflow 中定义一个自定义运算符,该运算符使用正确的参数运行 Go 二进制文件。但是,自定义运算符本身必须用 Python 编写。

最新更新