设计建议从 Airflow 调用 Cloud Build 以执行带参数的 python 函数
Design advice calling Cloud Build from Airflow to execute a python function that takes args
我正在寻求一些设计建议和任何使用 Cloud Build 执行带参数的 python 函数的示例。
我有一个在 GCP 上使用 Airflow 的数据管道。某些文件在加载到 BigQuery 之前需要清理。我有一个 Python 函数可以完成这项工作。
我想要的是 运行 在 Cloud Build 图像上运行并从我的管道传递函数参数。
到目前为止,我有一个安装的 Cloud Build 触发器,运行 是一个没有参数的简单 Python 函数。
根据我的研究,我发现了两个选项,cloudbuild_v1 库和 Cloud Build Airflow 运算符。
我想就我应该使用哪个选项或是否应该考虑其他选项以及任何可用示例提出建议。
谢谢。
我正在寻求一些设计建议和任何使用 Cloud Build 执行带参数的 python 函数的示例。
我有一个在 GCP 上使用 Airflow 的数据管道。某些文件在加载到 BigQuery 之前需要清理。我有一个 Python 函数可以完成这项工作。 我想要的是 运行 在 Cloud Build 图像上运行并从我的管道传递函数参数。
到目前为止,我有一个安装的 Cloud Build 触发器,运行 是一个没有参数的简单 Python 函数。
根据我的研究,我发现了两个选项,cloudbuild_v1 库和 Cloud Build Airflow 运算符。
我想就我应该使用哪个选项或是否应该考虑其他选项以及任何可用示例提出建议。
谢谢。