问题标签 [telegraf-inputs-plugin]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
289 浏览

go - 编写 Telegraf 输入插件 - 贡献指南是最新的吗?

我最近尝试创建自己的 Telegraf 输入插件以从 Tibit OLT ( https://tibitcom.com/ ) 收集指标。很抱歉我以前没有任何 Golang 经验,也没有人问谁有经验,所以我希望 StackOverflow 社区能来拯救我!

我按照建议配置了我的 go env,并从一开始就拥有了所需的所有资源(在我的“src”目录中):

influxdata.com 上的资源之一建议您接下来应该执行 git checkout ...

这是否假设您已签署个人贡献者许可协议 ( CLA ) 并且能够创建功能分支?或者,是在 go get ... 之后与 git 存储库建立的关联(假设不是 git pull)。无论如何,我跳过了上述步骤并尝试...

但是当我尝试制作时,我得到:

从我读过的其他一些帖子中,go make 不再使用,您现在使用:

这不会引发任何错误,并且旨在使 bin 文件夹中的二进制可执行文件,但它似乎没有创建一个?

我已经按照视频教程生成了一个演示插件,但是当我运行...

我没有得到输入插件的任何输出。

很抱歉,对于这个问题的不同部分可能会有一些答案,但我有点迷茫,已经成为一个阻碍者。

先感谢您!

0 投票
1 回答
200 浏览

influxdb - Telegraf 插件 - Telegraf 仅针对一个插件向 influxdb 发送数据

我是新来的,我有一个插件有问题,

所以我使用 Telegraf 从 ipmi 传感器获取数据,它正在工作我可以通过 InfluxDB 在 Grafana 仪表板中看到,

所以直到这里一切正常,我在我的 telegraf.conf 中添加了另一个输入插件:telegraf-speedtest/speedtest.conf at master · Derek-K/telegraf-speedtest · GitHub

一旦我检查了 telegraf -test ,我可以看到第一个插件(ipmi 传感器)是好的,第二个插件(speedtest)也是好的。

但是 speedtest 测量值没有存储在我使用它检查的 influxdb 中

如您所见,这里只有 ipmi_sensor :(。Telegraf 已经重新启动,并且两个插件都在使用 -test 我不确定问题出在哪里,感谢您的帮助

谢谢你

0 投票
0 回答
68 浏览

influxdb - Telegraf 为我的时间戳添加随机 +1 到 +10 纳秒

我在 influxdb2(云)上,我遇到了一个非常奇怪的情况:

我正在使用 telegraf 的 tail 插件收集日志并将它们推送到存储桶中,我的时间戳(以 epoch 编写)被重新格式化为 ns,并且 telegraf 正在为其添加随机偏移量,这是一个示例:

我的输入日志文件包含:

telegraf 与以下 lineprotocol 行相呼应:

从上面的示例中,我的输入时间戳为 1617922080 必须由 telegraf 转换为 ns 为 1617922080000000000 但我不断得到一些随机/未知的偏移量:1617922080 007 000000。

这是我的电报配置:

这个偏移量是从哪里来的?

0 投票
0 回答
1030 浏览

apache-kafka - Kafka 消费者的问题(提供的成员在当前一代中未知)

我正在使用带有 Kafka 消费者输入插件的 Telegraf 将消息转发到 InfluxDB。尝试从 Kafka 服务器消费时,Telegraf 日志显示以下内容

通过查看 Kafka 日志,我可以看到与上述错误相关的以下内容:

我对 kafka_consumer 输入插件使用以下电报配置:

  • 卡夫卡版本:2.13-2.6.1
  • 电报版本:1.18.0

当我在网络中运行 Telegraf kafka_consumer 并通过其内部 IP 访问 Kafka 服务器时,它按预期工作。在这种情况下,我试图通过其公共 IP 访问 Kafka 服务器。知道在这种情况下问题可能出在哪里吗?

0 投票
0 回答
169 浏览

go - Telegraf 自定义插件“无效参数”

我正在为 Telegraf 创建一个自定义插件,从 Powertop 在 CSV 中生成的文件,我解析它并将其分配给一个变量。在 main.go 中一切正常,但是当我把它全部放在我的powertop.go文件中时,将它添加到all.go并使用[[inputs.powertop]]调用它,我得到一个“无效参数”错误

我求求你,请帮助我!我厌倦了这种阻塞:(

配置文件

转到文件

CSV 文件

0 投票
2 回答
338 浏览

influxdb - 从 Prometheus 服务器收集指标到电报

我有一个在 K8s 实例上运行的普罗米修斯服务器和在另一个集群上运行的电报。有没有办法使用电报从普罗米修斯服务器中提取指标?我知道 Telegraf 支持从 prometheus 客户端抓取指标,但我希望从 prometheus 服务器获取这些指标。

谢谢

0 投票
0 回答
58 浏览

ssl - 配置 Telegraf Kafka 输入 SSL

对于我的 docker 服务(基于 Telegraf)Kafka 订阅者,我拥有 AWS 为 tls_ca 发布的根 CA,并使用了 AWS ACM_PCA 签名的客户端 cert.pem 和客户端 privatekey.pem。

我得到的错误

但我确实使用客户端密码生成了我的签名证书和密钥。那么有没有办法为 TLS_config 设置客户端密码以正确加载客户端密钥并解析它。

0 投票
1 回答
445 浏览

telegraf - Telegrafprocessors.regex 基于两种模式创建一个新标签

我正在使用 Telegraf 的 [[processors.regex]] 创建替换标签。

需要从现有标签“instance”中添加一个新标签“custom_instance”。

  1. 匹配最多第一次出现的“#”
  2. 如果标签没有“#”,那么它应该简单地复制相同的值

它不会为 CmRcService 创建替换

有两种模式:这种模式 "^(. ?)#. $" 有效并创建了一个替换,而这个 "^[^#]+$" 没有,不知道为什么?

有没有其他方法可以简单地根据现有值创建替换标签?if "#" then 匹配到第一次出现 else 只需复制相同的值

0 投票
1 回答
135 浏览

telegraf - 仅按时间而不是标签聚合 Telegraf 中的数据

我使用 Telegraf 收集数据,然后将其写入 InfluxDb。我想将数据汇总到一行中。据我所知,Telegraf 有很多插件,包括聚合数据的插件。我BasicStats Aggregator Plugin用于我的目的。但它有意想不到的行为(对我来说出乎意料)。它按标签聚合行,但我只需要按时间戳聚合。我怎样才能让这个插件只通过它们的时间戳来聚合行?例如,我有以下行:

timestamp=1 tag1=foo field1=3

timestamp=1 tag1=bar field1=1

timestamp=1 tag1=baz field1=4

对于他们,我想获得以下汇总行:

timestamp=1 sum=8

先感谢您

0 投票
0 回答
101 浏览

telegraf-inputs-plugin - telegraf 输入尾部插件语法

我正在尝试电报输入尾部插件。我是第一次这样做,语法很混乱。请更正语法。日志文件是多行文本。