def playlog()

in _archiving/contribution/anhyobin/src/generator.py [0:0]

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

def playlog():

    flag = 0
    temp = 0

    for line in input_data:
        # Ingest data to Kinesis Firehose in 0.03 seconds
        if(temp != 0 and temp % 1000 == 0):
            flag += 1

        time.sleep(0.03)
        temp += 1

        raw_data = {}
        raw_data.update(line)

        raw_data['posnewz'] = int(raw_data['posnewz'])
        raw_data['posnewy'] = int(raw_data['posnewy'])
        raw_data['posnewx'] = int(raw_data['posnewx'])
        raw_data['pidx'] = int(raw_data['pidx'])
        raw_data['action'] = int(raw_data['action'])
        raw_data['posoldx'] = int(raw_data['posoldx'])
        raw_data['posoldy'] = int(raw_data['posoldy'])
        raw_data['posoldz'] = int(raw_data['posoldz'])
        raw_data['idx'] = int(raw_data['idx'])

        # Write json file to /tmp/playlog/
        filename = '/tmp/playlog/' + str(flag) + '_playlog.json'
        with open(filename, 'a') as logFile:
            json.dump(raw_data, logFile)
            # Kinesis Agent parsed from each file based on \n
            logFile.write('\n')
            os.chmod(filename, 0o777)
    
    print('all play log has been generated')