如何在NiFi的RouteOnContent处理器中检测空JSON字符串？

一、搞定空JSON对象{}的路由 #

RouteOnContent默认是检查属性，但空JSON没属性可查，这时候直接用NiFi的表达式语言（EL）判断内容本身就行：

1. 打开RouteOnContent的配置，切换到「Routing Strategy」选「Custom Condition」。
2. 写这个表达式：

   ${file:contentAsString() == '{}'}
   

   它会把流文件内容转成字符串，直接和空JSON的字符串对比，匹配的就路由到你指定的分支（比如叫「EmptyData」）。
   如果担心内容有多余空格（比如{ }），用JSONPath更靠谱：

   ${jsonPath($, '$') == {}}
   

   这个是解析JSON结构后判断是否为空对象，不受空格影响。

二、不用转JSON，直接用Avro路由 #

完全没必要转格式，直接操作Avro数据效率更高，分享两种实用方法：

方法1：RouteOnAttribute + Avro EL函数

NiFi自带Avro操作的EL函数，直接判断记录是否为空：

1. 加个RouteOnAttribute处理器。
2. 新增自定义属性，比如isEmptyAvro，值填：

   ${avro:isEmpty(record)}
   

   这个函数会检测Avro记录是否为空（对应你SQL返回null的场景）。
3. 配置路由规则，当isEmptyAvro为true时，流文件就会走到你想要的分支。

方法2：QueryRecord处理器（更灵活）

如果你的Avro是结构化数据，用SQL风格的查询来判断：

1. 配置QueryRecord的Avro读取器，关联你的Avro schema。
2. 加一条查询语句，比如：

   SELECT * FROM flowfile WHERE record IS NULL
   

   如果是空记录集合，就用：

   SELECT * FROM flowfile WHERE COUNT(*) = 0
   

3. 给这个查询配置对应的输出关系，匹配的流文件就会自动路由过去。

额外小技巧 #

如果你的空Avro是“没有任何字段的空记录”，可以用这个表达式判断字段数量：

${size(avro:getFieldNames(record)) == 0}

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