新しい行(トリガー)

このピースでできること

  • Google BigQuery のテーブルに新しい行が追加されたときにフローを開始します。
  • 指定したソート列の値を不正の最新値と比較することで、新導行を検知します。
  • 5分ごとにポーリングして新しい行を返します。

Google BigQuery の接続方法

workrun と Google BigQuery を接続するには、Google アカウント または サービスアカウント JSON で認証します。
フローの用途に合わせて選んでください。

方法 1:Google アカウント(OAuth2)で接続する

個人の Google アカウントで認証する方法です。クイックに接続できます。

ステップ 1:workrun に接続を追加する

  1. workrun で Google BigQuery のアクション/トリガーをフローに追加します。
  1. 「接続を選択」の横にある 「+ 新しい接続」 をクリックします。
  1. 認証タイプとして 「My Google Account」 を選択します。
  1. 「接続する」 をクリックすると、Google のログイン画面が表示されます。
  1. 使用する Google アカウントを選択してログインします。
  1. workrun へのアクセス許可を確認し、「許可」 をクリックします。
  1. 認証完了後、接続名が表示されたら 「保存」 をクリックして完了です。

方法 2:サービスアカウント(JSON キー)で接続する

サーバー間連携や自動化に適した方法です。Google Cloud のサービスアカウント JSON キーが必要です。

ステップ 1:サービスアカウント JSON キーを取得する

  1. Google Cloud Console を開き、対象のプロジェクトを選択します。
  1. IAM と管理サービスアカウント へ移動します。
  1. サービスアカウントを作成 をクリックします。
  1. 名前(例: )を入力して 作成して続行 をクリックします。
  1. ロールとして BigQuery ユーザー (または完全アクセスの場合は BigQuery 管理者)を追加します。
  1. キー タブを開き、鍵を追加新しい鍵を作成JSON作成 をクリックします。
  1. ダウンロードされた ファイルを開き、内容全体をコピーします。

ステップ 2:workrun に接続を追加する

  1. workrun で Google BigQuery のアクション/トリガーをフローに追加します。
  1. 「接続を選択」の横にある 「+ 新しい接続」 をクリックします。
  1. 認証タイプとして 「Service Account JSON」 を選択します。
  1. 「Service Account JSON」 フィールドに、ステップ 1 でコピーした JSON 内容を貼り付けます。
  1. 「保存」 をクリックして接続を完了します。

ピースの設定項目

1. プロジェクト(必須)

  • Google Cloud プロジェクトをドロップダウンから選択します。

2. データセット(必須)

  • 監視対象のデータセットをドロップダウンから選択します。

3. テーブル(必須)

  • 監視対象のテーブルをドロップダウンから選択します。

4. 列の並び替え(必須)

  • 新しい行を検知するために使用する TIMESTAMP または DATETIME 型の列名を入力します。この列の値を常に降順でソートし、最後のチェックより新しい行が返されます。

5. 1回のチェックで取得する最大行数(任意)

  • 1回のポーリングで取得する行の最大数を指定します。デフォルトは 500 です。