diff --git a/backend/categorisation/handler/handler.py b/backend/categorisation/handler/handler.py index 449c5ccf..ee0e7a7d 100644 --- a/backend/categorisation/handler/handler.py +++ b/backend/categorisation/handler/handler.py @@ -1,5 +1,6 @@ import json from typing import Any, Mapping + from backend.categorisation.categorisation_trigger_request import ( CategorisationTriggerRequest, ) @@ -12,6 +13,10 @@ logger = setup_logger() def handler(event: Mapping[str, Any], context: Any) -> None: + logger.info("Received message") + + logger.info(f"Number of events: {len(event.get('Records', []))}") + for record in event.get("Records", []): try: body_dict = json.loads(record["body"]) @@ -27,4 +32,5 @@ def handler(event: Mapping[str, Any], context: Any) -> None: ) except Exception as e: + logger.info("Handler exception") logger.error(f"Failed to process record: {e}")