ExtractGrok 2025.5.31.15

捆绑包

org.apache.nifi | nifi-standard-nar

描述

对照 FlowFile 的内容评估一个或多个 Grok 表达式,将结果添加为属性或用匹配内容的 JSON 符号替换 FlowFile 的内容

标签

delimit、extract、grok、log、parse、text

输入要求

REQUIRED

支持敏感的动态属性

false

属性

属性

描述

字符集

对文件进行编码的字符集

目标

控制是否将 Grok 输出值写入为新的 FlowFile 属性,在这种情况下,每个在 FlowFile 中匹配到的 Grok 标识符都会作为属性添加(并添加“grok.”前缀)或写入 FlowFile 内容中。写入 FlowFile 内容将覆盖任何现有的 FlowFile 内容。

Grok 表达式

Grok 表达式。如果在此表达式中引用了其他 Grok 表达式,则必须在 Grok 模式文件中提供这些表达式(如果已设置或存在于默认 Grok 模式中)

Grok 模式文件

自定义 Grok 模式定义。这些定义将在默认 Grok 模式之后加载。当未配置此属性时,Grok 解析器将使用默认的 Grok 模式。

保留空白的获取

如果为 true,则空白获取将包含在返回的获取映射中。

最大缓冲区大小

指定要缓冲的最大数据量(每个文件),以便应用 Grok 表达式。大于指定最大值的文件将不能完全评估。

仅限指名的获取

只存储来自 grok 的指名获取内容

限制

所需权限

解释

引用远程资源

模式可以通过 HTTP 引用资源

关系

名称

描述

matched

成功评估“Grok Expression”且 FlowFiles 因此被修改后,将 FlowFile 路由到此关系

unmatched

当提供的“Grok Expression”不匹配 FlowFiles 的内容时,将 FlowFile 路由到此关系

写入属性

名称

描述

grok.XXX

在 flowfile-attribute 模式下操作时,FlowFile 中匹配的每个 Grok 标识符都将作为属性添加(并添加“grok.”前缀)。例如,如果匹配了 Grok 标识符“timestamp”,则该值将添加到名为“grok.timestamp”的属性中

语言: 中文