7

我正在尝试使用 InfluxDB 的 Python 客户端来检索存储在 InfluxDB 上的数据，但不能超过 10k 行。我（未成功）遵循的示例是here。总之：

import influxdb
dfclient = influxdb.DataFrameClient('localhost', 8086, 'root', 'root', 'mydb')
q = "select * from some_measurement"
df = dfclient.query(q, chunked=True)  # Returns only 10k points

该问题似乎与此处记录的 InfluxDB 的内部限制有关（即max-row-limit配置选项）。我正在浏览资源以尝试找出如何获得大于 10k 行的 DataFrame，但对于解决此问题的任何帮助将不胜感激。

4

2 回答 2

8

问题是由DataFrameClient'query简单地忽略chunked参数 [代码] 引起的。

我发现的解决方法是不使用标准InfluxDBClient。问题中显示的代码变为：

import influxdb
client = influxdb.InfluxDBClient('localhost', 8086, 'root', 'root', 'btc')
q = "select * from some_measurement"
df = pd.DataFrame(client.query(q, chunked=True, chunk_size=10000).get_points())  # Returns all points

值得强调的是，从 v1.2.2 开始，max-row-limit设置（即上述代码中的默认值chunk_size）已从 10k 更改为无限制。

于 2017-04-25T10:44:12.407 回答
3

您是否尝试在查询中设置分块标志以分块接收数据。这可以使用如下查询来完成：

influxdb.DataFrameClient(host='localhost', port=8086, username='root', password='root', database=None, ssl=False, verify_ssl=False, timeout=None, use_udp=False, udp_port=4444, proxies=None)

您可以在第 1.2.3 节中阅读更多信息

于 2017-03-05T03:04:52.490 回答