Bigquery代码示例

以下是一个Python语言下使用BigQuery的代码示例，包括连接BigQuery、创建表、插入数据、查询数据等操作：

首先，需要安装`google-cloud-bigquery`库：

pip install google-cloud-bigquery

然后，连接BigQuery并创建一个数据集和一个表：

from google.cloud import bigquery

# 连接BigQuery
client = bigquery.Client()

# 创建数据集
dataset_id = 'my_dataset'
dataset_ref = client.dataset(dataset_id)
dataset = bigquery.Dataset(dataset_ref)
dataset.location = 'US'
client.create_dataset(dataset)

# 创建表
table_id = 'my_table'
schema = [
    bigquery.SchemaField('name', 'STRING', mode='REQUIRED'),
    bigquery.SchemaField('age', 'INTEGER', mode='REQUIRED'),
]
table_ref = dataset_ref.table(table_id)
table = bigquery.Table(table_ref, schema=schema)
client.create_table(table)

接下来，可以插入数据到表中：

# 插入数据
rows_to_insert = [
    ('Alice', 25),
    ('Bob', 30),
    ('Charlie', 35),
]
errors = client.insert_rows(table, rows_to_insert)
if errors:
    print('Errors occurred while inserting rows')

然后，可以查询表中的数据：

# 查询数据
query = """
    SELECT *
    FROM `my_dataset.my_table`
"""
query_job = client.query(query)
results = query_job.result()
for row in results:
    print(row)

以上是一个简单的BigQuery代码示例，包括连接BigQuery、创建表、插入数据、查询数据等操作。可以通过这个示例了解如何使用`google-cloud-bigquery`库来操作BigQuery。