Golang 客户端库支持 Apache Airflow

Golang client library support for Apache Airflow

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

感谢您的澄清,您不能!事实上,Composer 是 Apache Airflow 的托管版本,其中 dags 仅在 Python 和 Python 中描述。

您可以使用 Go 达到 Composer/Airflow API,您可以使用 Go 和 Go 模板生成 Python 代码。您还可以定义 custom Operator in Airflow 其中 运行 具有正确参数的 Go 二进制文件。但是,自定义运算符本身必须写在Python.