経緯
CodeBuildのログを整形してメール通知する必要がありました。
構築
今回はCodeBuildの失敗ログがトリガーになるので、CloudWatch Eventsで
CodeBuildの失敗するイベントを作成します。
そこからSNS経由でロググループとログストリーム名をLambdaで受け取り、ログをなんやかんやします。
※AWSのアイコンがアップデートされてさらにおしゃれになってました
こういう細かなアップデートがあるのもAWSの魅力ですね。
ただ、最新版にEmailのアイコンが無くなったような・・・？
CloudWatch Events
| 項目 | 値 |
|---|---|
| イベントパターン | チェック |
| サービス名 | CodeBuild |
| イベントタイプ | CodeBuild Build State Change |
| 特定の状態 | FAILED |
| ターゲット | SNS① |
SNS①
- トピック名：任意
- サブスクリプション: Lambdaのエンドポイント(プロトコル：Lambda)
Lambda
| 設定項目 | 値 |
|---|---|
| 関数の作成 | 一から作成 |
| 名前 | 任意 |
| ランタイム | Python3.6 |
| ロール | 1つ以上のテンプレートから |
| ロール名 | 任意 |
| ポリシーテンプレート① | Amazon SNS 発行ポリシー |
| ポリシーテンプレート② | CloudWatchLogsReadOnlyAccess |
| トリガーの追加 | SNS① |
| タイムアウト | 1分 |
| 環境変数 | SNSarn/SNS②のArn |
コード
import json
import boto3
import os
import time
TOPIC_ARN = os.environ['SNSarn']
def lambda_handler(event, context):
message_unicode = event['Records'][0]['Sns']['Message']
message_dist = json.loads(message_unicode)
group_name = message_dist['detail']['additional-information']['logs']['group-name']
stream_name = message_dist['detail']['additional-information']['logs']['stream-name']
time.sleep(90)
client = boto3.client('logs')
logs = client.get_log_events(
logGroupName=group_name,
logStreamName=stream_name,
startFromHead=True
)
body = logs['events']
message = ""
for line in body:
log = '{}'.format(line['message'])
message = message + log + '\n'
Msg = message
sub = '[Codebuild FAILED]'
client = boto3.client('sns')
response = client.publish(
TopicArn=TOPIC_ARN,
Message=Msg,
MessageStructure='context',
Subject=sub
)
SNS②
- トピック名：任意
- サブスクリプション: 通知したいメールアドレス
最後に
実際に検討を行ったCodeBuildのログは7000行あり、
メールが複数来たり、内容が不足していました。
原因は（環境差があると思いますが、）CodeBuildからCloudWatch Logsにログが出力されるまで約1分差がある事です。
Lambda起動時にはログがすべて出力され切らないまま動作し、またLambdaが3秒でtimeoutしてしまいます。
そこでPythonのコード上でスリープを入れ、Lambdaのtimeoutを3秒から増やしました。
するとSNSの本文に記載できる量をオーバーしてのエラーになった為、
一旦、S3へ保存し、通知したい内容を選別しSNS本文に記載する内容を絞りました。
苦戦しましたが、やりたい事は実現できました。
もっとスマートな方法がありましたら、ご教示頂けますと幸いです。