def send_to_dlq()

in functions/source/cfct_register/cfct_register.py [0:0]


def send_to_dlq(event):
    try:
        sqsClient = session.client('sqs')
        newRelicDLQ = os.environ['newRelicDLQ']
        sqsResponse = sqsClient.send_message(
            QueueUrl=newRelicDLQ,
            MessageBody=json.dumps(event))
        logger.info("Sent to DLQ: {}".format(event))
    except Exception as sqsException:
        logger.error("Failed to send to DLQ: {}".format(sqsException))