我有一个 Google Cloud DataFlow pipline,我可以使用以下命令从命令行运行它:
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 代码?
最佳答案
这两篇文章解释了如何从 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作者:梅特·阿塔梅尔。
关于java - 如何从 GAME java 代码而不是 Maven 运行数据流管道?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45058213/