问题标签 [kairosdb]

我正在使用kafka-kairosdb插件将 kafka 消息直接流式传输到 kairosDB。

我在文件夹中构建并成功添加了插件/lib，从日志中我看到该插件正在运行并连接到我的 kafka 主题。将消息发送到此主题后，插件不会继续进行，并且似乎保持打开状态for (MessageAndMetadata<byte[], byte[]> messageAndMetadata : m_stream)。

我没有更改配置中的任何内容，除了默认字符串解析器的主题名称以匹配我在 kafka 中的主题。

我想用 kairosDB 测试我的应用程序，但我不想使用外部 kairosDB 服务器。

是否可以为测试创建嵌入式 KairosDB（具有内存数据库，如 H2）？

我编写了以下脚本，允许我设置传感器的数量和它们的批量插入数量。每个批量插入都有一个不同的纪元时间。每个传感器插件都有一个不同的值 + 不同的标签（温度）值。

凯罗斯版本：

Scylla（后端存储）版本：

问题： 只有第一个批量插入 Kairos，其他批量被忽略，我不知道为什么。任何关于为什么或如何更正脚本的想法都值得赞赏。

剧本：

输出示例：

我的 kairos 客户端是用 Java 编写的。KairosDB 版本 1.1.3-1。

我有数据点：

t1 - 1000, v1 - 100

t2 - 2000, v2 - 200

t3 - 3000, v3 - 300

t4 - 4000, v4 - 500

我想产生一个输出，它将是这些点的插值，ts - 1500从tp - 1000. 所以输出应该是这样的（插值数据点）：

[1500,150],[2500,250],[3500,400]

可以用普通的kairos来做吗？我们是否有一个外部库

KairosDB 版本 1.1.3-1。

我有 dataPoints [time, name, key, value]。是否可以首先按nameand对它们进行分组key，然后聚合结果，然后再次对它们进行分组，然后再次key聚合？

所以基本上：

1. +的所有值和name1+key1的所有值name2key1
2. 按平均值聚合每个（周期 10 秒）
3. 按以下方式对汇总结果进行分组key1（我想在此处合并结果）
4. 按总和（同一时期，10 秒）汇总给定的结果。

我们有很多传感器，例如能量计，并且希望使用 kairosdb 存储数据。在我们使用简单的 SQL 存储之前，每个传感器都有自己的表，其中每个测量都是一行。

测量值通过 JSON 对象从传感器发布到系统：

因此，例如，对于两个设备上的两个传感器，我们的数据库中有这个：

传感器 A1234：

传感器 B5678：

现在，我们正在研究什么是存储相同信息但使用 KairosDB 的最佳解决方案。

我们的目标是回答一些“问题”，例如： - 最新的伏特、瓦特、安培 - x（开始时间戳）和 y（结束时间戳）之间的平均安培数 - 总瓦数（或子集）是多少两个日期之间的传感器

等等。

那么，选择指标名称和/或标签的最佳方法是什么？

我们是否应该使用传感器名称作为指标名称（不带标签）：

或者我们应该在所有传感器的相同指标上使用标签：

或者，我们是否完全走错了路？

查询性能有区别吗？

I want to see which queries Kairosdb receives from my application and from others. How can I enable query logging?

我有如下数据： -

我正在使用这样的python脚本将数据发送到KairosDB服务器 -

我知道这些数据将存储在三个不同的表中：-

我的查询是：-

现在我想知道如何从这三个表中获取数据，我的意思是从 Cassandra 检索数据的流程是什么。

提前致谢。

我想使用 post 方法将数据发送到 KairosDB，但我的 Json 不正确。Json 必须是这样的：

对于我添加Dictionary<string, float>到我的对象的数据点。当我序列化它时我有什么：

如果我改变我的字典.ToArray()，我有这个 Json：

我不知道如何为数据点生成预期格式的 json。

编辑： 我如何创建我的对象：

我们有一个单节点 Cassandra，有时我们会收到以下错误：

更多信息：Kairosdb 连接到 cassandra 主机时超时，例如 "cassandra-host.me" 。
我已经发现 172.31.152 是 Cassandra DNS 的 IP 地址（“cassandra-host.me”）。令我困惑的是，172.31.0.170 IP 地址是什么？

第二个 IP 不时更改，我可以看到该服务始终运行没有任何问题。

如果您需要更多信息来帮助，请告诉我。