Я пытаюсь следовать приведенному ниже примеру для потоковой передачи данных в таблицу BigQuery.
# TODO(developer): Uncomment the lines below and replace with your values.
# from google.cloud import bigquery
# client = bigquery.Client()
# dataset_id = 'my_dataset' # replace with your dataset ID
# For this sample, the table must already exist and have a defined schema
# table_id = 'my_table' # replace with your table ID
# table_ref = client.dataset(dataset_id).table(table_id)
# table = client.get_table(table_ref) # API request
rows_to_insert = [
(u'Phred Phlyntstone', 32),
(u'Wylma Phlyntstone', 29),
]
errors = client.insert_rows(table, rows_to_insert) # API request
assert errors == []
Тем не менее, я получаю следующую ошибку:
zip-аргумент # 2 должен поддерживать итерацию
Я подозреваю, что между схемой таблицы и схемой ввода данных есть некоторое смещение. Может кто-нибудь сказать мне точно, как я могу запросить каждую из этих схем, чтобы я мог видеть, где различия, пожалуйста?
Спасибо
Josh