基本上,我只是想使用现有的 Google 模板 GCS_Text_to_Cloud_PubSub 在我的 DAG 中使用它来实现
DataflowTemplatedJobStartOperator
所有模板都应位于
gs://dataflow-templates/latest