问题标签 [telegraf-plugins]

我需要获取和存储从访问日志到 influxdb 的不同 2xx、4xx 和 5xx 请求的响应时间和计数。（用于图形和警报目的）。

我知道我可以使用 telegraf 来解析日志文件并继续向 influxdb 发送数据。并通过对数据运行查询来获取这些计数。

[ 1 , 2 ]

但是通过这种方式，我将向 influxbd 服务器发送大量数据点。

我想找到的是，如果有什么办法，我只能将处理后的数据发送到 influxdb，比如没有 req/sec，没有 2xx/4xx/5xx req/sec。

我一直在阅读各种主题和博客，但找不到任何匹配的内容。

任何帮助，将不胜感激。谢谢。

Using Telegraf plugins, there is a way to read data from InfluxDb and publish it to a Kafka topic.

But is there a way to read the data on demand and place it on a Kafka topic? Like a query based demand.

I can do a query based read through REST API (curl GET).

There are HTTP Listener plugins but these are only for POST methods. None for GET method where I can query a subset of data from InfluxDb and place them on a Kafka topic. In this case, kafka would be the output plugin.

我正在尝试使用 Telegraf 的 input.tail 插件将数据从我的 csv 文件导入到 InfluxDB。

我可以在不明确字段类型的情况下导入数据。问题是我想将数据从 csv 合并到已经存在的measurement，其中包含浮点类型。我发现我们可以通过使用csv_column_typesin tail 插件显式更改类型，但也不乏。

telegraf.conf

我也试过[processors.converter.tags]了——不缺。

错误信息是when writing to [http://localhost:8086]: received error partial write: field type conflict: input field "sentBytes" on measurement "tail" is type float, already exists as type integer dropped=5000; discarding points。

telegraf --version Telegraf 1.11.0 (git: HEAD c9d8f7b0)

有人可以澄清我做错了什么吗？

我正在使用 Telegraf，并且我有多个 input.http 插件返回相同的字段名称并希望区分它们。

我为不同的搜索条件调用 ElasticSearch，返回的 JSON 结构始终相同，因此虽然我可以在 input.http 级别（name_override 或 name_suffix）定义度量，但我想更改始终为“doc_count”的字段值”。

示例输出（无论查询参数如何，结构都相同）：

我玩过 processes.rename ，我可以让它工作（包括基于测量名称的过滤），但这仅适用于一个测量。它忽略了多个 porcesses.rename 定义。

以下定义仅尊重第一部分。

我确信有一种方法可以实现我正在尝试做的事情，但还没有偶然发现它。

我正在尝试使用 telegraf 监视系统服务状态（运行或停止）。我将所有数据推入influxdb并尝试将其可视化grafana。

我的最终目标是我需要可视化processname and processstate从 influxdb 到 grafana。我在 telegraf 中使用了 procstat 插件来实现服务监控。我的电报 conf 文件

默认情况下推送每个进程...我如何将进程名称和进程状态从 Telegraf 推送到 influxdb

我无法使用 Telegraf 输出插件连接到 Elasticsearch 实例。

我通过 Elasticsearch 服务创建了一个 Elasticsearch 设置。我在 Kibana 中为它创建了一个用户和密码（连接到一个角色）。

然后我为它设置了一个 Telegraf 输出：

但是当我尝试以此启动 Telegraf 时，它只会给出错误，

[代理] 无法连接到 [outputs.elasticsearch]，15 秒后重试，错误为“健康检查超时：没有可用的 Elasticsearch 节点”

连接失败似乎起源于 golang 的 net/http 库的深处，我现在不知道如何获得一些更有用的输出。

我尝试过的事情：

事情#1：我测试了cURL：

这工作正常。

事情 #2：我创建了一个简单的 Go 程序来从 Go 连接到 elasticsearch：

.. 它以相同的“没有可用的 Elasticsearch 节点”触发了第一次恐慌。

事情#3：我尝试在那个 Go 程序上运行 gdb 来调试它。一旦我调用 NewClient，它就会跳到汇编，所以我无法真正了解 net/http 内部发生了什么。

我以前从未使用过 Go，所以我希望避免花费数小时学习 Go、探索和调试来解决这里希望是一个简单的问题。

关于如何在此处获取更多信息或为什么失败的任何想法？我可以使用 Go 的构建或运行时标志吗？gdb-with-Go 调试提示，以便我可以进入 Go 库代码？Elasticsearch 客户端诀窍？

使用日志解析器输入插件，将自定义日志写入 influxdb。输入插件 logparser 给出错误：解析日志行时出错：

filename.log：必须有一个或多个字段。

这是运行电报版本 1.5.3 并且失败并出现上述错误。我希望电报日志会很好，并且会转储数据以流入。

我正在尝试使用 fluent-bit 将日志从日志文件发送到正在侦听端口 8094 的电报。我可以通过这样的终端向该端口发送数据

回声“some_log_data”| 数控本地主机 8094

但是当我使用 fluent-bit formward 输出插件将数据发送到同一个端口时，它在 fluent-bit 日志中给出了这个错误

流利位_1 | [2019/11/21 11:14:44] [error] [io] TCP connection failed: localhost:8094 (Connection denied)
fluent-bit_1 | [2019/11/21 11:14:44] [错误] [out_fw] 没有可用的上游连接

这是我的 docker-compose 文件：

流利的bit.conf：

电报.conf：

有人可以帮我弄清楚我做错了什么吗？

谁能帮我将 Telegraf 流式传输到云 InfluxDB 中？我使用本教程，python 脚本在我的本地机器上启动，并将通知推送到 rabbitMQ。Telegraf 通过此配置订阅了 rabbitMQ。

日志显示数据正在写入 influxdb 云

但我在云 Influxdb 中找不到数据

我正在使用电报 API 和节点（使用电报 repo）开发机器人。所有使用 Telegram 新版本（V6.1.0）的用户都存在以下 bug：

如您所见- 缺少“投票”按钮。有谁知道这个bug？我检查并分组投票确实出现了，但在 1 对 1 聊天中它丢失了。

多谢你们