サードパーティ サービス向けのクラスタ通知を構成する

Slack 通知

Slack 通知を設定するには、Slack アプリケーションを作成し、アプリケーションの着信 Webhook を有効にして、Slack ワークスペースにアプリケーションをインストールする必要があります。

Slack アプリケーションの作成

1. メールアドレスで登録するか、またはワークスペース管理者から送信された招待状を利用して、Slack ワークスペースに参加します。

2. ワークスペース名と Slack アカウントの認証情報を使用して、Slack にログインします。

3. 新しい Slack アプリを作成する

   1. [Create an app] ダイアログで [From scratch] をクリックします。
   2. アプリ名を指定し、Slack ワークスペースを選択します。
   3. [Create App] をクリックします。
   4. [Add Features and Features] で、[Incoming Webhooks] をクリックします。
   5. [Activate Incoming Webhooks] の切り替えボタンをクリックします。
   6. [Webhook URLs for Your Workspace] セクションで、[Add New Webhook to Workspace] をクリックします。
   7. 表示された認証ページで、通知を受け取るチャネルを選択します。
   8. [許可] をクリックします。
   9. [Webhook URLs for Your Workspace] セクションに Slack アプリケーションの Webhook が表示されます。後で使用できるように、URL を保存します。

Cloud Run 関数を作成する

GKE がクラスタ通知を Pub/Sub トピックに公開すると、イベントにより Cloud Run functions がトリガーされて Slack 通知が送信されます。

1. gke_slack という名前の新しいディレクトリを作成し、そのディレクトリに移動します。

   mkdir ~/gke_slack && cd $_ 

2. gke_slack ディレクトリに以下のファイルを作成します。

   index.js

   const functions = require('@google-cloud/functions-framework'); const { IncomingWebhook } = require('@slack/webhook');  const url = process.env.SLACK_WEBHOOK;  const webhook = new IncomingWebhook(url);  // Optionally filter what notification types to forward to Slack. // If empty, all types will be allowed. const allowedTypeURLs = [];  // Register a CloudEvent callback with the Functions Framework that will // be executed when the Pub/Sub trigger topic receives a message. functions.cloudEvent('slackNotifier', pubSubEvent => {     const data = decode(pubSubEvent.data.message.data);      // Send message to Slack.     if (isAllowedType(pubSubEvent.data.message.attributes)) {         const message = createSlackMessage(data, pubSubEvent.data.message.attributes);         webhook.send(message);     } });  // decode decodes a pubsub event message from base64. const decode = (data) => {     return Buffer.from(data, 'base64').toString(); }  // isAllowedType can be used to filter out messages that don't match the // allowed type URLs. If allowedTypeURLs is empty, it allows all types. const isAllowedType = (attributes) => {     if (allowedTypeURLs.length == 0) {         return true;     }     for (var x in allowedTypeURLs) {         if (attributes['type_url'] == allowedTypeURLs[x]) {             return true;         }     }     return false; }  // createSlackMessage creates a message from a data object. const createSlackMessage = (data, attributes) => {     // Write the message data and attributes.     text = `${data}`     for (var key in attributes) {         if (attributes.hasOwnProperty(key)) {             text = text + `\n\t\`${key}: ${attributes[key]}\``         }     }     const message = {         text: text,         mrkdwn: true,     };     return message; } 

   SLACK_WEBHOOK は、Slack アプリケーション用に作成された webhook URL を指定する Cloud Run functions の環境変数です。関数のデプロイ時に、環境変数を定義します。

   Webhook は、Cloud Run functions からのメッセージをリッスンし、受信します。GKE がクラスタ通知を Pub/Sub（イベント）に送信すると、この関数は Webhook URL にメッセージ（トリガー）を送信します。その後、構成済みの Slack ワークスペースにメッセージが送信されます。

   createSlackMessage 関数でメッセージを拡張すると、テキストのフォーマット情報や画像など、多くの情報を含めることができます。isAllowedType 関数は、URL タイプでの通知の基本的なフィルタリングを有効にするために提供されます。allowedTypeURLs では、許可する URL タイプを指定できます。GKE または Pub/Sub サブスクリプションですでに通知をフィルタリング済みの場合、この関数は必要ありません。

   package.json

   {   "name": "gke-slack",   "version": "0.0.1",   "description": "Slack integration for GKE, using Cloud Run functions",   "main": "index.js",   "dependencies": {     "@slack/webhook": "6.1.0",     "@google-cloud/functions-framework": "^3.0.0"   } } 

   package.json は、プログラムの以下の属性を記述します。

   • 名前、バージョン、説明
   • 主要ランタイム ファイル
   • 依存関係

   必要に応じて、依存関係、要件、その他の情報を追加できます。

これで、gke_slack ディレクトリに index.js ファイルと package.json ファイルが追加されました。

Cloud Run functions 関数をデプロイする

Cloud Run functions 関数は、Google Cloud CLI または Google Cloud コンソールでデプロイできます。

gcloud functions deploy slackNotifier \   --gen2 \   --trigger-topic=TOPIC_NAME \   --runtime=nodejs14 \   --entry-point=slackNotifier \   --region=REGION \   --source=. \   --set-env-vars="SLACK_WEBHOOK=WEBHOOK_URL" 

Deploying function… availableMemoryMb: 256 entryPoint: slackNotifier environmentVariables:   SLACK_WEBHOOK: https://hooks.slack.com/services/… eventTrigger:   eventType: google.pubsub.topic.publish   failurePolicy: {}   resource: projects/PROJECT_ID/topics/TOPIC_NAME   service: pubsub.googleapis.com labels:   deployment-tool: cli-gcloud name: projects/PROJECT_ID/locations/us-central1/functions/slackNotifier runtime: nodejs10 serviceAccountEmail: PROJECT_ID@appspot.gserviceaccount.com sourceUploadUrl: https://storage.googleapis.com/… status: ACTIVE timeout: 60s updateTime: 'YYYY-MM-DDThh:mm:ssZ' versionId: '1' 

Cloud Run 関数のデプロイ完了後、GKE がクラスタ通知を送信するたびに Slack 通知が届きます。

Slack 通知の確認

Autopilot クラスタを使用した場合は、次のように通知を確認します。

1. コントロール プレーンのアップグレードを開始します。
2. GKE がノードを新しいバージョンに自動的にアップグレードするまで待ちます。所要時間は、構成したメンテナンスの時間枠とメンテナンスの除外によって変動する場合があります。
3. GKE がノードをアップグレードしたら、Slack でメッセージを確認します。

Standard クラスタを使用した場合は、次のように通知を確認します。

1. 特定のノードプールを新しいバージョンにアップグレードします。ノード上の GKE バージョンを変更しない場合は、ノード上で現在インストールされている同じバージョンにアップグレードできます。

2. GKE がノードをアップグレードしたら、Slack でメッセージを確認します。

Slack の通知は次のようになります。

Master is upgrading to version 1.20.10-gke.301.     cluster_location: us-central1     cluster_name: pubsub-cluster     payload: {"resourceType":"MASTER", "operation":"operation-1632775054313-45128f4f", "operationStartTime":"2021-09-27T20:37:34.313742491Z", "currentVersion":"1.20.9-gke.1001", "targetVersion":"1.20.10-gke.301"}     project_id: 729788050015     type_url: type.googleapis.com/google.container.v1beta1.UpgradeEvent