def write_data()

in modules/influxdb-subscriber/src/data2influxdb_v2test.py [0:0]

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

    def write_data(payload_message, token_string, url, bucket_name, org, measurement_name):
        bucket = bucket_name
        #Create a Influxdb client and write each datapoint from JSON message to influxdB
        with InfluxDBClient(url, token=token_string, org=org) as client:
            with client.write_api(write_options=SYNCHRONOUS) as write_api:
                print('*** Write Points ***')
                payload_message['Picture'] = "data:image/png;base64, " + payload_message['Picture']
                dictionary = [{"measurement": measurement_name,"tags": {tag_name: tagkey},"fields": payload_message}]
                try:
                    print("Write")
                    write_api.write(bucket=bucket,record=dictionary)
                except Exception as e:
                    print(sys.exc_info())
                    traceback.print_exc()
                print('***Wirte Points Finished ***')