是否可以在流利的事件之前添加和附加？

Question

目前正在使用 fluentd 将第三方应用程序日志流式传输到标准输出。

fluentd 收到的日志是：

Jun 12, 2020 11:40:00 PM UTC INFO    [com.app.purge.PurgeManager run] PURGE: appAtom purge local data complete

本质上，我希望能够操纵这个日志条目成为：

[LOG_START] [APP_LOG] Jun 12, 2020 11:40:00 PM UTC INFO    [com.app.purge.PurgeManager run] PURGE: appAtom purge local data complete [LOG_END]

浏览了 fluentd 文档中的许多插件，但找不到任何可以执行此操作的插件。

流畅的配置：

<source>
  @type tail
  path "path/Molecule/logs/*.shared_http_server.deployment.log"
  pos_file "path/fluentd/access.pos"
  tag app.access
  read_from_head true
  refresh_interval 1s
  <parse>
    @type none
  </parse>
</source>

<match app.access>
  @type stdout
  <format>
    @type single_value
  </format>
</match>

如有任何帮助，我们将不胜感激。谢谢

Answer 1

您可以使用 fluentd record_transformer 插件将任何字符串附加到您的日志记录。从 fluentd 文档中引用此 link。

<filter foo.bar>
  @type record_transformer
  <record>
    message yay, ${record["message"]}
  </record>
</filter>

像{"message":"hello world!"}这样的输入被转换成{"message":"yay, hello world!"}

是否可以在流利的事件之前添加和附加？

Is it possible to prepend and append to fluentd events?

fluentd