OSP Event Handler V2 - Order Delivered Sqs Handler Code

Code

class ecstask.osp_eventhandler_v2.handlers.order_delivered_sqs_handler.OrderDeliveredSqSHandler(queue_name, message_body, message_group_id=None)

Bases: object

__init__(queue_name, message_body, message_group_id=None)

Handling of the request data from the order delivered webhook to orders sqs. This takes only 1 message, so chunk size is set to 1.

Parameters

• queue_name (string) – the name of the queue

• message_body (json) – json of webhook request. Requires: orderId, retailerBannerId

• message_group_id (string) – the sqs message group id

execute()

This method is used to publish Sqs messages. It uses the pymorri method send_messages_to_sqs.

__prepare_message_to_publish()

This function makes SqsMessage model which is then used to create the list as sqs_messages

Returns

the custom model corresponding to sqs entries

Return type

sqs_messages (List[SqsMessage])