NiFi中PutMongoRecord无法读取filename属性问题咨询

看起来你遇到的核心问题是FlowFile属性无法在PutMongoRecord的集合名配置中被正确解析，导致集合名变成空字符串，触发MongoDB的无效命名空间错误。结合你的描述，我大概率能猜到问题出在哪里，给你一步步分析：

最可能的原因：集合名配置错了位置 #

很多新手容易把集合名配置在MongoDB Record Writer这个Controller Service里，但这里有个关键知识点：

Controller Service是NiFi的全局共享组件，它的运行上下文不绑定任何单个FlowFile，所以根本无法访问filename这类属于特定FlowFile的属性。

而你需要把集合名的表达式配置在PutMongoRecord处理器本身的Collection Name属性中——这个属性是针对每个FlowFile处理的，完全支持解析FlowFile属性表达式。

具体修复步骤 #

• 打开PutMongoRecord处理器的配置界面，找到Collection Name属性。
• 输入你的表达式：${filename:substringBefore('.csv')}，记得点击属性右侧的表达式语言开关（那个小图标）确保EL被启用。
• 把MongoDB Record Writer里的集合名配置清空或者留空（因为处理器的配置会覆盖Writer里的设置）。
• 重启处理器测试。

额外排查点（如果上面的方法没解决） #

• 用LogAttribute确认filename的实际值：比如输出${filename}的完整内容，确保它确实包含.csv后缀（如果文件名没有这个后缀，substringBefore('.csv')会返回整个文件名，不会空，但还是要确认）。
• 检查表达式拼写：比如是不是把substringBefore写成了substringbefore（NiFi的EL是大小写敏感的），或者符号有没有打错（比如冒号、括号）。
• 确认PutMongoRecord的其他属性没有冲突：比如Database Name是否正确配置，避免库名也出现问题。

另外你提到硬编码集合名或${hostname()}正常运行，这也验证了我的判断：${hostname()}是NiFi的系统属性，不属于FlowFile属性，所以Controller Service也能解析；但filename是FlowFile专属属性，只有处理器层面的配置才能读取到。

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