iframe-proxy | Sunbelt Computer Software

44 lines (34 loc) · 1.13 KB

import json
import logging
import boto3
logger = logging.getLogger()
logger.setLevel(logging.DEBUG)
QUEUE_URL = os.getenv('QUEUE_URL')
SQS = boto3.client('sqs')
def producer(event, context):
    status_code = 200
    message = ''
    if not event.get('body'):
        return {'statusCode': 400, 'body': json.dumps({'message': 'No body was found'})}
        message_attrs = {
            'AttributeName': {'StringValue': 'AttributeValue', 'DataType': 'String'}
        SQS.send_message(
            QueueUrl=QUEUE_URL,
            MessageBody=event['body'],
            MessageAttributes=message_attrs,
        message = 'Message accepted!'
    except Exception as e:
        logger.exception('Sending message to SQS queue failed!')
        message = str(e)
        status_code = 500
    return {'statusCode': status_code, 'body': json.dumps({'message': message})}
def consumer(event, context):
    for record in event['Records']:
        logger.info(f'Message body: {record["body"]}')
        logger.info(
            f'Message attribute: {record["messageAttributes"]["AttributeName"]["stringValue"]}'

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

handler.py

Latest commit

History

handler.py

File metadata and controls