问题标签 [influxdb-python]

我有一个 influxDB ，testdb我正在尝试对具有fieldtype不同.fieldTypefieldType

设置

现在我有 4 个测量值，即 , rpm, load, 。他们是：modeexecutionfieldType

我可以做什么

我能够从多个相同的测量中成功获得结果fieldType。

问题

我无法将所有 4 个测量值合并到一个查询中。下面的查询应该返回所有 4 个测量的结果，而不是只返回float类型的结果。

如果我更改顺序，我会得到相同的结果：

有没有办法让我获得结果string并float输入一个结果集？

我正在尝试编写脚本以将一些数据推送到 InfluxDB 并且代码执行时不会出现错误/警告。我有以下 python 输出，我想在 Influxdb 上插入：

我看到以下错误：

我的脚本中的片段

谁可以帮我这个事？

我们的查询需要 20 秒，我们需要大大减少这个时间。我们通过 python 数据框客户端调用它，但我通过 CLI 客户端重现了相同的查询和 20 秒的响应时间：

Influx 在带有 EBS 通用 SSD (gp2) 卷的 r5.large EC2 实例上运行，CLI 位于同一子网中的 EC2 上。该查询返回 747120 行，每行有 1 个标签 (turbine_id) 和 5 个字段（所有十进制值）。这看起来很正常吗？

通过 influx 主机上的 htop，我发现 RAM 使用没有显着变化，在查询开始时会出现短暂的 CPU 峰值，持续约 1 秒，然后没有后续的 CPU 活动。

分片持续时间设置为 1 年。

我尝试将 influxdb 主机缩放到 r5.8xlarge 并且查询时间根本没有改变。

请让我知道我们可以进行的任何优化。

我正在执行一个 influxSQL 查询，该查询在 1 分钟内返回结果。询问 ：

单独的查询，如

也需要超过 1 分钟才能返回。

而查询

返回结果非常快，在几秒钟内，如 3-4 秒。

表（测量值）xyz 非常大。有超过 1000 万条记录符合这个 where 条件。call_duration 和 recipient_id 是 Fields 而 target_id 是 Tag

虽然 MIN 和 MAX 函数返回结果非常快，但我怀疑为什么 SUM 需要更多时间？

InfluxDB 版本：1.7.4 机器配置 - AWS EC2 - t2.medium（4 GB RAM）

配置文件：

我认为结果应该在 5-6 秒内返回

mydb我在 Influxdb 上创建了一个新数据库。接下来我做了use mydb 当我在我的数据库上运行插入时，我遇到了错误 - ERR: {"error":"unable to parse 'angle, userid=1, product=pname value=5.1': missing tag key"}

这是我正在运行的插入 - INSERT angle, userid=1, product=dname value=5.1

我正在使用（使用 DataFrameClient）将值（浮点数）写入 Influx 数据库，以及两个标签：ID 和时间戳

在我的循环中，碰巧我连续多次写入同一个数据库，如下所示：

有人告诉我，可以将这些写入请求批处理为一个，这将减少 Influx 的负载。

write_to_influx我实际上在掌握这个问题时从另一个脚本中窃取了该方法。在文档中它说

参数：points（字典列表，每个字典代表一个点）——要写入数据库的点列表

但是有了write_to_influx(value_1, ID_1)，不仅有一个字典，还传递了一个数据点 ID。

类似于已经应用的方法和文档描述......如果我想将多个值写入多个数据点 ID，我应该传递一个字典列表和一个数据点 ID 列表吗？因为这似乎不起作用：

而真：

返回错误：

我的问题：如何一次写入多个条目（到同一个数据库）？write_points 是 write 方法吗？DataFrameClient 呢？

我正在使用批量插入数据的 Python 库将数据插入 InfluxDB。从下图中，我想要的是在三个点中的每一个处发出警报，阈值被违反，但由于数据是分批插入的，我似乎无法找到正确的警报设置组合来执行此操作。我能得到的最好的结果是使用max. last根本不会触发警报，因为批量插入的最后一个数据点从未超过阈值。

有没有办法做到这一点？也许通过检查每个数据点？请注意，数据是 1Hz 并且不是“实时”的，在将数据插入 InfluxDB 之前需要大约一个小时来收集和处理数据，但这可能会有所不同。

所以，我的Influx数据库部署在我的AWS Kubernetes Cluster(EKS).
我想要的是能够用我的python项目连接数据库并能够查询数据库。
我可以看到我可以使用 Influx API，就像这些示例一样，但我无法配置数据库，因为它没有部署在本地。既然数据库已部署在 EKS 中，我应该如何配置它？
我做了一些研究，但到目前为止没有任何帮助。
我是 Kubernetes 和 Influx 的新手，所以也许这是一个简单的问题，无论如何，任何建议或提示都会受到赞赏。

我正在编写一个简短的 Python 脚本，以允许用户更改标签上的保留长度。用户输入他们希望查看的测量值，然后在提示可能的“标识符”后，他们输入他们想要更改的那个，然后输入持续时间。它看起来像这样：

该脚本检查用户输入的持续时间是否与现有的保留策略相同，如果不是则创建一个新的。我的问题分为两部分：

1. 我真的很难找到有关 RP 的任何深入文档，但是在 influx 社区帖子中我发现了这个查询： SELECT * INTO <new_RP>.<measurement_name> FROM <old_RP>.<measurement_name> WHERE <tage_key> = '<tag_name>'所以我试图验证它是否适用于示例数据库

有谁知道这里的输出“书面”是什么意思？如果这意味着没有数据改变了他们的 RP，那么我猜要么我输入了错误的查询，要么它不起作用

2. 运行我的脚本后，我得到了这个错误

有谁知道是什么partial write: points beyond retention policy dropped=7294意思？我在想这可能是因为我输入的保留政策比数据的时间戳更早/更短，但我不知道是这种情况谢谢

我有一些代码必须再次编写才能准备好生产。代码很乱，我有几行表示 sql 查询，但我无法解析确切的语句。

如果有人能为我解决 sql 查询语句，我将不胜感激。需要明确的是，我对这些部分感兴趣： ("device" =~ /^('+qs+')/) ("location"=~ /^'+loc+'$/)