如何查找JSON内容中的特定字段或查找Flowfile属性

hgc7kmma  于 2022-11-26  发布在  其他
关注(0)|答案(1)|浏览(105)

我有一个RedPanda消息队列,NIFI从其中提取JSON数据,然后使用JOLTTransform将JSON数据减少到只包含我想要的字段。
这样做的结果是单个JSON对象。

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

我希望使用ParseSyslog或ExtractGrok之类的处理器来解析消息字段的内容,并将成功解析的结果添加回JSON内容中。
到目前为止,我已经能够使用EvaluateJSONPath将消息字段提取到一个名为message的属性中,但这正是我迷失的地方。我没有找到可以读取JSON内容中的特定字段或流文件中的属性的Grok处理器或Syslog处理器。
问题是,我可以使用/做什么来Grok消息字段并将其放回流文件内容中。我对NIFI很陌生,所以可能有明显的答案,但我找不到。
干杯干杯干杯

9avjhtql

9avjhtql1#

我一直在以一种方式使用NIFI,它不是为它而设计的。我试图用斧头让NIFI做我相信它是为它而设计的。
我不应该尝试处理流文件的内容,而应该将事件路由到其他服务,这些服务完成我想要的工作。

相关问题