product.py

import logging
import json
from typing import Dict
from src.product.product_service import receive_product_update
logger = logging.getLogger(__name__)


# Actual lambda handler, responsible for extracting message from SNS
# and dealing with lambda-related things, passing the encoded message along to the
# message handler
async def handler(event: Dict):
    logger.info(f'{event=}')

    # Read the SNS message and pass the contents to the actual message handler
    message: Dict = json.loads(event['Records'][0]['Sns']['Message'])
    logger.info(message)
    results = await receive_product_update(message)
    logger.info(results)

    # Return the current size of the repository
    return len(results.keys())