Google BigQuery Connector リファレンス

Google BigQuery は、データを保管してアクセスするためのウェアハウスであり、データセットをリアルタイムで分析するためのツールも提供しています。

始める前に

  • Google BigQuery Connector を使用するには、 Google ワークスペース​のアカウントが必要です。コンポーザーから個人の Google アカウントへの接続は許可されません。

    Google ワークスペースのアカウントに接続すると、コンポーザーが 未確認のアプリケーション​であることを示すメッセージが表示されます。これは想定される動作です。このメッセージをバイパスしてコネクタを使用するには、​「このアプリは Google で確認されていません」​のダイアログで ​[詳細]​ ​> [[プロジェクト名](安全ではないページ) に移動] > [許可]​ をクリックします。

  • Google BigQuery Connector では、Google の制限されたデータにアクセスするために、サードパーティアプリケーションのアクセス権が必要です。コネクタを使用する前に、Google ワークスペース管理者は、 設定されたアプリケーションのリストに次のクライアント ID を追加​して、コンポーザーとの OAuth 接続を作成する必要があります。

    292130641403-rlgmr379unk36nuvpba0sd1u3u9c6vap.apps.googleusercontent.com

接続

include:composer::_partials/connection-definition.adoc[]

Connection Display Name (接続表示名)

この接続の詳細を把握するのに役立つ接続名を入力します。 1 つのフローおよび複数のフローで接続を複数回再利用できます。接続の作成後、ログイン情報は非表示になります。そのため、この接続を他の接続と簡単に区別できる名前を付けると役立ちます。

接続は自分にのみ表示されます。コンポーザーアプリケーションの他のユーザーは、独自の接続を作成する必要があります。

Project ID (プロジェクト ID)

Google BigQuery から取得したプロジェクト ID。

Username (ユーザー名)

Google BigQuery にログインするために使用する OAuth ユーザー名。

Password (パスワード)

Google BigQuery にログインするために使用する OAuth パスワード。

データ型

Google BigQuery では、次のデータ型がサポートされています。

  • INT64

  • BIGNUMERIC

  • BOOL

  • BYTES

  • DATE

  • DATETIME

  • FLOAT64

  • JSON

  • NUMERIC

  • STRING

  • TIME

  • TIMESTAMP

Triggers (トリガー)

include:composer::_partials/trigger-definition.adoc[]

特定のプロジェクト ID では、US ベースのデータセットが取得されます。
On New Row Source (新規行のソース)

15 秒ごとにウォーターマークに基づいてテーブルのすべての新しい行を返します。次の項目の値を指定します。

  • Dataset name (データセット名)

  • Table name (テーブル名)

  • New Watermark Column (新規ウォーターマーク列)​: この項目では、次の列のデータ型を使用できます。

    • DATE

    • DATETIME

On New or Updated Row Source (新規または更新済み行のソース)

15 秒ごとにウォーターマークに基づいてテーブルのすべての新しい行または更新された行を返します。次の項目の値を指定します。

  • Dataset name (データセット名)

  • Table name (テーブル名)

  • New Watermark Column (新規ウォーターマーク列)​: この項目では、次の列のデータ型を使用できます。

    • DATE

    • DATETIME

  • Update Watermark Column (更新ウォーターマーク列)​: この項目では、次の列のデータ型を使用できます。

    • DATE

    • DATETIME

Polling Frequency (ポーリング頻度)

include:composer::_partials/polling-frequency.adoc[]

アクション

include:composer::_partials/action-definition.adoc[]

Insert Rows

1 つ以上の行をテーブルに挿入してテーブルを更新します。​[SQL string (SQL 文字列)]​ の値を指定します。

Update Rows

行のセットを更新します。​[SQL string (SQL 文字列)]​ の値を指定します。

Delete Rows

行のセットを削除します。​[SQL string (SQL 文字列)]​ の値を指定します。

Select Rows

行のセットを取得します。​[SQL string (SQL 文字列)]​ の値を指定します。

Input Parameters (入力パラメーター)

クエリステートメントにパラメーター値を含めるには、​:​ に続けてパラメーター名を指定します (例: Select field from dataset.table where field = :param1​)。パラメーターの値は ​[Input Parameters (入力パラメーター)]​ セクションで定義します。たとえば、​param1​ の値を ​12345​ として定義すると、このクエリステートメントは ​Select field from dataset.table where field = 12345​ として解釈されます。

パラメーターの値は、リテラル文字列、または先行するアクションの出力値として定義する必要があります。String (文字列) または Date (日付) データ型の入力パラメーター値は、式エディターを使用して、単一引用符で囲んで指定する必要があります。リテラル文字列の場合は、エディターで単一引用符を ​’12345’​ のように値に追加します。先行するアクションからの出力値の場合は、カスタム式オプションを選択し、エディターでカスタム式を ​’Field From Previous Step’​ のように単一引用符で囲んで、変更を適用します。

Google BigQuery™ は Google LLC の商標です。

include:composer::_partials/see-also.adoc[]