是否可以通过gcloud api来引流正在运行的数据流作业?具体来说是否有这个的python实现,或者留档请求结构以便实现?如果能够自动引流,并且在不使用cli的情况下重新配置数据流作业,那就太好了。
由于这个类似的答案,我能够通过Rest更新API消耗正在运行的数据流。
POST更新请求的正文:
{"request estedState":"JOB_STATE_DRAINING"}