我的目标是创建一种机制，当新文件上传到云存储时，它将触发云功能。最终，此云函数将触发云数据流作业。 我有一个限制，云数据流作业应该用Python编写，云函数也应该用Python编写。 我现在面临的问题是，我无法从云函数调用云数据流作业。
最佳答案
是的，你可以!从packaging your Dataflow Job in a template开始。需要执行一些更新来读取输入值。这仅更改作业 header /配置，而不更改“真实”处理
然后，trigger your template with API Rest 。没有Python库可以解决这个问题，但有一个答案here with code example
关于google-cloud-functions - 如何从 GCP 中的 Cloud Functions 调用用 Python(3.x) 编写的 Dataflow 作业，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/57721124/