def put_metrics()

in lambda/metric_stream_producer.py [0:0]

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

def put_metrics(metrics_data: List[dict], time: datetime, event: dict, context: dict, metric_sets):
    """Put records to kinesis stream"""
    try:
        KINESIS_CLIENT.put_records(
            Records=translate_metrics_to_records(
                metrics_data=metrics_data,
                time=time,
                event=event,
                context=context,
                metric_sets=metric_sets
            ),
            StreamName=os.environ[StreamName(event['frequency']).name]
        )
    except ClientError as ex:
        raise ex