问题标签 [flux-influxdb]

因此，我试图找到有关更复杂的 Flux 查询的任何文档，但经过几天的搜索，我仍然迷路了。我希望能够计算一周中每个小时的平均值，然后当新数据进来时，我想检查它是否偏离该小时的 x 个标准偏差。

基本上我希望有 24x7 数组字段，每个字段代表过去 1 年一周中每个小时的平均值/中值。然后我想将每个小时的最后几天值与这些平均值进行比较并报告错误。我不明白如何计算这些平均值。是否有一些关于 Flux 的隐藏的大量文档？

我真的不需要一个完整的解决方案，只是一些方向会很好。就像，在标准库或其他东西中是否有一些实用功能

编辑：经过一番阅读，看起来我需要做的就是使用 window 和 aggregateWindow 函数，但我还没有找到确切的方法

我想通过一个任务传递一个 http.post json，但我找不到关于如何转义字符串的文档，而且我的字符串中有引号

根据文档，您可以使用方括号进行成员访问。但是，当我尝试使用变量执行此操作时，会导致以下错误。

如何使用变量访问成员？

我正在尝试对 Fluxgroup操作的结果进行转换。

我需要根据各个行的值得出一个值。

来源查询：

返回具有以下形状的数据：

例如，我想要做的是添加组中所有行的值，最终得到如下所示的数据：

我已经尝试过map，但这似乎只能让我访问各个行，而不是组中的表。我的第一个想法是尝试将所有行映射到一个平面记录中，之后地图就变得微不足道了。

如何访问表本身？这是一个正确的方法吗？

我有一列#datatype string被称为names并包含每一行的以下信息：

我的问题是我怎样才能（通过逗号,）将此列拆分为具有名称（names_1和names_2）的两列，这样我会得到如下内容：

我试过strings.split()了，但它只适用于单个字符串。所以也许我需要一种方法来将此代码应用于整个列：

我需要使用 Python API 通过 Flux 查询语言获取 InfluxDB 2.0 中特定测量的最高（又名最近）时间戳。

我已使用以下查询来获取时间戳，但我不确定如何确保通过此方法提取的时间戳确实是最新的。

特别是，我使用的索引last_data[0]是任意last_data的，就像对象列表一样<influxdb_client.client.flux_table.FluxTable object at 0x00000193FA906AC8>，我不确定如何解释。时间戳似乎没有排序。

无法使用 InfluxDB [flux 作为查询语言] 更改 Grafana 中的图例名称。以前我使用 InfluxQL 作为查询语言，当时，grafana 提供了一个设置图例名称的选项。但是在切换到flux之后，这个选项似乎消失了。现在它总是将图例名称显示为_value，我需要将其更改为一些自定义文本。请在我正在使用的查询下方找到。提前感谢您的时间。

我在将数据记录到我的流入数据库时​​犯了一个错误。我没有将传感器的每次变化都作为测量点记录到表中，而是意外地强制每秒记录数据。因此，它们中的大多数基本相同，并且显然不必要地使数据库更大。

例子：

问题是，这个数据记录运行了一年，我没有注意到它，但我真的很想将清理后的数据复制到我的新实例中。

所以我想要的是某种删除所有重复值（没有改变）之间的东西。对于所示的示例，这将是

有机会这样做吗？

另一点：我很确定我必须部分做，因为数据库太大了，如果我马上做的话，几分钟后我会遇到超时。对于一张桌子，我已经有大约 25521585 个测量点，所以它相当大。

此致

I am recording period between application heartbeats into Influxdb. The "target" period is 2000ms. If the period is above 2750ms, then it is defined as a "lag event".

My end objective is to run statistics on "how long" we are running without lag events.

I switched to Flux from Influxql, so that i could use the stateDuration() method. Using the below method, i am able to collect the increasing durations. At lag events, the state_duration is then reset to -1.

At this point, I would like to be able to collect 'max(state_duration)' for each duration between lag events, and this is where i get stuck. Trying to "group by every new stateDuration sequence"/"group by increasing stateDurations"...

I was thinking that it might be possible to use "reduce()" or "map()" to inject a sequence number that i can use to group by, somehow increasing that sequence number whenever i have a -1 in the state_duration.

Below is a graph of the "state_duration" when running the flux query, i am basically trying to capture the value at the top of each peak.

Any help is appreciated, including doing this e.g. in InfluxQL or with Continuous Queries.

Data looks like below when exported to csv:

我正在尝试使用 last() 和 first() 函数创建两个具有第一个值和最后一个值的新列。但是，当我尝试映射新列时，该功能不起作用。这是下面的示例代码。这可以使用 Flux 吗？