"""Utility functions related to operations with sqs.Message.""" import json def get_message_body(message): """Extract message body mapped to dictionary from sqs.Message object. Args: message (sqs.Message): message pulled from SQS-message. Returns: dict: decoded message body. """ full_message = json.loads(message.body) message_json_string = full_message.get('Message', '{}') message_body = json.loads(message_json_string) return message_body