我试图通过API触发批处理数据流作业,所以我试图让它在这里的API资源管理器工具中工作。不幸的是,文档没有指定所需的参数是什么,所以我试了几刀,但是除了这个响应我什么也得不到:
{
"error": {
"code": 400,
"message": "Request contains an invalid argument.",
"status": "INVALID_ARGUMENT"
}
}
有效负载需要是这个Job,但该文档是已触发作业的Job属性的详尽列表。尽管如此,我还是尝试了一下:
{
"projectId": "my-project",
"location": "us-central1",
"name": "some-random-name",
"type": "JOB_TYPE_BATCH"
}
但我无法让api资源管理器返回任何有用的内容。
有人让它起作用了吗?
job. createAPI不是设计为以这种方式使用的-相反,使用Apache BeamSDK创建模板化的数据流管道,并通过带有templates.createAPI的API运行作业。