问题标签 [influxdb-python]

我有一个数据集，有必要将时间戳增加一纳秒，以避免我的观点被视为重复。（从文档中得到建议）

检查数据库中是否已经存在具有特定标签集和时间戳的点的最佳方法是什么？

目前我这样做：

如果结果不为空，则给定点是重复的。当发现重复时，时间戳会添加一纳秒。每次必须将一个点写入数据库时​​，我都会进行此检查，但这对吞吐量有很大影响。有没有更好的方法来处理这个问题？

我正在通过https://www.influxdata.com/blog/getting-started-python-influxdb/文档来使用 python 查询 influxdb。

我能够创建数据库：

另外，我还在数据库中发送数据：

调用 json 主体为：

但很快，我想从数据库中查询指标：

此查询导致错误：

文件 ipython-input-31-6e47204db16b，第 1 行，模块 client.query('SELECT "duration" FROM "pyexample"."autogen"."brushEvents" WHERE time > now() - 4d GROUP BY "user"')

文件“/home/rahul/anaconda2/lib/python2.7/site-packages/influxdb/client.py”，第 420 行，在 data.get('results', []) 中的查询

文件“/home/rahul/anaconda2/lib/python2.7/site-packages/influxdb/resultset.py”，第 25 行，在init中 引发 InfluxDBClientError(self.error)

我怎样才能得到查询结果？

我检查了保留政策，也发现了错误：

回溯（最近一次通话最后）：

文件“”，第 1 行，在 client.query('SHOW RETENTION POLICIES')

文件“/home/rahul/anaconda2/lib/python2.7/site-packages/influxdb/client.py”，第 409 行，查询 expected_response_code=expected_response_code

请求中的文件“/home/rahul/anaconda2/lib/python2.7/site-packages/influxdb/client.py”，第 286 行，引发 InfluxDBClientError（response.content，response.status_code）

InfluxDBClientError: 400: {"error":"error parsing query: found EOF, expected ON at line 1, char 25"}

我想使用 asyncio 将 UDP 消息发送到我的 InfluxDB 服务器。这是我的同步代码：

如何使用 async/await 语法重写“write_udp”函数？

-- 编辑 2018 年 7 月 5 日 --

更具体地说，我不确定如何引用“socket”的异步等价物。大概有一个基于异步套接字的版本，我将其引用为 self.udp_socket = socket.socket_asyncio，然后我将通过 await socket.socket_asyncio.sendto(....) 触发消息我需要了解的是如何引用这个基于异步的套接字对象。

我需要csv使用 python 以格式呈现来自数据库的查询结果。

上述代码行检索查询结果为：

Out[5]: ResultSet({'(u'n', None)': [{u'sid': 3, u'time': u'2018-07-04T04:58:22Z', u'M' : u'01081093', u'N': u'01081093', u'iid': u'0', u'V': 4, u'sd': u'0', u'ides': u' 0'}, {u'sid': 3, u'time': u'2018-07-04T04:58:22Z', u'M': u'01081093', u'N': u'01081093', u'iid'：无，u'V'：4，u'sd'：无，u'ides'：无}

现在我需要这些结果的形式csv，所以下一行代码是：

res.to_csv("/home/rahul", sep=",", encoding="utf-8")

但在这里我得到以下错误：

回溯（最近一次通话最后）：

文件 ""，第 1 行，在 res.to_csv("/home/surya", sep=",", encoding="utf-8")

AttributeError：“ResultSet”对象没有属性“to_csv”

如何纠正这一点，我ResultSet在 stackoverflow 上看到了一些错误，但我无法检索我的结果以进行csv格式化。

我在制作需要 STREAM 并提供 BATCH 的 UDF 时遇到了麻烦。

这边走：

有人有示例代码吗？我在网上搜索（论坛、文档），但所有示例都是针对 BATCH-BACH、STREAM-STREAM 或 BATCH-STREAM。

我在示例中看到，在编写对 Kapacitor 的响应时，在“end_batch(self,end_req)”方法中，有必要“传达”BATCH 已经结束，在一个示例中，这是这样制作的：

为了发送 BATCH，我必须从“point(self,point)”方法发送它，但无法访问 end_req 对象并且不知道如何创建一个。

提前致谢！再见！

我在不知不觉中使用了 delete 和 deleted 值，谁能告诉我如何撤销 influx db 中的删除命令。我正在使用最新版本的 influxdb。

例如：从 'aaa' 中删除 name='abcd'

请在这个问题上帮助我。谢谢你。

我正在使用 influxdb 来存储我的生产服务器 CPU/MEMORY 利用率。最近我的客户问是否可以查询出一段时间内或每月所有服务器的工作时间和非工作时间的平均利用率。例如，如果工作时间是早上 6 点 - 下午 6 点，非工作时间是下午 6 点 - 早上 6 点。是否可以查询一个月或某周或某天的服务器平均利用率。

我正在使用 influxdbClient 通过 python 查询 Influxdb。

简单的查询适用于：

from influxdb import InfluxDBClient

client = InfluxDBClient(host='192.168.1.104', port=8086)

client.get_list_database()

client.switch_database('Mlogi_ALL')

res= client.query('SELECT * FROM n')

但是当我查询时：

client.query('SELECT * FROM n WHERE (time >= 2018-06-01T00:00:00Z AND time <= 2018-07-30T00:00:00Z')

它给出了错误：

InfluxDBClientError: 400: {"error":"error parsing query: found -06, expected ) at line 1, char 36"}

我哪里错了？

我在 python 中使用 Influx DataFrameClient 来检索数据：

但是查询检索dict格式的数据有很多不正确的标题移位（这让我感到惊讶）：

我尝试pandas.DataFrame(q)将查询的数据转换为 dataFrame 但没有奏效。

那么，在这里我如何绘制数据date与value数据的关系，如果需要对数据进行操作，如何申请pandas操作？

有什么方法可以使用 pandas 将这些查询的数据转换为 dataFrame 并因此对其进行可视化处理？

我正在尝试将订单簿数据存储到流入数据库中。这是数据的样子：

Level是订单簿中的深度。所以 Level=0 将是本书的顶部。当我写点时：

因为它们都有相同的时间戳，所以我只得到 Level=10 的条目。它会覆盖其他的。我猜我需要一些如何将 Level 设置为 atag以便每一行都可以是唯一的，但我不知道该怎么做。