def generate()

in datagen/stock.py [0:0]

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

def generate(stream_name, kinesis_client):
    while True:
        data = get_data()
        print(data)
        kinesis_client.put_record(
            StreamName=stream_name,
            Data=json.dumps(data),
            PartitionKey="partitionkey")