def write_batch_timestream()

in log-processor/lambda_function.py [0:0]

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

def write_batch_timestream(records, record_counter):
    try:
        result = timestream_write.write_records(DatabaseName = DATABASE_NAME, TableName = TABLE_NAME, Records = records, CommonAttributes = {})
        print('Processed [%d] records. WriteRecords Status: [%s]' % (record_counter, result['ResponseMetadata']['HTTPStatusCode']))
    except Exception as e:
        print(records)
        raise Exception('There was an error writing records to Amazon Timestream when inserting records')