def send()

in CWMetricsToOpenSearch/es_sink/sqs_transport.py [0:0]

• 13 lines of code
• 1 McCabe index (conditional complexity)

    def send(self, body):
        '''Send a message to SQS. Returns a TransportResult'''
        sqs = boto3.resource('sqs', region_name=self.target_descriptor.region)
        queue = sqs.Queue(self.target_descriptor.sqs_url)
        (result, took_time) = wall_time(queue.send_message, MessageBody=body)
        metadata = result['ResponseMetadata']
        status = int(metadata['HTTPStatusCode'])
        size = int(metadata['HTTPHeaders']['content-length'])
        print(result)
        return TransportResult(status=status,
                               result_text='',
                               took_s=took_time,
                               size=size)