ワークフローから Google スプレッドシートに書き込む

YAML

main:
  steps:
    - init:
        assign:
          - folder_id: 'FOLDER_ID'
          - drive_url: 'https://www.googleapis.com/drive/v3/files/'
          - drive_auth_scope: 'https://www.googleapis.com/auth/drive'
    - create_sheet:
        call: googleapis.sheets.v4.spreadsheets.create
        args:
          body: null
          connector_params:
            scopes: 'https://www.googleapis.com/auth/drive'
        result: resp
    - get_sheet_info:
        call: http.get
        args:
          url: '${drive_url + resp.spreadsheetId}'
          query:
            fields: parents
          auth:
            type: OAuth2
            scopes: '${drive_auth_scope}'
        result: sheet_info
    - move_sheet:
        call: http.patch
        args:
          url: '${drive_url + resp.spreadsheetId}'
          query:
            addParents: '${folder_id}'
            removeParents: '${sheet_info["body"]["parents"][0]}'
          auth:
            type: OAuth2
            scopes: '${drive_auth_scope}'
        result: resp
    - return:
        return: '${resp}'

JSON

{
  "main": {
    "steps": [
      {
        "init": {
          "assign": [
            {
              "folder_id": "FOLDER_ID"
            },
            {
              "drive_url": "https://www.googleapis.com/drive/v3/files/"
            },
            {
              "drive_auth_scope": "https://www.googleapis.com/auth/drive"
            }
          ]
        }
      },
      {
        "create_sheet": {
          "call": "googleapis.sheets.v4.spreadsheets.create",
          "args": {
            "body": null,
            "connector_params": {
              "scopes": "https://www.googleapis.com/auth/drive"
            }
          },
          "result": "resp"
        }
      },
      {
        "get_sheet_info": {
          "call": "http.get",
          "args": {
            "url": "${drive_url + resp.spreadsheetId}",
            "query": {
              "fields": "parents"
            },
            "auth": {
              "type": "OAuth2",
              "scopes": "${drive_auth_scope}"
            }
          },
          "result": "sheet_info"
        }
      },
      {
        "move_sheet": {
          "call": "http.patch",
          "args": {
            "url": "${drive_url + resp.spreadsheetId}",
            "query": {
              "addParents": "${folder_id}",
              "removeParents": "${sheet_info[\"body\"][\"parents\"][0]}"
            },
            "auth": {
              "type": "OAuth2",
              "scopes": "${drive_auth_scope}"
            }
          },
          "result": "resp"
        }
      },
      {
        "return": {
          "return": "${resp}"
        }
      }
    ]
  }
}

Console

1. Google Cloud コンソールで BigQuery ページに移動します。

   BigQuery に移動

2. [クエリエディタ] のテキスト領域に、次の BigQuery SQL クエリを入力します。

   SELECT name, gender, SUM(number) AS total
   FROM `bigquery-public-data.usa_names.usa_1910_2013`
   GROUP BY name, gender
   ORDER BY total DESC
   LIMIT 100
   

3. [実行] をクリックします。

bq

ターミナルで、次の bq query コマンドを入力し、標準 SQL 構文を使用してインタラクティブ クエリを実行します。

    bq query \
    --use_legacy_sql=false \
    'SELECT
      name, gender, SUM(number) AS total
    FROM
      `bigquery-public-data.usa_names.usa_1910_2013`
    GROUP BY
      name, gender
    ORDER BY
      total DESC
    LIMIT 100'

Console

1. Google Cloud コンソールの [ワークフロー] ページに移動します。

   [ワークフロー] に移動

2. [add 作成] をクリックします。

3. 新しいフィールドの名前を入力します: read-bigquery-write-sheets。

4. [リージョン] リストで [us-central1 (Iowa)] を選択します。

5. [サービス アカウント] で、Compute Engine のデフォルトのサービス アカウント（PROJECT_NUMBER-compute@developer.gserviceaccount.com）を選択します。

6. [次へ] をクリックします。

7. ワークフロー エディタで、次のワークフローの定義を入力します。

   main:
       steps:
       - init:
           assign:
           # Replace with your sheetId and make sure the service account
           # for the workflow has write permissions to the sheet
           - sheetId: "1D8n7uoU8kGwQvR4rcLkF10CdAfnUKE2o0yl6P-Z7nfM"
           - limit: 100
       - runQuery:
           call: googleapis.bigquery.v2.jobs.query
           args:
               projectId: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
               body:
                   useLegacySql: false
                   # Query name and gender of most popular names
                   query: ${"SELECT name, gender, SUM(number) AS total
                       FROM `bigquery-public-data.usa_names.usa_1910_2013`
                       GROUP BY name, gender
                       ORDER BY total DESC
                       LIMIT " + limit}
           result: queryResult
       - init_header_row:
           assign:
           - rows:
               - ["Name", "Gender", "Total"]
       - process_query_result:
           for:
               value: row
               in: ${queryResult.rows}
               steps:
               - process_each_row:
                   assign:
                   - name: ${row.f[0].v}
                   - gender: ${row.f[1].v}
                   - total: ${row.f[2].v}
                   - row: ["${name}", "${gender}", "${total}"]
                   - rows: ${list.concat(rows, row)}
       - clear_existing_values:
           call: googleapis.sheets.v4.spreadsheets.values.clear
           args:
               range: "Sheet1"
               spreadsheetId: ${sheetId}
           result: clearResult
       - update_sheet:
           call: googleapis.sheets.v4.spreadsheets.values.update
           args:
               range: ${"Sheet1!A1:C" + (limit + 1)}
               spreadsheetId: ${sheetId}
               valueInputOption: RAW
               body:
                   majorDimension: "ROWS"
                   values: ${rows}
           result: updateResult
       - returnResult:
           return: ${updateResult}

8. プレースホルダ sheetId 値を spreadsheetId に置き換えます。

9. [デプロイ] をクリックします。

gcloud

1. ワークフローのソースコード ファイルを作成します。

   touch read-bigquery-write-sheets.yaml

2. テキスト エディタで、次のワークフローをソースコード ファイルにコピーします。

   main:
       steps:
       - init:
           assign:
           # Replace with your sheetId and make sure the service account
           # for the workflow has write permissions to the sheet
           - sheetId: "1D8n7uoU8kGwQvR4rcLkF10CdAfnUKE2o0yl6P-Z7nfM"
           - limit: 100
       - runQuery:
           call: googleapis.bigquery.v2.jobs.query
           args:
               projectId: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
               body:
                   useLegacySql: false
                   # Query name and gender of most popular names
                   query: ${"SELECT name, gender, SUM(number) AS total
                       FROM `bigquery-public-data.usa_names.usa_1910_2013`
                       GROUP BY name, gender
                       ORDER BY total DESC
                       LIMIT " + limit}
           result: queryResult
       - init_header_row:
           assign:
           - rows:
               - ["Name", "Gender", "Total"]
       - process_query_result:
           for:
               value: row
               in: ${queryResult.rows}
               steps:
               - process_each_row:
                   assign:
                   - name: ${row.f[0].v}
                   - gender: ${row.f[1].v}
                   - total: ${row.f[2].v}
                   - row: ["${name}", "${gender}", "${total}"]
                   - rows: ${list.concat(rows, row)}
       - clear_existing_values:
           call: googleapis.sheets.v4.spreadsheets.values.clear
           args:
               range: "Sheet1"
               spreadsheetId: ${sheetId}
           result: clearResult
       - update_sheet:
           call: googleapis.sheets.v4.spreadsheets.values.update
           args:
               range: ${"Sheet1!A1:C" + (limit + 1)}
               spreadsheetId: ${sheetId}
               valueInputOption: RAW
               body:
                   majorDimension: "ROWS"
                   values: ${rows}
           result: updateResult
       - returnResult:
           return: ${updateResult}

3. プレースホルダ sheetId 値を spreadsheetId に置き換えます。

4. 次のコマンドを入力してワークフローをデプロイします。

   gcloud workflows deploy read-bigquery-write-sheets \
       --source=read-bigquery-write-sheets.yaml \
       --location=us-central1 \
       --service-account=PROJECT_NUMBER-compute@developer.gserviceaccount.com

   PROJECT_NUMBER は、実際の Google Cloud プロジェクトの番号に置き換えます。プロジェクト番号は、Google Cloud コンソールの [ようこそ] ページで確認できます。