您如何通过gcloud api消耗数据流作业?

本文介绍了您如何通过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.

推荐答案

我能够通过 Rest Update API 感谢此类似答案

POST更新请求的正文:

Body for POST Update request:

{"requestedState":"JOB_STATE_DRAINING"}

{ "requestedState": "JOB_STATE_DRAINING" }