我的用例涉及获取项目中存在的所有流数据流作业的作业 ID 并取消它。更新我的数据流作业的源并重新运行它。
我正在尝试使用 python 来实现这一点。直到现在我还没有遇到任何有用的文档。
我想到使用 python 的库子进程来执行 gcloud 命令作为解决方法。但我再次无法存储结果并使用它。
有人可以指导我什么是最好的方法吗？
除了直接使用其余 API 之外，您还可以使用为 API 生成的 Python 绑定谷歌 API python 客户端 https://github.com/googleapis/google-api-python-client/blob/master/docs/start.md。对于简单的调用，它不会增加太多的价值，但是当传递许多参数时，它比原始 HTTP 库更容易使用。
有了这个库，工作列表调用就会像这样
from googleapiclient.discovery import build
import google.auth
credentials, project_id = google.auth.default(scopes=['https://www.googleapis.com/auth/cloud-platform'])
df_service = build('dataflow', 'v1b3', credentials=credentials)
response = df_service.projects().locations().jobs().list(
project_id=project_id,
location='<region>').execute()
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
