def handler()

in functions/source/s3-to-lifecycle-events-converter/handler.py [0:0]

• 15 lines of code
• 2 McCabe index (conditional complexity)

def handler(event, context):
    sqs_messages = []

    s3_client = boto3.client('s3', region_name=os.environ.get("AWS_REGION"))

    for record in event['Records']:
        bucket = record['s3']['bucket']['name']
        key = unquote_plus(record['s3']['object']['key'])
        tmpkey = key.replace('/', '')
        download_path = '/tmp/{}{}'.format(uuid.uuid4(), tmpkey)
        s3_client.download_file(bucket, key, download_path)

        with open(download_path) as json_file:
            data = json.load(json_file)

            sqs_messages += data.get('assetModels', [])
            sqs_messages += data.get('assets', [])

    cache_integration_points(sqs_messages)
    send_sqs_messages(sqs_messages)