私はすでにこのトピックについていくつかの紹介を読みましたが、このコードは実行されませんでした。 プロジェクトで 'product_flat_index'テーブルを作成しました。この関数は、そのテーブルにクエリ結果を追加します。しかし、それは実行されませんでした。Google Bigquery API:テーブルに結果クエリを追加するにはどうすればよいですか?
def insertValues(service):
project_id = "598330041668"
dataset_id = 'recommendation_001'
table_id = 'product_flat_index'
# [START run_query]
query = ('SELECT sku, SUM(sales) AS sales, COUNT(sales) AS sales_frequency, SUM(views) AS views,'
'SUM(carts) AS carts, SUM(sales)/SUM(carts) AS sales_effective_rate,AVG(rating) AS rating,'
'SUM(comments) AS comments '
'FROM recommendation_001.user_input_product '
'GROUP BY sku '
)
configuration = {
"query": query,
}
body = {
"configuration":
{
"query": configuration,
"destinationTable": {
"projectId": project_id,
"datasetId": dataset_id,
"tableId": table_id
},
"createDisposition": "CREATE_IF_NEEDED",
"writeDisposition": "WRITE_APPEND",
},
}
return service.jobs().insert(
projectId=project_id,
body=body
).execute()
# [END run_query]