handler.py 文件源码

def handler(event, context):
    log.debug("Received event {}".format(json.dumps(event)))

    stage = event['ResourceProperties']['Stage']
    topicNamePrefix = event['ResourceProperties']['TopicNamePrefix']
    topicName = topicNamePrefix + '-' + stage
    requestType = event['RequestType']

    # Initialize a Session object in order to look up Config regions
    boto3Session = boto3.Session()

    # All Config regions
    snsRegions = boto3Session.get_available_regions(
        service_name='sns',
        partition_name='aws',
    )

    if "Create" in requestType:
        create_topics(snsRegions, topicName, context, event, stage)

    elif "Update" in requestType:
        create_topics(snsRegions, topicName, context, event, stage)

    elif "Delete" in requestType:
        delete_topics(snsRegions, topicName, context, event)