Source code for lambdas.product_service

import logging
from datetime import datetime, timedelta
from pymorri.exceptions.mori_exceptions import MoriException
from pymorri.util.aws_utils import send_messages_to_sqs
from pymorri.util.model import SqsMessage
logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)
response = {"message": ""}


def add_product_sqs(queue_name, product_id, sqs_payload):
    """
    This method provide to store the product into sqs.
    :param queue_name : Queue name.
    :param product_id: Single product id from the request..
    :param sqs_payload: SQS payload
    """
    try:
        sqs_message = SqsMessage(message_group_id=str(product_id),
                                 message_body=sqs_payload,
                                 message_deduplication_id=str(product_id)
                                 )
        product_message = [sqs_message]
        send_messages_to_sqs(queue_name, product_message)
    except MoriException as ex:
        logger.error(ex)
        raise ex