在使用 BigQuery 表格结果的类型转换选项时,可以采用以下示例代码:
使用 StandardSQL:
from google.cloud import bigquery
client = bigquery.Client()
query_job = client.query(
"""
SELECT *
FROM mydataset.mytable
"""
)
table = query_job.to_dataframe(create_bqstorage_client=True)
# Convert TIMESTAMP columns to Python datetime objects
table['timestamp_column'] = pd.to_datetime(table['timestamp_column'])
# Convert ARRAY columns to Python list objects
table['array_column'] = table['array_column'].apply(list)
使用 Legacy SQL:
from google.cloud import bigquery
client = bigquery.Client()
query_job = client.query(
"""
SELECT *
FROM [mydataset.mytable]
"""
)
table = query_job.to_dataframe()
# Convert TIMESTAMP columns to Python datetime objects
table['timestamp_column'] = pd.to_datetime(table['timestamp_column'])
# Convert ARRAY columns to Python list objects
table['array_column'] = table['array_column'].apply(list)
以上代码演示了如何将 BigQuery 表格结果中的 TIMESTAMP 和 ARRAY 字段分别转换为 Python datetime 对象和列表对象。通过采用这些选项中的一种或多种,可以更容易地处理 BigQuery 中的数据。