时间戳

首页 > 解决方案 > BigQuery 字段的类型已从 STRING 更改为 TIMESTAMP

python - BigQuery 字段的类型已从 STRING 更改为 TIMESTAMP

问题描述

我正在使用 Python API 将数据导入 BigQuery：

import os
from google.cloud import bigquery
from google.cloud.exceptions import BadRequest
import json

from schema import schema


target_project_name = 'project_name'
target_dataset_name = 'dataset_name'
target_table_name = 'table_name'

os.environ["GOOGLE_APPLICATION_CREDENTIALS"] = './credentials.json'

dataset_ref = bigquery.dataset.DatasetReference(target_project_name, target_dataset_name)
table_ref = bigquery.table.TableReference(dataset_ref, target_table_name)

job_config = bigquery.LoadJobConfig()
job_config.schema = schema

client = bigquery.Client()

cnt = 0

with open('./data/transformed_v2.json', 'r') as f:
    json_list = []
    for line in f.readlines():
        cnt += 1
        if cnt >= 10:
            break
        json_contents = json.loads(line)
        json_list.append(json_contents)


    job = client.load_table_from_json(json_list, table_ref)

try:
    result = job.result()
except BadRequest as ex:
    for err in ex.errors:
        print(err)
    print(job.errors)

schema上面代码中提到的包含一个有问题的字段，migration_datetime定义为bigquery.SchemaField("migration_datetime", "STRING", mode="NULLABLE"). 该字段包含存储在'%Y-%m-%dT%H:%M:%S' format. The schema in the target table has the migration_datetime field specified asSTRING 中的值。

会job.result()引发一个错误，即Field migration_datetime has changed type from STRING to TIMESTAMP. 为了缓解这种情况，我_string在列中的值中添加了后缀，migration_datetime但错误仍然存​​在。请问您可能是什么原因？

标签： pythongoogle-bigquerydatetime-format

解决方案

考虑job_config在此处传递或使用load_table_from_jsonclient.schema_from_json

推荐阅读