如何从GAE java代码而不是Maven运行Dataflow pipline？

Question

我有一个谷歌云DataFlow管道，我可以使用以下命令从命令行运行它：

mvn compile exec:java -Dexec.mainClass=com.dataflow.myApp -Dexec.args="--streaming --stagingLocation=gs://gcp-myApp-staging --project=myProject"

我需要使用Cron调度这个过程，并且需要从GAE java代码运行pipline。如何通过java而不是maven来运行我的pipline代码？

Answer 1

这两篇文章解释了如何从GAE运行数据流管道，并通过Cron触发它们：

1)艾米·昂鲁的《How to do data processing and analytics from Google App Engine with Google Cloud Dataflow》

2) Scheduling Dataflow pipelines using App Engine Cron Service or Cloud Functions by Mete Atamel。

Answer 2

你应该关注Configuring PipelineOptions for Execution on the Cloud Dataflow Service的帖子