[AWS] Lambdaからバッチ実行を監視してTeamsに投稿してみた

import json
import urllib.request
import boto3
import send_teams as st
import datetime
import dateutil.parser
import time

def lambda_handler(event, context):
    jst_datetime = datetime.datetime.now()
    
    command = "grep mailbatch.sh /var/log/cron | tail -20"
    instance_id = "xxxxxxxxxxxxxxxxxxx"
    ssm = boto3.client('ssm', region_name='ap-northeast-1')
    retry = 3
    
    # 最大でリトライ回数までコマンドを実行
    for i in range(1,retry):
    
        # コマンド実行
        r = ssm.send_command(
            InstanceIds = [instance_id],
            DocumentName = "AWS-RunShellScript",
            Parameters = {
                "commands": [
                command
                ]    
            }
        )
        command_id = r['Command']['CommandId']
        
        # 処理終了待ち
        time.sleep(3)
        
        # 結果取得
        res = ssm.list_command_invocations(
              CommandId = command_id,
              Details = True
            )
        invocations = res['CommandInvocations']
        status = invocations[0]['Status']
            
        # ステータスが"Success"の場合
        if status == "Success":
            # 処理を抜ける
            break
    
    # ステータスが"Success"の場合
    if status == "Success":
        # コマンドの実行結果部分を取得
        description = invocations[0]['CommandPlugins'][0]['Output']
    
        # 改行を<br>タグに変換
        description = description.replace('\n','<br>')
    
        # Teamsに投げるメッセージを作成
        message='<table><tr><th>取得日時</th> <th align="left">{}</th></tr><tr><th>内容</th><th align="left"><font size="1">{}</font></th></tr></table>'.format(jst_datetime.strftime("%Y/%m/%d %H:%M:%S"),description)  
        
    # ステータスが"Success"以外の場合
    else:
        message='<table><tr><th>取得日時</th> <th align="left">{}</th></tr><tr><th>内容</th><th align="left"><font size="1">{}</font></th></tr></table>'.format(jst_datetime.strftime("%Y/%m/%d %H:%M:%S"),"Lambda取得エラー　ステータス=" + status)    

    # Teamsに投げるタイトルの設定
    title="バッチ稼働状況通知"

    # Teamsに送信
    st.send(title,message)
    #print(message)
    
    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
    }

import os
import urllib.request
import json


def send(title,message):
    send_data = {"title":title,"text": message}
    send_text = "payload=" + json.dumps(send_data)
    send_text =  json.dumps(send_data)
    request = urllib.request.Request(
        os.environ["NOTIFICATION_TARGET"], 
        data=send_text.encode("utf-8"),
        method="POST"
    )

    urllib.request.urlopen(request)