SNSに飛んできたアラートをTypetalkに投稿する

AWSでインフラ構築をしていて、リソースモニタリング時のアラートとアプリログを何らかの形で通知してほしい。という依頼がありました。

• CloudWatchでリソース監視＆アラート設定をして、しきい値を超えたらSNSに通知する
• ログはCloudWatchLogs（？のAgent）でログを吸い上げてサブスクリプションフィルターでSNSに通知する
• SNSのサブスクリプションでメーリングリストを指定して関係者に配信する

という流れをひとまず作りました。こんなイメージ。

業務でBacklog、Typetalkを使ってるのですが、Typetalkの方にもアラートを投げてほしい。という要望が出たのでそちらも対応することにしました。
Amazon Chatbot（ https://aws.amazon.com/jp/chatbot/ ）というのがあり、簡単そう！ともいましたが、AmazonChimeとSlackしか対応してないみたいなので却下。
SNSからメール配信しているので、その配信先にTypetalkが加われば一番手間がかからなさそう。こんなイメージ？

Typetalkを調べてみると、APIが用意されていて、APIをコールしたら特定のトピックに投稿できるとのこと
https://developer.nulab.com/ja/docs/typetalk/api/1/post-message/
シンプルですね。
でもSNSから直接APIコールはできなさそうなのでググる。
あ、みんなlambdaを挟んでAPIをコールしてるんですね。こんなイメージかな

こんな構成で行けそう。
ではlambda関数を作っていきます。

import requests
import json
import os

token = os.environ['TYPETALK_TOKEN']
url = os.environ['TYPETALK_TOPIC_URL']

def lambda_handler(event, lambda_context):
    records = event.get("Records")
    if records and len(records) > 0:
        for record in records:
            sns = record.get("Sns")
            if sns:
                subject = sns.get("Subject").replace("\\", "\\\\" )
                message = sns.get("Message").replace("\\", "\\\\" )
                timestamp = sns.get("Timestamp")
                topic_message = subject + "\n"
                topic_message += message + "\n"
                topic_message += timestamp + "\n"

                data = {'message': topic_message[:4000]}
                headers = {'X-TYPETALK-TOKEN': token}
                res = requests.post(url, json = data, headers = headers)

先人たちのコードを参考にこんな形にしました。
Typetalk自体はTokenと投稿先のTopicIDがわかれば後はPOSTするだけでOKです。
Typetalk APIリファレンス：メッセージの投稿

TokenとTopicIDはlambdaの設定側から突っ込む形式にしました。
また、Typetalkでメッセージを投稿する際は一度に4,000文字が最大とのことなのでメッセージ文字列を4000の位置までで切ってPOSTしています。

比較的簡単！