"""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. """ message_body = json.loads(message.body) return message_body