S3に格納されたファイルを検知し、EC2上のシェルを自動実行する

#!/bin/bash
# 動作確認

# Lambdaから引数を取得
VALUE=${1}
echo "Lambdaから取得した値は【"${VALUE}"】" # Lambdaから値を取得する前提で記載

echo "実行ユーザ確認"
whoami

# ディレクトリ移動
cd /***/***/***/***/work/

echo "現在パス確認"
DIR_VALUE=$(pwd)
echo "${DIR_VALUE}"

echo "実行前確認"
ls -l
echo ""

# ファイル作成
touch ${DIR_VALUE}/${VALUE}".txt"

echo "実行後確認"
ls -l

import boto3
import logging
import time
import json

# ログ設定
logger = logging.getLogger()
logger.setLevel(logging.INFO)
 
ssm = boto3.client('ssm')
sns = boto3.client('sns')

# 対象インスタンスを定義
instance = ["i-***************"]

# 実行するコマンドを定義（作成したシェルのパス＆引数）
# (※シェルの実行ユーザと合わせる必要があります)
cmd_to_test = "su hulft -c \"bash /**/**/**/**/work/test.sh 9999\""

# 結果通知用TOPICを定義
# ここのarnは、後述するSNSのarnを転記
ERROR_TOPIC = 'arn:aws:sns:ap-northeast-1:*********:*********'
 INFO_TOPIC = 'arn:aws:sns:ap-northeast-1:*********:*********'

def lambda_handler(event, context):
    
    # S3に格納されたファイルを確認
    input_bucket = event['Records'][0]['s3']['bucket']['name']
    input_key = event['Records'][0]['s3']['object']['key']
    print("バケット名：" +  input_bucket , " ファイル名：" + input_key)
    
    try:
        # デプロイコマンドを実行
        res = ssm.send_command(
            InstanceIds = instance,
            DocumentName = "AWS-RunShellScript",
            Comment = 'Executing test command...', 
            TimeoutSeconds = 100, 
            Parameters = {
                "commands": [
                    cmd_to_test
                ]
            }
        )
        command_id = res['Command']['CommandId'] # CommandIdを取得

        # 処理完了まで5秒待つ
        time.sleep(5)

        # ステータスを取得
        list_invocations = ssm.list_command_invocations(
            CommandId = command_id,
            Details = True
            )
        deploy_res = list_invocations['CommandInvocations'][0]['Status']

        # 実行結果が失敗していれば通知の上、処理を中断
        if (deploy_res!='Success'):
            # メール通知
            res = sns.publish(
                TopicArn = ERROR_TOPIC,
                Message = 'テスト結果：'+ deploy_res + 'のため、テスト失敗',
                Subject = '【エラー】テスト失敗'
            )
            return False
        # メール通知
        res = sns.publish(
            TopicArn = INFO_TOPIC,
            Message = 'テスト成功',
            Subject = 'テスト成功'
        )
        return True

    except Exception as e:
        logger.error(e)
        raise e