如何从 GCP 中的 Cloud Functions 调用用 Python(3.x) 编写的数据流作业答案

【问题标题】：How to call a Dataflow job written in Python(3.x) from Cloud Functions in GCP如何从 GCP 中的 Cloud Functions 调用用 Python(3.x) 编写的数据流作业
【发布时间】：2019-08-30 05:49:07
【问题描述】：

我的目标是创建一种机制，当新文件上传到 Cloud Storage 时，它会触发 Cloud Function。最终，此 Cloud 函数将触发 Cloud Dataflow 作业。我有一个限制，即 Cloud Dataflow 作业应该用 Python 编写，而 Cloud Function 也应该用 Python 编写。我现在面临的问题是，我无法从 Cloud Function 调用 Cloud Dataflow 作业。

【问题讨论】：

标签： google-cloud-functions google-cloud-dataflow

【解决方案1】：

是的，你可以！从packaging your Dataflow Job in a template 开始。为了读取输入值，需要执行一些更新。这仅更改作业标题/配置，而不是“真正的”处理

那么，trigger your template with API Rest。没有python库，但有答案here with code example

【讨论】：