您如何通过gcloud api消耗数据流作业? [英] How do you drain a dataflow job through the gcloud api?

问题描述

是否可以通过gcloud api耗尽正在运行的数据流作业?具体来说，是否有此功能的python实现或请求结构的文档，以便可以实现?能够在不使用cli的情况下自动执行排空并重新配置数据流流作业会很好.

Is it possible to drain a running dataflow job through the the gcloud api? Specifically is there a python implementation of this, or documentation of the request structure so that it can be implemented? It would be nice to be able to automate draining, and reconfiguring dataflow streaming jobs without the use of the cli.

推荐答案

我能够通过此类似答案

POST更新请求的正文:

Body for POST Update request:

{"requestedState":"JOB_STATE_DRAINING"}

{ "requestedState": "JOB_STATE_DRAINING" }

这篇关于您如何通过gcloud api消耗数据流作业?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！