def lambda_handler()

in src/BatchJobsStates/JobStatesToCW/app.py [0:0]

• 29 lines of code
• 8 McCabe index (conditional complexity)

def lambda_handler(event, context):

    logger.info(f"Transform event to metric {json.dumps(event)}")

    for record in event["Records"]:
        rec = json.loads(record["body"])

        if 'ECSCluster' in rec['Properties']:
            ecs_cluster = rec['Properties']['ECSCluster'].split('/')[-1].split('_Batch')[0]
            rec['Properties']['ECSCluster'] = ecs_cluster

        if 'ECSCluster' in rec['Dimensions']:
            ecs_cluster = rec['Dimensions']['ECSCluster'].split('/')[-1].split('_Batch')[0]
            rec['Dimensions']['ECSCluster'] = ecs_cluster

        if 'JobQueue' in rec['Properties']:
            job_queue = rec['Properties']['JobQueue'].split('/')[-1]
            rec['Properties']['JobQueue'] = job_queue

        if 'JobQueue' in rec['Dimensions']:
            job_queue = rec['Dimensions']['JobQueue'].split('/')[-1]
            rec['Dimensions']['JobQueue'] = job_queue

        if 'JobDefinition' in rec['Properties']:
            job_queue = rec['Properties']['JobDefinition'].split('/')[-1]
            rec['Properties']['JobDefinition'] = job_queue

        if 'JobDefinition' in rec['Dimensions']:
            job_queue = rec['Dimensions']['JobDefinition'].split('/')[-1]
            rec['Dimensions']['JobDefinition'] = job_queue

        embedded_metrics_placed_jobs(
            rec["Dimensions"],
            rec["Properties"],
            rec['MetricName'],
            rec['MetricTime'])

    logger.info(f"Metrics sent to EMF")


    return