def prepare_record()

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

• 15 lines of code
• 4 McCabe index (conditional complexity)

def prepare_record(some_measures, device_id, delta_seconds):
    current_time = int((time.time() - delta_seconds) * 1000)
    record = {
        'Time': current_time,
        'DeviceID': device_id,
    }

    for measure_field in some_measures:
        measure_value = random.uniform(measure_field['start'], measure_field['end'])
        if random.random() < chance_of_anomaly:
            if random.random() > 0.5:
                measure_value = measure_value + measure_field['end']
            else:
                measure_value = measure_value - measure_field['start']
        record[measure_field['measure'] + '_measure'] = measure_value

    return record