擅长:python、mysql、java
<p>下面是将数据帧加载到BQ的代码片段:</p>
<pre><code>import pandas as pd
from google.cloud import bigquery
# Example data
df = pd.DataFrame({'a': [1,2,4], 'b': ['123', '456', '000']})
# Load client
client = bigquery.Client(project='your-project-id')
# Define table name, in format dataset.table_name
table = 'your-dataset.your-table'
# Load data to BQ
job = client.load_table_from_dataframe(df, table)
</code></pre>
<p>如果您只想指定模式的一个子集,但仍要导入所有列,则可以使用</p>
<pre><code># Define a job config object, with a subset of the schema
job_config = bigquery.LoadJobConfig(schema=[bigquery.SchemaField('b', 'STRING')])
# Load data to BQ
job = client.load_table_from_dataframe(df, table, job_config=job_config)
</code></pre>