问题标签 [influxql]

如何在 Influx 中获取当前数据库名称？

例如，我们SELECT DATABASE();在 MySQL 中使用来获取 db。我们在 Influx 中有类似的功能吗？

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

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

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

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

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

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

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

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

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

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

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

有很多关于问题根源的问题没有答案，所以我想更深入地说明我的问题，希望能得到一些关于如何实现它的想法。

警告： InfluxDB 新手在这里，所以请多多包涵。

所以，我的根本问题是你不能在 InfluxQL 中按字段分组，因为字段没有被索引。但是，只要我明白我必须写下一些字段才能在 InfluxDB 中获得一行，它就不能只包含标签。

这个想法是通过解析日志条目并生成可以稍后由 Chronograph 绘制的测量值来从 Postfix 日志中收集失败的登录尝试。

原始日志条目是这样的：

此日志条目生成以下测量值（在 InfluxDB 线路协议中）：

您可以看到 Telegraf 将客户端的 IP 转换为字段。只是因为我认为我在这里需要一些领域，而 IP 是这里最好的申请人。

只要我了解文档，Telegraf 的输入解析器不能一次制作标签和字段，我必须决定哪个去哪个地方。

我想在 Chronograph 中创建多个图表的目标，基于 1）在选定的时间间隔内生成了多少失败的日志条目和 2）制作图表 - 和警报 - 如果某个 IP 达到关于失败登录的限制以触发警报消息和也采取行动。它有点类似于 Fail2Ban，但我也很想获得图表，因为有时失败的登录操作是有效的。

我只是不知道如何查询 2) 并对 1) 有一些基本的想法。如果有人可以帮助我提供有关如何编写这些查询或如何更改我的架构以实现目标的指示，我将非常感激。

有人可以指出我在下面的命令中做错了什么，并给出了如下所示的错误吗？

命令：

错误：

我不小心在一个系列中插入了一个带有一些单引号的标签：

我无法摆脱它们。我试过了

但该系列仍然存在。

如何删除它？

我在 influxDb 中使用两个键进行了测量：operation和count. 密钥可以存储两个不同的operation值：“添加”和“删除”。

当 operation='add' 时，我想将 operation='delete' 时的 sum(count) 值减去 sum(count) 值。

mysql 支持以下查询，但在 influxql 中会抛出错误：

select (select sum(count) from measurement where operation='add') - (select sum(count) from measurement where operation='delete');

如何使用单个 influxql 查询来完成？我不认为 influxql 在这种情况下允许两个不同的 where 子句。

我们有一个场景，我们想要频繁更改（单个）测量值的标签。我们的目标是创建一个存储预后值的数据库。但它绝不应该丢失数据并跟踪对已写入数据的更改，例如更改或覆盖。

我们目前的计划是有一个额外的字段“write_ts”，它指示测量值在哪个时间点被插入或更改，以及一个标签“版本”，每次更改都会更新。此外，版本“0”应始终包含最新值。

所以让我们假设我有这个示例值的更新预测值。

所以，我这样做：

现在我的问题：

如果我出于任何原因在 SELECT、INSERT、DROP 之间失去了连接：

我会得到双记录。

（或者如果我执行 SELECT、DROP、INSERT：我会丢失数据）

有什么方法可以防止这种情况吗？

我正在尝试使用 cli 中的 -execute 在 influxDB 上运行命令

查询没有运行，因为我无法为时间条件转义单引号（'）。有人可以帮忙语法吗。

是否可以将在 influxDb 查询中重新调整的时间戳传递给另一个查询。

输出

是否可以将时间从结果传递到另一个查询？

我在 kafka_consumer 中有以下数据作为输入：

时间模式

2020-01-22T10:50:04.623699901Z ABC

2020-01-22T10:50:22.344965434Z ABC

2020-01-22T10:50:42.148796899Z ABC

2020-01-22T10:51:01.840920723Z PQR

2020-01-22T10:51:22.516903602Z PQR

2020-01-22T11:13:34.453262122Z PQR

2020-01-22T11:13:34.453309721Z ABC

我期望查询提供以下输出：

start_time end_time 模式

2020-01-22T10:50:04.623699901Z 2020-01-22T10:50:42.148796899Z ABC

2020-01-22T10:51:01.840920723Z 2020-01-22T11:13:34.453262122Z PQR

2020-01-22T11:13:34.453309721Z 2020-01-22T11:13:34.453309721Z ABC

我想使用 InfluxQL 编写一个选择查询，它可以给我上述输出。能否请你帮忙？