NiFi优化MySQL行计数查询流程：直接获取Avro结果值

方案1：直接让ExecuteSQL输出JSON，跳过格式转换 #

不用额外加ConvertAvroToJSON，直接改ExecuteSQL的输出配置即可：

• 先在控制器服务里创建一个JsonRecordSetWriter，启用它（默认配置就能用，无需修改参数）。
• 编辑你的ExecuteSQL处理器，找到Record Writer属性，选择刚才创建的JsonRecordSetWriter。
• 执行计数查询时给字段起别名，比如 SELECT COUNT(*) AS total_rows FROM your_table。
• 之后直接用${json.total_rows}就能读取数值，比如在RouteOnAttribute里设置路由规则：has_data: ${json.total_rows:gt(0)}，即可根据计数结果分流。

方案2：用RecordPath直接读取Avro格式的结果 #

如果不想改输出格式，NiFi支持用RecordPath表达式直接解析Avro记录，无需转JSON：

• 保持ExecuteSQL默认的Avro输出（Output Format设为Record）。
• 在需要判断的处理器（比如RouteOnAttribute）里，用${record:path('/total_rows')}获取计数数值，这里的total_rows是你查询时给的字段别名。
• 示例路由规则：no_data: ${record:path('/total_rows'):eq(0)}，直接基于Avro内容判断路由。

方案3：封装成模板减少重复操作 #

如果这个“查询计数+路由”的逻辑要在画布多处使用，把ExecuteSQL（配好输出格式）+ 路由处理器打包成模板，之后直接拖拽复用即可，不用每次重复搭建流程。

为什么你之前用${json.field_name}会返回空值？ #

ExecuteSQL默认输出的是Avro格式的Record对象，不是JSON字符串，${json.*}表达式只能解析JSON格式的内容，所以读不到值。必须要么转成JSON，要么用Record相关的表达式来读取Avro里的字段。

内容的提问来源于stack exchange，提问作者Hein du Plessis