0

0

Apache NiFi如何构建一个拖放式的XML文件处理流程

幻夢星雲

幻夢星雲

发布时间:2026-01-24 08:43:02

|

801人浏览过

|

来源于php中文网

原创

需利用处理器、连接、处理器组及拖放式画布构建无代码xml处理流程:一、用getfile读取xml;二、用evaluatexpath解析字段;三、用convertrecord转json;四、用routeonattribute按状态路由;五、用putfile或putdatabaserecord输出。

apache nifi如何构建一个拖放式的xml文件处理流程

如果您希望在Apache NiFi中构建一个无需编写代码、通过图形界面完成的XML文件处理流程,则需利用其核心组件——处理器(Processor)、连接(Connection)、处理器组(Process Group)及拖放式画布。以下是实现该目标的具体步骤:

一、配置XML输入源处理器

该步骤用于从指定位置读取原始XML文件,为后续解析与转换提供数据输入。NiFi支持多种输入方式,可根据实际部署环境选择最适配的一种。

1、在NiFi画布空白处右键,选择“Add Processor”,搜索并添加“GetFile”处理器。

2、双击“GetFile”进入配置界面,在“Properties”选项卡中设置“Input Directory”为存放XML文件的本地路径,例如/opt/nifi/input/xml

3、将“File Filter”设为正则表达式.*\.xml,确保仅捕获XML扩展名文件。

4、勾选“Keep Source File”为false,使文件被成功读取后自动移出输入目录。

二、解析XML内容为属性或流内容

原始XML需被结构化识别,以便后续按字段路由或转换。NiFi提供多个专用XML解析处理器,适用于不同解析粒度需求。

1、添加“EvaluateXPath”处理器,并将其上游连接至“GetFile”的success关系。

2、在“Properties”中设置“Destination”为“flowfile-content”,表示将XPath查询结果写入流内容主体。

3、添加一个自定义XPath属性,例如命名为“order_id”,值设为/order/id/text(),用于提取根节点下id文本值。

4、保存配置后,该处理器会将匹配的XML片段或提取值注入FlowFile属性或内容,供下游使用。

三、使用ConvertRecord处理器进行XML到JSON转换

当需要将XML结构标准化为通用中间格式(如JSON)时,ConvertRecord结合Schema Registry可实现无损类型映射与格式切换。

1、添加“ConvertRecord”处理器,并连接至“EvaluateXPath”的success关系。

ColorMagic
ColorMagic

AI调色板生成工具

下载

2、在“Controller Services”中启用“XMLReader”和“JsonRecordSetWriter”两个服务。

3、为“XMLReader”配置“Schema Access Strategy”为“Infer Schema”,并设置“Treat Initial As Array”为true(若XML含多个同级根元素)。

4、为“JsonRecordSetWriter”设置“Schema Write Strategy”为“embedded”,确保输出JSON携带内联schema信息。

四、基于XML内容执行条件路由

根据XML中特定字段值将数据分流至不同处理分支,例如按订单状态区分正常处理与异常告警路径。

1、添加“RouteOnAttribute”处理器,连接至“ConvertRecord”的success关系。

2、在“Properties”中新增一个路由规则,名称设为“is_shipped”,值设为${xml.status:equals('shipped')}

3、再新增一个规则“is_pending”,值设为${xml.status:equals('pending')}

4、未匹配任何规则的FlowFile将自动进入“unmatched”关系,可用于兜底日志记录或重试队列。

五、将处理结果写入目标系统

完成解析、转换与路由后,需将最终输出持久化至文件系统、数据库或消息队列等目标端点。

1、添加“PutFile”处理器,连接至“RouteOnAttribute”的is_shipped关系。

2、配置“Directory”属性为目标路径,例如/opt/nifi/output/shipped

3、添加“PutDatabaseRecord”处理器,连接至is_pending关系,并配置JDBC Connection Pool控制器服务。

4、在“PutDatabaseRecord”中设置“Statement Type”为“INSERT”,并指定目标表名为pending_orders,确保XML字段已映射至对应列名。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

455

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

546

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

334

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

82

2025.09.10

js正则表达式
js正则表达式

php中文网为大家提供各种js正则表达式语法大全以及各种js正则表达式使用的方法,还有更多js正则表达式的相关文章、相关下载、相关课程,供大家免费下载体验。

530

2023.06.20

正则表达式不包含
正则表达式不包含

正则表达式,又称规则表达式,,是一种文本模式,包括普通字符和特殊字符,是计算机科学的一个概念。正则表达式使用单个字符串来描述、匹配一系列匹配某个句法规则的字符串,通常被用来检索、替换那些符合某个模式的文本。php中文网给大家带来了有关正则表达式的相关教程以及文章,希望对大家能有所帮助。

258

2023.07.05

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

766

2023.07.05

java正则表达式匹配字符串
java正则表达式匹配字符串

在Java中,我们可以使用正则表达式来匹配字符串。本专题为大家带来java正则表达式匹配字符串的相关内容,帮助大家解决问题。

219

2023.08.11

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
WEB前端教程【HTML5+CSS3+JS】
WEB前端教程【HTML5+CSS3+JS】

共101课时 | 10.1万人学习

JS进阶与BootStrap学习
JS进阶与BootStrap学习

共39课时 | 3.3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号