import json import os import boto3 from botocore.exceptions import ClientError import logging def dw_aurora_error_handler(event, context): TOPIC_ARN = os.environ["TOPIC_ARN"] LOG_LEVEL = os.environ.get('LOG_LEVEL') logger = logging.getLogger() level = logging.getLevelName(LOG_LEVEL) if not isinstance(level, int): level = logging.INFO logger.setLevel(level) snsClient = boto3.client("sns") logger.info(f'TOPIC_ARN: {TOPIC_ARN}') try: res = snsClient.publish(TopicArn=TOPIC_ARN, Message=event["error"], Subject="Stored Procedure Error") except ClientError as e: print(e) raise e logger.info(f'----------- Finished SP Error Reporting -----------')