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
)