我正在尝试创建一个云函数,它将检查某些预定查询的状态,以便触发另一个进程。我正尝试在main.py中使用下面的代码
from google.cloud import bigquery
from google.cloud import bigquery_datatransfer
def extract_data(event, context):
transfer_client = bigquery_datatransfer.DataTransferServiceClient()
project_id = "projects/whr-asia-datalake-nonprod"
configs = transfer_client.list_transfer_configs(parent=project_id)
print("Got the following configs:")
for config in configs:
print(f"\tID: {config.name}, Schedule: {config.schedule}")
在requirements.txt中,我添加了以下代码
google-cloud-bigquery-datatransfer==1
google-cloud-bigquery==1
得到如上所示的空响应。我已经安排了今天运行的查询。可能的问题是什么?
发布于 2021-11-04 12:26:20
我也有类似的问题,但只能看到几个查询。事实证明,默认情况下,它只从美国提取查询。
https://github.com/googleapis/google-cloud-python/issues/8466#issuecomment-610772303
不确定这到底是不是你的问题,但将位置添加到项目中,它应该从其他地区拉动。
def get_scheduled_queries():
transfer_client = bigquery_datatransfer.DataTransferServiceClient()
parent = transfer_client.common_project_path(project_id + "/locations/EU")
configs = transfer_client.list_transfer_configs(parent=parent)
for config in configs:
https://stackoverflow.com/questions/66226254
复制相似问题