def lambda_handler()

in lambda/dynamo_stream/app.py [0:0]

• 13 lines of code
• 7 McCabe index (conditional complexity)

def lambda_handler(event, context):

    logger.info(event)

    for record in event['Records']:
        event_name = record['eventName']

        metrics.add_metric(
            name=metric_names[event_name], unit=MetricUnit.Count, value=1)

        if event_name == "INSERT" or event_name == "MODIFY":
            item = {k: deserializer.deserialize(
                v) for k, v in record['dynamodb']['NewImage'].items()}
            
            # Return and report the failed record as soon as we encounter a problem
            if 'error' in item['id']:
                logger.error(item)
                return {"batchItemFailures":[{"itemIdentifier": record["dynamodb"]["SequenceNumber"]}]}

    return