如何在JSON内容或grok属性中查找特定字段

Question

我有一个RedPanda消息队列，NIFI从该队列中提取JSON数据。然后，使用JOLTTransform将JSON数据简化为我想要的字段。

其结果是单个JSON对象。

{
  "foo": "bar",
  "message": "<Litteral copy of 1 syslog line>"
}

我希望使用像ParseSyslog或ExtractGrok这样的处理器来解析消息字段的内容，并将成功解析的结果添加回JSON内容。

到目前为止，我已经能够使用message将消息字段提取到一个名为EvaluateJSONPath的属性中，但这就是我迷路的地方。我发现没有Grok处理器或Syslog处理器，它们可以从JSON内容中的特定字段或流文件中的属性中读取。

问题是，我可以使用/做什么来对消息字段进行Grok并将其放回流文件内容中。我对NIFI非常陌生，所以可能有明显的答案，但我找不到。

干杯。

Answer 1

我一直在用NIFI的一种方式，这不是为它设计的。我试着用斧头让NIFI做我认为是设计的事情。

我应该将事件路由到执行我想要的工作的其他服务，而不是尝试处理流文件内容。意思是，使NIFI成为一个路由服务，而不是一个“解析”服务。