我想用PYTHON执行Google数据流模板。实际上,我一直在使用Dataflow REST API
或Cloud Functions
集成来执行数据流模板。这是我在Postman中执行的数据流模板:
网址:https://dataflow.googleapis.com/v1b3/projects/{{my-project-id}}/templates:launch?gcsPath=gs://{{my-cloud-storage-bucket}}/temp/cloud-dataprep-template
{
"jobName": "test-datfalow-job",
"parameters": {
"inputLocations" : "{\"location1\":\"gs://{{my-cloud-storage-bucket}}/my-folder/**/*\"}",
"outputLocations": "{\"location1\":\"gs://{{my-cloud-storage-bucket}}/my-output/output.csv\"}"
},
"environment": {
"tempLocation": "gs://{{my-cloud-storage-bucket}}/tmp",
"zone": "us-central1-f"
}
}
我不知道是否有机会使用googleapi python客户端,或者我必须使用python的请求.post以及谷歌云认证
您可以使用来自Dataflow API Client Library for Python的模板launch方法,如下所示:
相关问题 更多 >
编程相关推荐