def lambda_handler()

in traffic_mirroring/cloudwatch_event_handler.py [0:0]


def lambda_handler(event, context):
    log.info("Parsing event: %s", event)
    
    instance = parse_event(event)
    if not instance:
        log.warn("The event type is either invalid or not supported")
        return

    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)