如何使用python管理google大查询中的作业
如何使用python管理google大查询中的作业
提问于 2019-08-23 02:11:19
我是BQ的新手，我有一个简单的问题。有一个python脚本，每天执行一个装入到pandas的表。分析完成后，将数据加载到BQ，然后运行另一个sql查询将数据追加到现有表中。我的问题是，如何管理作业并检查是否所有数据都已成功下载/上传，以及最后一个查询是否运行无误？
回答 1
Stack Overflow用户
回答已采纳
发布于 2019-08-27 22:39:52
处理错误的解决方案
client = bigquery.Client()
job_config = bigquery.job.QueryJobConfig()
query_job = bigquery.job.QueryJob(str(uuid.uuid4()),
query, client=client, job_config=job_config)
query_job._begin()
while not query_job.done():
time.sleep(5)
if not query_job.errors:
#TODO页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/57614972
复制相关文章
相似问题
腾讯云开发者
