def lambda_handler()

in traffic_mirroring/backfill_handler.py [0:0]


def lambda_handler(event, context):
    log.info("Parsing event: %s", event)

    instances = parse_sns_message(event)
    if not instances:
        return

    for instance in instances:
        log.info("Parsed instance: %s", instance)
        if requires_session(ec2, instance):
            try:
                handle_event(ec2, instance, CONFIG)
            except ClientError as e:
                log.error("Failed to setup traffic mirroring for %s due to error: %s",
                          instance.network_interface_id, e)
    
    publish_sns_message()