Я хотел бы выполнить запрос к таблице (t1), получить результат в python, отредактировать результат (с различной логикой, не поддерживаемой в большом запросе), а затем сохранить отредактированный результат в новой таблице (t2) в большом запрос.
Я получаю результаты из таблицы со стандартом:
Импорт
import os
os.environ['GOOGLE_APPLICATION_CREDENTIALS'] = 'path_to_json_credentials.json'
from google.cloud import bigquery
client = bigquery.Client()
QUERY = \
(
'SELECT Col1,Col2,Col3, Col4'
'FROM `dataset.table1`'
)
# API request
query_job = client.query(QUERY)
#### # Waits for query to finish
rows = query_job.result()
for row in rows:
if row.col1 = x:
row.col2 = new_val
# после редактирования сохранить обратно в bigquery
Псевдо: * +1010 *
`dataset.table2` = rows