def handler()

in cdk/stacks/sample_kinesis_stream_producer/producer_lambda/app.py [0:0]

• 11 lines of code
• 3 McCabe index (conditional complexity)

def handler(event, context):
    sent = 0
    for x in range(iterations):
        records = []
        for device_id in device_ids:
            records.append(prepare_record(measures, device_id,
                                          (iterations - x) / iterations * 60))

        print("records {}".format(len(records)))
        write_records(event["Stream"], records)
        sent = sent + len(records)
    return {"records": sent}