How can I insert data synchronously?

[tungrix]

I am keep getting list of dict in multiple data sources at the same time, how can I insert them to different bucket in InlfuxDB synchronously?

[bednar]

Your code from #546 is pretty fine:

from time import time

from influxdb_client import WritePrecision, InfluxDBClient
from influxdb_client.client.write_api import SYNCHRONOUS

with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org", debug=True) as client:
    write_api = client.write_api(write_options=SYNCHRONOUS)
    write_api.write(bucket="test1",
                    record={"symbol": 'BTCUSDT', "price": 16813.0, "timestamp": int(time())},
                    record_measurement_name="symbol",
                    record_time_key="timestamp",
                    record_tag_keys=[],
                    record_field_keys=["price"],
                    write_precision=WritePrecision.S)

Regards

[tungrix]

My situation is like:

def callback1(data):
    write_api.write()

def callback2(data):
    write_api.write()

client = WebscoketClient()
client.trade_data(callback=callback1)
client.orderbook(callback=callback2)

while True:
    sleep(1)

I think the above code can't insert data synchronously.
Is there any suggestion or example can help me achieve this?
Or should I need to use multiprocessing or threading?