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