如果您发现BigQuery分区表(按DAY分区)未分区,则可能是因为您没有按照正确的方式创建表。您需要确保在创建表时使用正确的分区字段和分区类型,并正确插入分区数据。
使用Python创建BigQuery分区表时,您可以按照以下示例代码中的方式指定分区字段和类型:
from google.cloud import bigquery
client = bigquery.Client()
table_ref = client.dataset('my_dataset').table('my_partitioned_table')
schema = [
bigquery.SchemaField('name', 'STRING'),
bigquery.SchemaField('date', 'DATE')
]
table = bigquery.Table(table_ref, schema=schema)
table.partitioning_type = 'DAY'
table.partitioning_field = 'date'
table = client.create_table(table)
在正确创建分区表后,您可以使用以下代码样本向表中插入分区数据:
rows_to_insert = [
('Name 1', '2019-01-01'),
('Name 2', '2019-01-02'),
('Name 3', '2019-01-03'),
]
errors = client.insert_rows(table, rows_to_insert)
if errors == []:
print('Rows inserted successfully')