bigquery.py

from google.cloud import bigquery
import sys
bigquery_client = bigquery.Client(
        project = "my-project")
query = bigquery_client.run_sync_query("select * from airflow.quotes_" + sys.argv[1])
query.run()
dataset = bigquery_client.dataset("airflow")
table = dataset.table("quotes")
table.reload()
result = table.insert_data(query.rows)
print(query.rows)
print(result)