NiFi中GeoEnrichIP处理器如何正确引用host_address字段完成IP地理富集

你之前的Enrich: host_address配置方式不符合GeoEnrichIP的自定义属性规则，且未明确IP字段的读取来源，导致处理器无法定位到待富集的IP字段，可按以下步骤配置：

前置配置校验 #

• 首先确认GeoLite2 Database File配置项已填写合法的本地GeoLite2城市/国家库mmdb文件路径，且NiFi进程对该文件有读取权限
• 确认ConvertRecord输出的FlowFile内容为标准JSON格式，host_address字段存储的是有效公网IP地址（内网IP无法返回公网地理信息）

步骤1：配置IP读取来源 #

找到GeoEnrichIP的核心配置项IP Source，选择值为FLOWFILE_CONTENT，指定处理器从FlowFile的JSON内容中读取IP字段。如果你的host_address存储在FlowFile属性中，选择FLOWFILE_ATTRIBUTES即可。

步骤2：添加自定义富集属性 #

添加用户自定义属性，规则如下：

• 属性名（键）：可自定义，为富集后输出的地理信息字段的前缀，比如填geo
• 属性值：如果是从JSON内容读IP，填写指向host_address字段的JSONPath表达式 $.host_address；如果是从FlowFile属性读IP，直接填写属性名host_address

举个配置示例：
你添加一条自定义属性：
键：geo
值：$.host_address
最终输出的JSON内容中会自动新增geo_city、geo_country、geo_latitude、geo_longitude等地理字段，完成IP富集。

常见异常排查 #

• 如果host_address是JSON中的嵌套字段，调整JSONPath即可，比如嵌套在info层级下的IP字段对应表达式为$.info.host_address
• 若输出字段值为空，先排查IP是否为内网保留地址，或GeoLite2库中无该IP的对应地理信息

内容的提问来源于stack exchange，提问作者jjammin92