我正在使用与以下代码类似的代码将zip文件从bquery提取到GCS。
有时我需要提取大约90个文件。我想提取一个压缩文件夹,而不是一一发送文件。
注意:我正在使用Jupyter。
感谢您的帮助。
from google.cloud import bigquery
client = bigquery.Client()
project_id = 'fh-bigquery'
dataset_id = 'public_dump'
table_id = 'afinn_en_165'
bucket_name = 'your_bucket'
destination_uri = 'gs://{}/{}'.format(bucket_name,'file.csv.gz')
dataset_ref = client.dataset(dataset_id,project=project_id)
table_ref = dataset_ref.table(table_id)
job_config = bigquery.job.ExtractJobConfig()
job_config.compression = 'GZIP'
extract_job = client.extract_table(
table_ref,destination_uri,job_config = job_config
)
extract_job.result()`