def put_slas()

in lambda/sla_stream_producer.py [0:0]


def put_slas(slas_data: List[dict], time: datetime, event: dict, context: dict, metric_sets):
    """Put records to kinesis stream"""
    KINESIS_CLIENT.put_records(
        Records=translate_clas_to_records(
            slas_data=slas_data,
            time=time,
            event=event,
            context=context,
            metric_sets=metric_sets
        ),
        StreamName=KINESIS_STREAM_NAME
    )