擅长:python、mysql、java
<p>当然,格式和你的问题有关。我有相同的用例需要解决,但是输出的是文件,而不是googlebigquery数据集。对我来说,具有以下BODY参数的代码正在启动google数据流管道:</p>
<pre><code>BODY = {
"jobName": "{jobname}".format(jobname=JOBNAME),
"parameters": {
"inputLocations" : "{{\"location1\":\"gs://{bucket}/employee/input/patient.json\"}}".format(bucket=BUCKET),
"outputLocations": "{{\"location1\":\"gs://{bucket}/employee/employees.json/file\",\"location2\":\"gs://{bucket}/jobrun/employees_314804/.profiler/profilerTypeCheckHistograms.json/file\",\"location3\":\"gs://{bucket}/jobrun/employees_314804/.profiler/profilerValidValueHistograms.json/file\"}}".format(bucket=BUCKET)
},
"environment": {
"tempLocation": "gs://{bucket}/employee/temp".format(bucket=BUCKET),
"zone": "us-central1-f"
}
}
</code></pre>