使用 influxdb 记录高频时间序列数据

Question

我想每 10 毫秒记录一次数据。下面是示例代码：

with InfluxDBClient(url=url, token=token, org=org, enable_gzip=True) as client:
    with client.write_api(
        write_options=WriteOptions(
            batch_size=100, flush_interval=500, jitter_interval=0
        )
    ) as write_client:

        while True:
            time.sleep(0.01)
            val = np.random.randint(10)
            print(val)
            write_client.write(
                bucket,
                org,
                {
                    "measurement": "my_measurement",
                    "fields": {"my_value": int(val)},
                },
            )
            write_client.flush()

但是，上面的记录并没有按要求的频率进行记录。另外，在这种情况下如何处理批处理也让我感到困惑。

Answer 1

您需要为数据点指定时间，否则服务器接收到数据点时将为其分配服务器时间。批处理不会对其产生更大的影响。