问题标签 [kapacitor]

我正在尝试使用 InfluxDBClient 从用 Python 编写的 kapcitor udf 中的 InfluxDB 获取数据。如果数据大小非常小，例如 2000 条记录，我可以获取数据，但是一旦数据大小超过它就会开始失败并显示以下错误消息： _ts=2018-10-22T11:19:32.535Z lvl= error msg="encountered error" service=kapacitor task_master=main task=batch_task1 node=func2 err="keepalive timeout, last keepalive received was: 2018-10-22 11:17:52.535771714 +0000 UTC_ _ts=2018-10-22T11 :19:32.536Z lvl=error msg="failed to snapshot task" service=kapacitor task_master=main task=batch_task1 err="keepalive timeout, last keepalive received was: 2018-10-22 11:17:52.535771714 +0000 UTC_ 我尝试在 kapacitor.conf 中为 udffunctions 更改超时，但没有成功。我什至尝试将超时时间提高到超过 1 小时，但仍然出现相同的错误。

任何帮助，将不胜感激。

提前致谢

例如，var str1 = "abc.test.com:8080"

我需要如下的东西，

var splitted = split(str1,":")

var only_hostname = splitted[0] //将给出 abc.test.com*

我们如何才能在 TICKscript 中实现同样的效果？

我正在编写一个 TickScript，它作用于一系列可能有两个结果的点。

结果要么是通过，要么是“不通过”（通常是退出 NUM 的一些变体）。

我的脚本看起来像这样：

该脚本似乎确实在做它的事情，但有一个关键问题是永远不会将 Level 设置回 OK。

如果我喂大量涌入这 4 点：

我期望 1 个警告和 1 个 OK。上面列出的所有时间戳都在 25 小时内。

然而，实际发生的是我收到 2 个警告并且没有 OK。

有人可以就如何前进提供一些建议吗？

help my apacitor is not runnning, actually im running influxdb in the same server that kapacitor and telegraf, but my kapacitor don't work

This is my first time posting to stackoverflow, so I apologize in advance if I am not following certain protocols. I will fix and / or expand my question as needed.

I am trying to add 2 different influxdb sources that are hosted on 2 different servers to chronograf kapacitor but I cannot get it working.

Can you connect to 2 different influxdb instances through the UI?

How do you configure kapacitor.conf to read from 2 different influxdb instances?

Through the Chronograf UI I can get either source working correctly but not both at the same time. This seems to be expected through the UI so I must be missing something.

If I set the sources in kapacifor.conf, chronograf does not read from them. There are also no errors in kapacitor logs.

This is my kapacitor.conf influxdb settings that do not work:

I have read the documentation and also have the latest TICK stack packages.

I have also searched online and found some references that look like my configuration and are said to work, but they do not seem to work for me.

TICK stack host information:

Any help would be greatly appreciated.

我刚刚开始研究实时流数据处理框架的主题，我有一个问题，我至今找不到任何确凿的答案：

通常的嫌疑人（Apache 的 Spark、Kafka、Storm、Flink 等）是否支持以纳秒（甚至皮秒）的事件时间分辨率处理数据？

大多数人和文档都在谈论毫秒或微秒的分辨率，但是如果可能有更多的分辨率或问题，我无法找到明确的答案。我推断唯一具有此功能的框架是 influxData 的 Kapacitor 框架，因为他们的 TSDB influxDB 似乎以纳秒分辨率存储时间戳。

这里的任何人都可以提供一些对此的见解，甚至是一些知情的事实吗？提供此功能的替代解决方案/框架？

任何事情都会非常感激！

谢谢并恭祝安康，

西蒙

我的问题的背景：我正在一个环境中工作，该环境具有许多用于数据存储和处理的专有实现，并且目前正在考虑一些组织/优化。我们正在使用许多不同的诊断/测量系统以不同的采样率进行等离子体物理实验，现在高达“每秒超过千兆样本”。我们系统中的一个常见事实/假设是每个样本确实有一个以纳秒分辨率记录的事件时间。当尝试使用已建立的流（或批处理）处理框架时，我们必须保持这个时间戳分辨率。或者更进一步，因为我们最近在某些系统上突破了 1 Gsps 阈值。因此我的问题。

如何遍历 Kapacitor 滴答脚本中的字符串列表。？

是否有任何 lambda 表达式来执行此操作

我有一个刻度脚本，我必须在多个 interface_name 上使用 where 子句运行查询，它看起来像这样：

并且此查询在 influx db 上运行，但 kapacitor 将此查询更改为以下内容：

如何避免\在"刻度脚本中出现之前。

我正在关注SE Thread以获得对快速节点上的 HTTP POST 的一些响应。但无法得到kapacitor的任何回应。

环境

我正在通过PowerShell使用Windows 10。我连接到一个 InfluxDB 内部服务器，该服务器在 中提到，并且有一个 TICKscript 来通过它流式传输数据。kapacitor.conf

kapacitor.conf

守护程序运行没有任何问题。

test2.tick

1. 已经定义了任务.\kapacitor.exe define bc_1 -tick test2.tick
2. 启用它.\kapacitor.exe enable bc_1

状态没有显示：

守护进程日志为任务提供了这个

但我在 Express Node 方面一无所获。该代码与上述 SE 线程中的代码完全相同。

关于如何在 HTTP Post 上从 Kapacitor 捕获流的任何帮助？我已经有一个实时系统，它已经将信息推送到专用数据库中

我正在研究 kapacitor 警报以生成有关 influxDB 中数据的警报。发出请求后，我从流中接收到一个新值。我想将我收到的流中的当前值与之前收到的前一个值进行比较，以查看当前值是否大于前一个值。如果它大于以前的值，那么我想使用 kapacitor 和 tickscript 在 chronograf 上生成警报。

我如何在tickscript中实现这一点？非常感谢任何帮助。我是tickscript的新手。