From 476d0f533b096ebfa4b67e8107d16d4966553237 Mon Sep 17 00:00:00 2001
From: "shimoda.m@nds-tyo.co.jp" <shimoda.m@nds-tyo.co.jp>
Date: Tue, 20 May 2025 09:17:42 +0900
Subject: [PATCH] =?UTF-8?q?feat:=20=E3=82=A2=E3=83=AB=E3=83=88=E3=83=9E?=
 =?UTF-8?q?=E3=83=BC=E3=82=AF=E5=8F=96=E8=BE=BC=E8=B5=B7=E5=8B=95=E5=87=A6?=
 =?UTF-8?q?=E7=90=86=E8=BF=BD=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../launch-batch-ultmarc-io.py                | 80 +++++++++++++++++++
 1 file changed, 80 insertions(+)
 create mode 100644 lambda/launch-batch-ultmarc-io/launch-batch-ultmarc-io.py

diff --git a/lambda/launch-batch-ultmarc-io/launch-batch-ultmarc-io.py b/lambda/launch-batch-ultmarc-io/launch-batch-ultmarc-io.py
new file mode 100644
index 00000000..b4105b7e
--- /dev/null
+++ b/lambda/launch-batch-ultmarc-io/launch-batch-ultmarc-io.py
@@ -0,0 +1,80 @@
+import json
+import logging
+import os
+from datetime import datetime
+from zoneinfo import ZoneInfo
+
+import boto3
+
+# 環境変数
+SFN_STATE_MACHINE_ARN = os.environ["SFN_STATE_MACHINE_ARN"]
+TZ = os.environ["TZ"]
+LOG_LEVEL = os.environ["LOG_LEVEL"]
+
+# logger設定
+logger = logging.getLogger()
+
+
+def log_datetime_convert_tz(*arg):
+    """ログに出力するタイムスタンプのロケールを変更する（JST指定）"""
+    return datetime.datetime.now(ZoneInfo(TZ)).timetuple()
+
+
+formatter = logging.Formatter(
+    '[%(levelname)s]\t%(asctime)s\t%(message)s\n',
+    '%Y-%m-%d %H:%M:%S'
+)
+formatter.converter = log_datetime_convert_tz
+for handler in logger.handlers:
+    handler.setFormatter(formatter)
+
+level = logging.getLevelName(LOG_LEVEL)
+if not isinstance(level, int):
+    level = logging.INFO
+logger.setLevel(level)
+
+
+# boto3クライアント
+sfn_client = boto3.client('stepfunctions')
+
+
+def lambda_handler(event, context):
+    logger.info('I-1 駆動処理開始')
+    # イベント情報を取得する
+    s3_event = event["Records"][0]["s3"]
+    event_bucket_name = s3_event["bucket"]["name"]
+    event_object_key = s3_event["object"]["key"]
+    logger.info(f'I-2 バケット名：{event_bucket_name}')
+    logger.info(f'I-3 キー名：{event_object_key}')
+
+    # StepFunctionsを起動する
+    response = sfn_client.start_execution(
+        stateMachineArn=SFN_STATE_MACHINE_ARN,
+        input=json.dumps(
+            {
+                'InputParams': {
+                    'BucketName': event_bucket_name,
+                    'TargetKey': event_object_key,
+                }
+            }
+        )
+    )
+    print(f'{datetime.now():%Y-%m-%d %H:%M:%S} Info I-4 StepFunctions起動レスポンス：{str(response)}')
+
+    print(f'{datetime.now():%Y-%m-%d %H:%M:%S} Info I-5 駆動処理終了')
+
+
+# ローカルでのデバック実行用。
+# 利用する際にコメントを外してください
+# if __name__ == '__main__':
+#     lambda_handler({"Records": [{
+#         # バケット名やファイルキーはよしなに変えてください。
+#         "s3": {
+#             "bucket": {
+#                 "name": "test-shimoda-bucket"
+#             },
+#             "object": {
+#                 "key": "recv/SRC_ULT_MDB_ALL_20250414070000.csv"
+#             }
+#         }
+#         }]}, {})