Запись кадра данных обратно в таблицу BQ

Question

job_config = bigquery.LoadJobConfig()
# job_config.autodetect = True
# job_config.source_format = bigquery.SourceFormat.NEWLINE_DELIMITED_JSON

job_config = bigquery.LoadJobConfig(schema=[
    bigquery.SchemaField("Weekend", "INT64")

])
job_config.write_disposition = "WRITE_TRUNCATE"

job = client.load_table_from_dataframe(
    full_df_at, table_id, job_config=job_config
)

# Wait for the load job to complete.
job.result()
print('A table {} is created'.format(table_id))

Этот код приводит к следующей ошибке.

TypeError                                 Traceback (most recent call last)
<ipython-input-39-c4a9bfab1edc> in <module>
      5 
      6 job_config = bigquery.LoadJobConfig(schema=[
----> 7     bigquery.SchemaField("Weekend", "INT64")
      8 
      9 ])

TypeError: __init__() got an unexpected keyword argument 'schema'

Как мне решить? Этот код работает нормально. Это из-за изменений в Pandas обновлениях? Как мне заставить этот код работать?

Answer 1

Вы можете попробовать:

job_config = bigquery.LoadJobConfig()
# job_config.autodetect = True
# job_config.source_format = bigquery.SourceFormat.NEWLINE_DELIMITED_JSON

job_config.schema = [
        bigquery.SchemaField("Weekend", "INT64")
   ]

job_config.write_disposition = "WRITE_TRUNCATE"

job = client.load_table_from_dataframe(
    full_df_at, table_id, job_config=job_config
)

# Wait for the load job to complete.
job.result()
print('A table {} is created'.format(table_id)) 

Вы можете проверить Python Клиент для Google BigQuery , где вы можете найти пример использования LoadJobConfig.