Bigquery分区日期Python

from google.cloud import bigquery

client = bigquery.Client()

table_id = "project.dataset.table"  # 表的ID
schema = [
    bigquery.SchemaField("id", "INTEGER"),
    bigquery.SchemaField("name", "STRING"),
    bigquery.SchemaField("date", "DATE")
]

table = bigquery.Table(table_id, schema=schema)
table.time_partitioning = bigquery.TimePartitioning(
    type_=bigquery.TimePartitioningType.DAY,
    field="date"
)

table = client.create_table(table)  # 创建分区表

from google.cloud import bigquery

client = bigquery.Client()

table_id = "project.dataset.table"  # 表的ID

rows = [
    {"id": 1, "name": "John", "date": "2022-01-01"},
    {"id": 2, "name": "Jane", "date": "2022-01-02"},
    {"id": 3, "name": "Bob", "date": "2022-01-03"}
]

errors = client.insert_rows_json(table_id, rows)  # 插入数据

if errors == []:
    print("Data inserted successfully.")
else:
    print("Encountered errors while inserting data.")

from google.cloud import bigquery

client = bigquery.Client()

table_id = "project.dataset.table"  # 表的ID

query = """
    SELECT *
    FROM `project.dataset.table`
    WHERE date BETWEEN DATE('2022-01-01') AND DATE('2022-01-31')
"""

query_job = client.query(query)  # 执行查询

results = query_job.result()  # 获取查询结果

for row in results:
    print(row)