src/BatchJobsStates/JobStatesToCW/app.py [31:75]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    try:
        metrics.set_namespace("AWSBatchMetrics")
        logger.info(f"Deactivate metrics.should_use_default_dimensions {metrics.context.should_use_default_dimensions}")
        metrics.context.should_use_default_dimensions = False
        logger.info(f" Done metrics.should_use_default_dimensions {metrics.context.should_use_default_dimensions}")

        # use the event timestamp instead of using the EMF context timestamp
        metric_converted_time = datetime.datetime.strptime(metric_time, '%Y-%m-%dT%H:%M:%SZ')
        metric_converted_time = int(round(metric_converted_time.timestamp()*1000))
        metrics.context.meta['Timestamp'] = metric_converted_time

        for k, v in dimensions.items():
            metrics.put_dimensions({k:v})
        metrics.put_metric(metric_name, 1, "Count")
        for k, v in properties.items():
            metrics.set_property(k, v)

    except ClientError as e:
        message = f"Error adding CloudWatch metric job resubmission: {format(e)}"
        logger.warning(message)
        raise Exception(message)
    return

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



src/ECSRunTask/RunTaskToCW/app.py [32:77]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    try:
        metrics.set_namespace("AWSBatchMetrics")
        logger.info(f"Deactivate metrics.should_use_default_dimensions {metrics.context.should_use_default_dimensions}")
        metrics.context.should_use_default_dimensions = False
        logger.info(f" Done metrics.should_use_default_dimensions {metrics.context.should_use_default_dimensions}")

        # use the event timestamp instead of using the EMF context timestamp
        metric_converted_time = datetime.datetime.strptime(metric_time, '%Y-%m-%dT%H:%M:%SZ')
        metric_converted_time = int(round(metric_converted_time.timestamp()*1000))
        metrics.context.meta['Timestamp'] = metric_converted_time

        for k, v in dimensions.items():
            metrics.put_dimensions({k:v})
        metrics.put_metric(metric_name, 1, "Count")
        for k, v in properties.items():
            metrics.set_property(k, v)

    except ClientError as e:
        message = f"Error adding CloudWatch metric job resubmission: {format(e)}"
        logger.warning(message)
        raise Exception(message)
    return


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