Go AWS Lambda 関数を使用して Slack 通知を送信する-Golang-php.cn

導入

この記事では、AWS インスタンスの CPU 使用率が 50% に達したときに Slack 通知を送信する AWS Lambda 関数を作成する方法について説明します。

AWS Lambda は、アマゾンウェブサービス (AWS) が提供するサーバーレスコンピューティングサービスです。これにより、サーバーを自分でプロビジョニングしたり管理したりすることなく、コードを実行できます。

これはイベント駆動型です。つまり、s3 で完了したファイルのアップロード、Amazon API Gateway からの HTTP リクエスト、またはその他のさまざまなトリガーなど、他の AWS サービスによってトリガーされたイベントに応答してコードが実行されます。

ここでは、EC2 インスタンスからメトリクスを監視および収集するように Amazon Cloudwatch を設定する方法、それらのメトリクスに基づいて特定のしきい値または条件が満たされたときに通知をトリガーする Cloudwatch アラーム、Amazon Simple Notice サービスを設定する方法について説明します。これらの通知を受信し、最後にラムダ関数が SNS トピックをサブスクライブし、通知を処理して Slack メッセージを送信します。

前提条件

これを読み進めるには、読者は次の基本的な知識と理解を持っている必要があります

ゴラン
AWS とそのサービス ### プロジェクトのセットアップまず、これらの通知を Slack に送信する関数を書き出すことから始めます。

新しい go プロジェクトを作成し、任意の名前を付けます。私は main.go ファイルに「lambdaFunction」という名前を付け、次のコードを貼り付けます

import (
   "bytes"
   "context"
   "encoding/json"
   "fmt"
   "github.com/aws/aws-lambda-go/events"
   "github.com/aws/aws-lambda-go/lambda"
   "net/http"
)

type slackMessage struct {
   Text string `json:"text"`
}

func handleRequest(ctx context.Context, snsEvent events.SNSEvent) error {
    webhookURL := "https://hooks.slack.com/services/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"
    for _, record := range snsEvent.Records {
        snsRecord := record.SNS
        sendSlackNotification(webhookURL, snsRecord.Message)
    }
    return nil
}

func sendSlackNotification(webhookURL, message string) {
   slackMessage := slackMessage{Text: "Cpu usage is above 50%" + message}
   slackBody, _ := json.Marshal(slackMessage)
   req, err := http.NewRequest(http.MethodPost, webhookURL, bytes.NewBuffer(slackBody))
   if err != nil {
      fmt.Printf("Error creating request: %v\n", err)
      return
   }
   req.Header.Set("Content-Type", "application/json")

   client := &http.Client{}
   resp, err := client.Do(req)
   if err != nil {
      fmt.Printf("Error sending request: %v\n", err)
   }
   defer resp.Body.Close()
   if resp.StatusCode != http.StatusOK {
      fmt.Printf("Error response from slack: %v\n", resp.StatusCode)
   } else {
      fmt.Printf("Successfully sent Slack notification: %v\n", resp.StatusCode)
   }
}



func main() {
   lambda.Start(handleRequest)
}

ログイン後にコピー

go mod を実行

何が起こっているのか理解してみましょう
handleRequest 関数

まず、Slack に送信されるメッセージ形式を表すために、slackMessage という名前の構造体を作成します。これには、メッセージの内容を保持する単一フィールド Text があります
handleRequest 関数は、ラムダランタイムによって実行されるメイン関数です。これは、2 つの引数 context と、受信した SNS 通知に関する詳細を含む snsEvent events.SNSEvent を受け取ります。
この関数は、snsEvent 内の各 snsRecord を反復処理し、sns.message フィールドからメッセージコンテンツを取得し、Slack Webhook URL とメッセージコンテンツを使用して sendSlackNotification を呼び出します

sendSlackNotification 関数

この関数は 2 つの引数 webhookURL (Slack 通知が送信される URL) と message: Slack に送信されるメッセージの内容を取ります。
提供されたメッセージに「CPU 使用率が 50% を超えています」という事前定義メッセージを追加しました。次に、json.marshal.
HTTP 投稿リクエストは、Slack Webhook URL、JSON 形式の本文、および application.json に設定されたコンテンツタイプヘッダーを持つ http.NewRequest を使用して作成されます。 *リクエストは http.client を使用して送信され、レスポンスが受信されます main 関数はローカルテストにのみ使用されます。 lambda 環境では、lamba.start 関数が handleRequest をエントリポイントとして自動的に呼び出されます

Slack Webhook URL の取得

Slack にメッセージを送信できるようにする Slack Webhook URL を取得するには、https://api.slack.com/apps に移動します。続行する前に、Slack アカウントにサインインしていることを確認してください。

右上の「新しいアプリを作成」をクリックしますダイアログボックスが表示されます。新しいアプリを作成するには、「最初から」を選択します。その後、別のダイアログボックスが表示されます。ここで、アプリに「cpu-alert」という名前を付けて、メッセージを送信する特定の Slack ワークスペースを選択できます。すでにテストワークスペース「サイト信頼性テスト」を作成しました
「アプリを作成」をクリックします
「機能の追加」セクションで「受信 Webhook」を選択します
受信 Webhook のアクティブ化ボタンを「オン」に切り替えます。もう一度戻って、「アプリのインストールセクション」までスクロールします
「ワークスペースにインストール」をクリックすると、Slack にメッセージを送信するチャネルを選択します。次に、「許可」をクリックします。
「機能と機能の追加」に戻り、「受信 Webhook」を選択します
下にスクロールして Webhook URL を見つけ、それをコピーしてコードに貼り付けます。

次のステップは、Go アプリの展開パッケージを作成することです
アプリケーションを構築していきます。

プロジェクトの作業ディレクトリでターミナルを開きます。run GOOS=linux go build -o main main.go
「ブートストラップ」ファイルを作成する次の内容を含む「bootstrap」という名前のファイルをプロジェクトのルートディレクトリに作成します。

#!/bin/sh 
./main

ログイン後にコピー

ブートストラップファイルを実行可能にする

chmod +x ブートストラップを実行する
zip function.zip main bootstrap を実行して、実行可能ファイルとブートストラップファイルを圧縮します。

lamba 関数のアップロード

AWS 管理コンソールに移動します
ラムダを検索し、新しい関数を作成します
任意の名前を付けます
「最初から作成する」を選択します
ランタイムとして、Amazon linux 2023 を選択します
機能の選択をクリック
機能の作成が完了したら、下にスクロールして「アップロード元」オプションを見つけます
コードを含むフォルダー全体ではなく、function.zip ファイルを選択してください
保存します
ランタイム設定セクションを見つけて、[編集] をクリックします
ハンドラーをブートストラップに設定して保存します

次のステップでは、Lambda 関数のトリガーを設定します。このトリガーは、関数にメッセージを Slack

に送信するよう促すイベントを定義します。

前に述べたように、そのトリガーは仮想マシンの CPU 使用率が 50% 以上になった場合です

この機能を実現するには、最初のステップとして EC2 インスタンスを作成します。

これが完了したら、メトリクスを監視および収集するように Cloudwatch を設定する必要があります

Cloudwatch を検索して開きます
アラームの作成を選択します
指標の選択を選択
EC2 を選択
インスタンスごとのメトリクスを選択
CPU使用率メトリクスを選択

コンディションセクション内

しきい値として「大きい/等しい」を選択します
しきい値を「50」として定義します
「次へ」をクリック次のページで通知セクションを見つけます
アラーム状態のトリガーは「アラーム中」のままにしておきます
「新しいトピックの作成」オプションを選択します
一意の名前を入力します。通知を受け取る電子メールを入力することもできます
トピックの作成を選択します
次のページで、一意のアラーム名を入力します次にアラームを作成します

ラムダ関数に戻ります

「トリガーの追加」を選択します
「ソースを選択」フィールドで「sns」を検索して選択します
前に作成したトピックを選択し、「追加」をクリックします ### テストシンプルなインフラストラクチャのさまざまな部分の組み立てが完了したので、今度はテストします。

これが機能することをテストするには、VM に一種のストレステストを行う必要があります。このテストでは、高い CPU 負荷が発生します。このテストを実行するには、Linux の「stress」ツールを使用します。

何よりもまず、EC2 inatance に「stress」ツールをインストールする必要があります。EC2 インスタンスに接続し、次のコマンドを実行します
sudo apt-get update
sudo apt-get インストールストレス
次のコマンドを使用して CPU のストレステストを行います
ストレス --cpu 4 --timeout 300
この例では、4 つの CPU ワーカー (並列プロセスまたはスレッドの数) を 300 秒 (5 分) 使用します。ワーカー数とセカンダ数はご希望に応じて調整できます。

Slack を開いて待つと、次のようなアラートが表示されます

Image description

遭遇する可能性のある一般的なエラー

ストレステストの実行中に、Cloudwatch の状態が「データ不足」に変化することに気づく場合があります。これにより、アラームが少し遅れる可能性があります。これを修正するには

Cloudwatch コンソールを開きます
アラームに移動し、特定のアラームを選択します
アクションをクリックして編集します
欠損データの処理セクションまで下にスクロールします
「欠落データを無視する(現在の状態を維持する)」を選択します
アラームを保存する＃＃＃結論これまで、Go で単純な Lambda 関数を作成して設定する方法を検討してきました。さらに、メトリクスを監視および収集するように CloudWatch を設定し、特定のしきい値に達したときにトリガーされるように CloudWatch アラームを設定し、これらのアラームを受信するための SNS トピックを確立しました。 SNS トピックの目的は、Slack メッセージを送信する Lambda 関数をトリガーすることです。

これは楽しくて有益だと感じていただけたと思います。間違いがある場合、明確に説明されていない部分がある場合、または何かを見逃していると思われる場合は、お気軽にご連絡ください。あなたのフィードバックは非常に貴重です。ありがとうございます!

github リポジトリへのリンクはここにあります

以上がGo AWS Lambda 関数を使用して Slack 通知を送信するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。