nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

I-02-02ログから日付→データソースのみ表示に変更

Browse Source
This commit is contained in:
Nik Afiq 2024-08-05 13:19:27 +09:00
parent 98dd3c6f81
commit 6f3f205a62
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lambda/daily-data-unreceive-check/daily-data-unreceive-check.py
View File

@ -157,7 +157,7 @@ def daily_data_unreceive_check(records: list, execute_date: str) -> tuple[list[d
message_id = record["messageId"] message_id = record["messageId"]
# 2.DynamoDBテーブルからレコードを取得し、処理済みメッセージかどうかを判別する # 2.DynamoDBテーブルからレコードを取得し、処理済みメッセージかどうかを判別する
if is_duplicate_message(message_id): if is_duplicate_message(message_id):
logger.info(f'I-02-02 受信したメッセージは既に処理済みのため、処理をスキップします。メッセージID: {message_id} バケットディレクトリ: {event_parameter["check_bucket_name"]}/{event_parameter["check_folder_prefix"]}/{receive_date}/') logger.info(f'I-02-02 受信したメッセージは既に処理済みのため、処理をスキップします。メッセージID: {message_id} データソース バケットディレクトリ: {event_parameter["check_bucket_name"]}/{event_parameter["check_folder_prefix"]}/')
continue continue
except Exception as e: except Exception as e:
logger.exception(f"E-02-01 メッセージ重複チェック処理に失敗しました　エラー内容：{e}") logger.exception(f"E-02-01 メッセージ重複チェック処理に失敗しました　エラー内容：{e}")