logging - Fluentd 过滤异常——kubernetes 集中式日志记录

Question

我正在尝试在我的 kubernetes 集群上添加集中式日志记录。我已经使用安装了 EFK 堆栈举个例子。一切正常，但我的应用程序的日志是字符串格式的，我想在弹性搜索中将日志写为 json。

我在fluentd中找到了一个使用过滤器的解决方案，如下所示：

<filter kubernetes.**>
  @type parser
  key_name log
  hash_value_field parsed
  <parse>
    @type json
  </parse>
</filter>

我现在的问题是，并非所有 pod 都以 json 格式记录，这会在 fluentd 中生成解析异常。

如何过滤这些 json 日志并保持其他日志不变？

谢谢

标签： loggingkubernetesfluentd