如何解决DataflowTemplateOperator 参数
大家好,我有下一个代码来触发我的数据流模板
def run_dataflow(template,params):
start_template_job = DataflowTemplateOperator(
task_id="sample_task",template=template,parameters=params,dag=dag
)
return start_template_job
end = DummyOperator(
task_id='end',dag=dag
)
sample_task=run_dataflow(
'gs://template/path',{
'inputFile': 'gs://sample/file.csv','output': 'gs://path/temp'
}
)
start >> sample_task
sample_task >> end
但我有下一个结果
googleapiclient.errors.HttpError: <HttpError 400 when requesting
The workflow could not be created. Causes: (2b7c42b31f66f3d8): Found unexpected parameters: ['inputFile' (perhaps you meant 'update'),'output' (perhaps you meant 'update')]"
你能帮我吗?我不知道我必须使用哪些参数。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。