未分類

BigQuery API

from google.cloud import bigquery
from google.oauth2 import service_account
from google.oauth2.service_account import Credentials

PROJECT_NAME = "<プロジェクト名>"
DATASET_NAME = "<データセット名>"
TABLE_NAME = "<テーブル名>"
CONFIDENTIAL_FILE = 'サービスアカウントのjsonキー'
os.environ["GOOGLE_APPLICATION_CREDENTIALS"] = CONFIDENTIAL_FILE
    
client = bigquery.Client()
job_config = bigquery.QueryJobConfig(destination=“PROJECT_NAME.DATASET_NAME.TABLE_NAME”)   ここでBQの設定ができる。
    
query = "Select * from `{0}.{1}.{2}`".format(PROJECT_NAME, DATASET_NAME, TABLE_NAME)
query_job =client.query(returnBigQuery().format(PROJECT_NAME, DATABASE_NAME, "ga_raw"), job_config=job_config)
query_result_data =query_job.result()

実際このデータの型を見ると、iteratorになっている。
そのため、以下のようにfor文などで変換処理をする

for record in query_result_data:

▼ お問合せはこちら

-未分類

© 2022 Yosshi Blog Powered by AFFINGER5