Golang 客户端库支持 Apache Airflow

Question

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

Answer 1

事实上，Composer 是Apache Airflow的托管版本，其中 dags 用 Python 描述，并且仅用 Python 描述。

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