こんにちは。GMOアドマーケティングのH.Tと申します。
目新しいネタではないのですが、Cloud Pub/SubでBigQueryの「スケジュールされたクエリ」の結果をSlack通知してみたのでご紹介いたします。

きっかけ

BigQueryの「スケジュールされたクエリ」が便利で使っています。
「スケジュールされたクエリ」はクエリ失敗時の通知オプションとしてメールかPub/Subから選べるのですが、システム通知をSlackで受け取りたいのでCloud Pub/Sub→Slack通知の連携を試してみました。

システム連携概要

以下図のとおり、BigQuery→Cloud Pub/Sub→Cloud Functions→Slackという形で連携します。

設定の流れ

1.まず、受け取りたいslackのwebhook urlを用意しておきます。
(slack側の準備は本記事では割愛させていただきます。)

2.BigQueryの「スケジュールされたクエリ」のPub/Sub設定項目を確認。
以下のとおり、Pub/Subのトピック名を入力する欄があるのでこれからPub/SubとCloud Funcitonsの設定をしていきます。

3.Cloud Pub/Subサービスを有効にして「トピックを作成」ボタンを押します。

4.「トピック ID」に適切な名前を入力します。「デフォルトのサブスクリプションを追加する。」のチェックは今回は不要なので外します。

5.トピックが作成できたら詳細画面に入ります。詳細画面から「CLOUD 関数をトリガー」ボタンを押します。

6.Cloud Functionsの設定画面になります。
関数名を設定します。
「失敗時に再試行する。」の挙動は検証していないので今回は外しました。
トピックはあらかじめ設定されています。
「保存」を押します。

7.「次へ」ボタンを押してコードの入力画面へ移動します。

8.コードの入力画面
関数の言語はnode.jsがデフォルトになっていますのでそのままnode.jsで実装したいと思います。
最初から受け取ったメッセージをconsole.logしているサンプルコードが入っていますが今回は特に消す必要もないのでここにslackへpost送信するコードを追加します。

9.以下のようにソースコードを書いたら「デプロイ」ボタンを押してデプロイします。

/**
 * Triggered from a message on a Cloud Pub/Sub topic.
 *
 * @param {!Object} event Event payload.
 * @param {!Object} context Metadata for the event.
 */
const request = require('request');

exports.sendSlack = (event, context) => {
  const message = event.data
    ? Buffer.from(event.data, 'base64').toString()
    : 'Hello, World';
  console.log(message);

  request({
    url: 'https://hooks.slack.com/services/xxxxxxxxxxxxxxxxxxxxxxxxxxx',
    method: 'POST',
    headers: {'Content-Type': 'application/json' },
    body: JSON.stringify({
      text: 'event message from bigquery: ' + message
    })
  }, (error, response, body) => {
    console.log(error, response, body)
  });
};