Influxdb read/write 操作
Influxdb read/write operations
Influxdb 版本 - 0.9rc30。 influxdb-python - 2.3.0
尝试来自 here 的示例。
如果我在 client.write_points(data)
之后立即使用 client.query(query)
,则查询结果中没有数据。但是,当我尝试 python 的 sleep 函数时
client.write_points(data)
sleep(0.5)
result = client.query(query)
print("Result: {0}".format(result))
我确实得到了正确的回应。这是否意味着,当脚本试图从数据库中获取一些数据时(没有 sleep
),该数据还不存在?
有没有其他方法可以解决?
提前致谢。
数据并非即时可用,具体取决于您的设置和写入的数据量。只要中断不会导致数据丢失,就可以在写入完全复制到数据存储之前接受写入。我怀疑你需要 0.5 秒的睡眠,不过,几十毫秒应该足够了。
如果这是一个全新的数据库,则 RC30 中还有一个刚刚修补的错误 (https://github.com/influxdb/influxdb/pull/2610) 导致第一批写入数据库的写入速度变慢。
Influxdb 版本 - 0.9rc30。 influxdb-python - 2.3.0
尝试来自 here 的示例。
如果我在 client.write_points(data)
之后立即使用 client.query(query)
,则查询结果中没有数据。但是,当我尝试 python 的 sleep 函数时
client.write_points(data)
sleep(0.5)
result = client.query(query)
print("Result: {0}".format(result))
我确实得到了正确的回应。这是否意味着,当脚本试图从数据库中获取一些数据时(没有 sleep
),该数据还不存在?
有没有其他方法可以解决?
提前致谢。
数据并非即时可用,具体取决于您的设置和写入的数据量。只要中断不会导致数据丢失,就可以在写入完全复制到数据存储之前接受写入。我怀疑你需要 0.5 秒的睡眠,不过,几十毫秒应该足够了。
如果这是一个全新的数据库,则 RC30 中还有一个刚刚修补的错误 (https://github.com/influxdb/influxdb/pull/2610) 导致第一批写入数据库的写入速度变慢。