pandas-gbq を使用してクエリを実行する

pandas-gbq パッケージを使用して、シンプルなクエリを実行します。

コードサンプル

Python

このサンプルを試す前に、クライアント ライブラリを使用した BigQuery クイックスタートにある Python の設定手順を完了してください。詳細については、BigQuery Python API のリファレンス ドキュメントをご覧ください。

BigQuery に対する認証を行うには、アプリケーションのデフォルト認証情報を設定します。詳細については、クライアント ライブラリの認証情報を設定するをご覧ください。

import bigframes.pandas as bpd
import pandas as pd
import pandas_gbq

# Set partial ordering mode for BigQuery DataFrames.
bpd.options.bigquery.ordering_mode = "partial"


def read_gbq_simple_pandas_gbq() -> pd.DataFrame:
    """Queries BigQuery using pandas-gbq and returns an in-memory DataFrame."""
    sql = """
    SELECT name, SUM(number) as total_people
    FROM `bigquery-public-data.usa_names.usa_1910_2013`
    WHERE state = 'TX'
    GROUP BY name
    ORDER BY total_people DESC
    LIMIT 20
    """
    df_pandas = pandas_gbq.read_gbq(sql)
    print("Queried using pandas-gbq.")
    return df_pandas


def read_gbq_simple_bigframes() -> bpd.DataFrame:
    """Queries BigQuery using BigQuery DataFrames and returns a distributed DataFrame."""
    sql = """
    SELECT name, SUM(number) as total_people
    FROM `bigquery-public-data.usa_names.usa_1910_2013`
    WHERE state = 'TX'
    GROUP BY name
    ORDER BY total_people DESC
    LIMIT 20
    """
    df_bigframes = bpd.read_gbq(sql)
    print("Queried using BigQuery DataFrames.")
    return df_bigframes


# [Preferred] Run using pandas-gbq:
# df_pandas = read_gbq_simple_pandas_gbq()
# print(df_pandas.head())

# Alternatively, run using BigQuery DataFrames:
# df_bigframes = read_gbq_simple_bigframes()
# print(df_bigframes.head())

次のステップ

他の Google Cloud プロダクトのコードサンプルを検索およびフィルタするには、Google Cloud サンプル ブラウザをご覧ください。