Google BigQuery - Select rows using custom SQL and insert into table (batch)
Select rows using custom SQL and insert into tableバッチアクションは、カスタムSQLクエリを実行し、結果を宛先テーブルに書き込みます。 これを使用して、ダウンストリームで使用するデータをステージングまたは変換します。 クエリに60秒を超える時間がかかる場合、Wait for query to complete?がYesに設定されていない限り、アクションは非同期モードに切り替わります。
このアクションは結果の最初のページを返し、次のページトークンが含まれる場合があります。 必要に応じて追加の結果を取得するには、Get batch of rows by Job IDアクションを使用します。
入力
| 入力フィールド | 説明 |
|---|---|
| プロジェクト | クエリに課金するプロジェクトを選択します。 |
| クエリ | 実行するSQLクエリを入力します。 バインド変数を宣言するには@を使用します。 |
| パラメーター | クエリで宣言されたバインド変数をマッピングします。 たとえば、クエリがselect * from table where id = @idの場合は、idという名前のパラメーターを指定します。 |
| 出力フィールド | 想定される出力フィールドを定義します。 これらは、クエリによって返される列名と一致している必要があります。 |
| 場所 | クエリを実行するリージョンを選択します。 |
| クエリの完了を待機しますか? | クエリの実行が完了するまで待機するには、Yesに設定します。 Noに設定した場合、アクションは60秒待機してからジョブIDのみを返します。 後で結果を取得するには、Get batch of rows by Job IDアクションを使用します。 |
| 宛先テーブル | クエリ結果を書き込むテーブルを入力します。 |
| 作成処理 | アクションが宛先テーブルを作成するかどうかを制御します。 テーブルが存在しない場合に作成するには、Create if neededをクリックします。 テーブルが存在しない場合にエラーを返すには、Never createをクリックします。 |
| 書き込み処理 | アクションが宛先テーブルにデータを書き込む方法を制御します。 テーブルを上書きするには、Write truncateをクリックします。 行を追加するには、Write appendをクリックします。 テーブルにすでにデータが含まれている場合にエラーを返すには、Write emptyをクリックします。 |
出力
| 出力フィールド | 説明 |
|---|---|
| 行 | 行オブジェクトの配列。 各データピルは結果内の列に対応します。 |
| 種類 | 実行されたジョブのタイプ。 成功したクエリの場合、これはqueryResponseです。 |
| ジョブ参照 | 実行されたジョブのプロジェクトID、ジョブID、場所が含まれます。 さらに結果を取得するには、Get batch of rows by Job IDアクションを使用できます。 |
| 合計行数 | クエリによって返された行の合計数。 |
| ページトークン | 結果の次のページを取得するためのトークン。 |
| スキーマ | クエリ結果のスキーマ。 |
| Etag | 結果スキーマを表すハッシュ。 |
| 処理された合計バイト数 | クエリによって処理されたバイト数。 これはBigQueryの請求対象に含まれます。 |
| ジョブ完了 | クエリジョブのステータス。 完了している場合、これはDoneである必要があります。 |
| キャッシュヒット | クエリ結果がキャッシュから提供された場合はtrueを返します。 それ以外の場合はfalseを返します。 |
Last updated: