如何在Apache NiFi中调用传入FlowFile参数的Oracle存储过程

Apache NiFi 原生提供了开箱即用的处理器组合，完全可以实现「从FlowFile取入参调用Oracle存储过程、捕获执行输出、序列化为Avro或其他格式」的需求，不需要自定义代码开发。

• 存储过程执行核心：ExecuteStoredProcedure 处理器，是NiFi官方专门为JDBC存储过程调用场景设计的组件，原生适配Oracle数据库，支持IN/OUT/INOUT三类参数绑定，支持REF CURSOR、隐式游标、普通类型输出参数的捕获。
• 结果序列化组件：基于NiFi的Record体系，搭配对应的RecordSetWriter控制器服务即可输出指定格式，要Avro格式就选AvroRecordSetWriter，也可以按需替换为JSON、CSV、Parquet等其他格式的Writer。

1. 前置控制器服务配置 #

• 先配置DBCPConnectionPool连接池服务：填入Oracle JDBC连接串、驱动类名oracle.jdbc.OracleDriver、账号密码，上传匹配你Oracle版本的JDBC驱动包，连接测试通过后启用服务。
• 配置你需要的输出格式对应的RecordSetWriter：如果输出Avro就新建AvroRecordSetWriter，可以配置为自动根据返回结果推导Avro Schema，也可以绑定提前定义好的固定Schema，配置完成后启用。

2. ExecuteStoredProcedure 核心参数配置 #

• 存储过程调用语句：按Oracle JDBC调用语法编写，参数位用?占位，例如带1个入参、1个REF CURSOR出参的存储过程，写法为：

  { call 你的存储过程名(?, ?) }
  

• 参数绑定规则：
  • 来自FlowFile的输入参数：参数方向设为IN，参数值来源选择FlowFile属性，填入对应参数所在的FlowFile属性名，参数类型匹配Oracle数据库中对应字段的类型（如VARCHAR、NUMBER、TIMESTAMP等）即可。
  • 存储过程输出参数：如果是返回结果集的REF CURSOR类型，参数方向设为OUT，参数类型选择ORACLE_CURSOR，处理器会自动读取游标内的全量结果数据。
• 结果输出配置：将处理器的Record Writer属性选择为之前配置好的AvroRecordSetWriter，执行完成后，存储过程返回的结果集会被序列化为Avro格式写入新FlowFile，路由到success关系；原始输入FlowFile会路由到original关系。

• 如果你的Oracle存储过程没有显式声明REF CURSOR出参，而是通过隐式游标返回结果，直接开启处理器的Return Anonymous Ref Cursors配置项，就能自动捕获隐式返回的结果集，不需要额外配置出参。
• 如果需要传入的参数值存放在FlowFile内容而非属性里，可以提前用ExtractText、EvaluateJsonPath等处理器把需要的字段值提取为FlowFile属性，再传入存储过程。
• 存储过程返回的非游标类OUT参数（比如执行状态码、错误提示文本），会被处理器自动写入结果FlowFile的属性中，下游流程可以直接调用这些属性值。

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