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))