我的目标是创建一种机制,当新文件上传到云存储中时,它将触发云函数。最终,此Cloud function将触发Cloud Dataflow作业。我有一个限制,云数据流作业应该用Python编写,云函数也应该用Python编写。我现在面临的问题是,我不能从Cloud Function调用Cloud Dataflow作业。
发布于 2019-08-30 19:51:57
是的,你可以的!从packaging your Dataflow Job in a template开始。为了读取输入值,需要执行一些更新。这只改变了作业头/配置,而不是“真正的”处理
然后是trigger your template with API Rest。这里没有python库,但是有一个答案是here with code example
https://stackoverflow.com/questions/57721124
复制相似问题