问题标签 [influxdb-2]

在尝试理解 InfluxDb 的不同概念时，我遇到了这个文档，其中有一个与 SQL 数据库的术语比较。

InfluxDB 测量类似于 SQL 数据库表。
InfluxDB 标签就像 SQL 数据库中的索引列。
InfluxDB 字段就像 SQL 数据库中的未索引列。
InfluxDB 点类似于 SQL 行。

但是我遇到了其他几个术语，我无法清楚地理解这些术语，并想知道是否有与之对应的 SQL。

系列
铲斗

根据我从文档中了解到的

系列是共享保留策略、度量和标签集的数据集合。

这是否意味着系列是数据库表中数据的子集？还是它像数据库视图？
我看不到任何解释存储桶的文档。我猜这是 2.0 版本中的一个新概念

有人可以澄清这两个概念吗？

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

我想在 InfluxDB 中存储交易以及最佳询价/出价数据，后者的更新速度比前者快得多。

如果可能的话，我想使用一个允许我查询的模式：“对于市场 X 上的每笔交易，找到时间戳为 <= 交易时间戳的市场 Y 上的最佳卖价/买价”。

（我会使用任何版本的 Influx。）

例如，交易可能如下所示：

报价数据可能看起来更像这样：

我希望能够以某种方式加入某个市场的每笔交易，例如foo-bar，只有其他市场上的最新询价/出价数据点，例如bar-baz，并得到如下结果：

这样我就可以计算市场foo-bar上的交易价格与市场bar-baz上最近报价的询价或出价之间的差异。

现在，我将交易存储在一个时间序列中，并在另一个时间序列中存储要价/投标数据点，然后在客户端将它们合并，逻辑如下：

问题是客户不得不丢弃大量的买/卖数据点，因为它们更新如此频繁，并且只有交易前的最新更新是相关的。

有几十个市场，我可能想比较交易的最新询价/出价，否则我只需将最新的询价/出价存储在与交易相同的系列中。

是否可以用 Influx 或其他时间序列数据库做我想做的事情？产生较低质量结果的另一种解决方案是按某个时间间隔（例如 250 毫秒）对要价/投标数据进行分组，并从每个间隔中取最后一个，以至少对客户之前必须放弃的报价数量施加上限找到最接近下一笔交易的交易。

我想在评估检查之前的 3 小时内特定类型事件的计数小于 5 时发出警报，但我需要每 15 分钟进行一次检查。

由于我需要比我测量的时间跨度更频繁地检查，因此我无法根据我的原始数据执行此操作（根据文档，“[时间表] 间隔与检查查询的聚合函数间隔匹配” . 但我想我可以使用“任务”将我的数据转换成可以工作的形式。

我能够通过通量查询以我希望的方式聚合数据，甚至将生成的滚动计数保存到仪表板。

结果如下散点图。

我希望我可以将其复制粘贴为一项新任务，并获得我漂亮的新聚合数据集。在解决了几个清晰的语法错误之后，我确定了以下任务定义：

不幸的是，我遇到了一个在任何地方都找不到的错误：could not execute task run; Err: no time column detected: no time column detected.

如果您能帮助我调试此任务运行错误，或通过以其他方式完成此任务来回避它，我将非常感激。

我想将跨不同保留策略的相同度量查询到单个图表中。理想情况下，我想在查询本身中执行此操作，因为我正在使用 Grafana。

根据 Flux 文档，“Flux 在表格中构建所有数据。当数据从数据源流式传输时，Flux 将其格式化为带注释的逗号分隔值 (CSV)，表示表格。然后函数操作或处理它们并输出新表格。”

在这种情况下，不同的保留策略会表现得像不同的表吗？我可以使用 union() 函数来获得我想要的吗？任何见解将不胜感激。

谁能帮我将 Telegraf 流式传输到云 InfluxDB 中？我使用本教程，python 脚本在我的本地机器上启动，并将通知推送到 rabbitMQ。Telegraf 通过此配置订阅了 rabbitMQ。

日志显示数据正在写入 influxdb 云

但我在云 Influxdb 中找不到数据

什么是等效通量查询SELECT address, name FROM addresses？（我指的是 InfluxData 开发的新型查询语言 FluxQL）

在有限的 Flux 文档中，我没有找到明确的答案。Flux 文档说filter()function 等同于SELECTandWHERE子句，但是给出的所有示例都等同于WHERE子句，在SELECT.

这些是 FluxQL 的文档以便更好地参考：

https://docs.influxdata.com/flux/v0.50/introduction/getting-started

https://v2.docs.influxdata.com/v2.0/query-data/get-started/

我已经将Influxdb 2.0.0部署为具有 EBS 卷持久性的 Statefulset。我注意到，如果由于某种原因，pod 被重新调度到其他节点，或者即使我们缩小 statefulset pod replicas = 0 然后扩大，对持久化数据的影响也是一样的：它们会丢失。

最初，如果 pod 被重新安排到其他节点，我会认为问题出在 EBS 卷上，它没有被卸载并且它们安装到另一个正在运行 pod 副本的节点，但事实并非如此。EBS 卷存在，相同的 pv/pvc 存在，但数据丢失。

为了弄清楚可能是什么问题，我特意进行了 influxdb 设置并添加了数据，然后这样做：

效果与重新安排 influxdb pod 时的效果相同。数据丢失。

有什么具体原因为什么会发生这样的事情？

我的环境：我正在使用 EKS k8s 环境和1.15 k8s 版本的控制平面/工作人员。

我有一个 InfluxDB（第 2 版），其中每秒将一个条目写入我的存储桶，以及一个identifier（源的 uuid）和一个side值（从 1 到 6 的一些特定于域的测量值）。而不是一长串这样的逐秒日志：

我想压缩这些条目，以便我可以计算持续时间，持续多长时间side=x：

我还通过从/到范围限制时间段。这是我当前的查询：

我的方法是读取原始数据，然后对其进行迭代，检测侧面的变化（类似于current.side != last.side），然后将其作为新条目报告给我的logbook. 当然，这种方法效率很低（JavaScript）：

有没有办法使用 InfluxDB 查询语言对数据进行分组和汇总？

尝试动态创建存储桶时，我不断收到以下错误。

错误：

OkHttp 错误前的日志：

代码：

版本： implementation("com.influxdb:influxdb-client-java:1.8.0")

注意：我尝试implementation("com.influxdb:influxdb-spring:1.8.0")使用稍微不同的配置并收到相同的错误。我能够InfluxDBClient毫无问题地初始化连接到现有的bucking。