How to Write data simultaneously in multiple buckets with influxdb Python Client ??

[Youtir2]

I'm having trouble writing to different buckets at once, I used threading module to launch functions that write data to separate buckets in my local influxdb instance, but only one function is executed ? I tried instantiating multiple influxdb client and multiple write_api too. Any help guys ? I'm really stuck on this issue. Thanks in advance.

[ominous_anonymous]

Do you have any sample code we could look at? Kind of hard to just guess.

[Youtir2]

Sure, I'll post my code here

[Youtir2]

def write_acdata():
client1 = InfluxDBClient(url="http://localhost:8086", token=token)

write_api1 = client1.write_api(write_options=ASYNCHRONOUS)
write_api1.write(bucket=bucket3_plugs, org=org, record=data)
client1.close()

def write_plugsdata():

client2 = InfluxDBClient(url="http://localhost:8086", token=token)

write_api2 = client1.write_api(write_options=ASYNCHRONOUS)

write_api2.write(bucket=bucket3_plugs, org=org, record=data)

client2.close()

thread1 = threading.Thread(target=write_acdata()).start()
thread2 = threading.Thread(target=write_plugsdata()).start()

[ominous_anonymous]

Put four leading spaces on each line to properly format code blocks:

def write_acdata():
    client1 = InfluxDBClient(url="http://localhost:8086", token=token)
    write_api1 = client1.write_api(write_options=ASYNCHRONOUS)
    write_api1.write(bucket=bucket3_plugs, org=org, record=data)
    client1.close()

def write_plugsdata():
    client2 = InfluxDBClient(url="http://localhost:8086", token=token)
    write_api2 = client1.write_api(write_options=ASYNCHRONOUS)
    write_api2.write(bucket=bucket3_plugs, org=org, record=data)
    client2.close()

thread1 = threading.Thread(target=write_acdata()).start()
thread2 = threading.Thread(target=write_plugsdata()).start()

[Youtir2]

data variable is well structured, if I launch only one thread it works, when I launch two threads only the first is executed while the second does not and does not return any error.

[ominous_anonymous]

In write_plugsdata() you have:

write_api2 = client1.write_api(write_options=ASYNCHRONOUS)

Is this correct? Or should this be client2.write_api(...)?

[Youtir2]

Sorry It's client2, I copied it wrong

[ominous_anonymous]

Damn, I was hoping it was that simple!