diff --git a/backend/pashub_fetcher/handler/test_handler.py b/backend/pashub_fetcher/handler/test_handler.py index 996835a2..07f651f4 100644 --- a/backend/pashub_fetcher/handler/test_handler.py +++ b/backend/pashub_fetcher/handler/test_handler.py @@ -1,7 +1,23 @@ from typing import Any, Mapping import json +from utils.logger import setup_logger + +logger = setup_logger() + def handler(event: Mapping[str, Any], context: Any) -> None: - print("Received event:") - print(json.dumps(event, indent=2)) + logger.info("Received event:") + + for record in event.get("Records", []): + body_str = record.get("body", "") + + try: + body_obj = json.loads(body_str) + except json.JSONDecodeError: + logger.error("Failed to parse body as JSON") + logger.info(body_str) + continue + + logger.info("Parsed message body:") + logger.info(json.dumps(body_obj, indent=2))