guillaume blaquiere 2019-10-21 12:34

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

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

Xao 1970-01-01 08:00:00

您如何将二进制文件推向气流?您是否已将其gsutil's保存到{bucket_path} / data /?

guillaume blaquiere 1970-01-01 08:00:00

@Xao,是的,这是最简单的。但是,请使用您的二进制文件创建一个文件夹,并使用您的数据创建另一个文件夹,以免两者混用!