WSO2文件未处理直接从SFTP等目录移至Out目录问题求助

问题描述 #

我们需处理约200个文件，流程为从SFTP的in目录获取文件，处理完成后移至out目录。但目前WSO2直接将文件移至out目录，未做任何处理；即便设置逐个处理、添加文件处理间隔，问题仍存在。生产环境在Kubernetes部署2个POD（也曾尝试单POD），且该问题在SMB及本地目录场景下同样出现。

补充代理配置参数 #

<parameter name="transport.vfs.Streaming">true</parameter>
<parameter name="transport.PollInterval">10</parameter>      
<parameter name="transport.vfs.FileProcessInterval">5000</parameter>
<parameter name="transport.vfs.FileURI">file://D:/integration_name/in</parameter>
<parameter name="transport.vfs.ContentType">application/xml</parameter>
<parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
<parameter name="transport.vfs.MoveAfterFailure">file://D:/integration_name/error</parameter>
<parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
<parameter name="transport.vfs.FileNamePattern">.*.xml</parameter>
<parameter name="transport.vfs.MoveAfterProcess">file://D:/integration_name/out</parameter>

可能的原因分析 #

• 代理未配置实际处理逻辑：如果代理服务仅配置了VFS传输参数，没有添加任何业务处理中介（如XSLT转换、数据校验、后端服务调用等），WSO2会默认直接完成文件移动操作，因为没有需要执行的处理步骤。
• Streaming模式导致处理逻辑未触发：transport.vfs.Streaming设为true时，文件以流形式传输，若后续处理逻辑未正确读取流数据，框架会判定处理已完成，直接触发移动。建议尝试将该参数改为false验证。
• 文件并发处理配置错误：transport.vfs.FileProcessInterval是同一文件的重复处理间隔，而非多文件间的处理间隔。要实现逐个处理，需添加transport.vfs.MaxConcurrentFiles参数并设为1，限制同时处理的文件数量。
• 文件锁机制未启用：未启用transport.vfs.Locking时，可能出现文件被误判为已处理的情况，尤其是在多POD或高并发场景下。启用该参数可确保文件在处理完成前不会被重复操作。
• 处理异常被静默忽略：若处理逻辑抛出异常但未配置对应的错误处理序列，WSO2可能不会触发ActionAfterFailure，而是继续执行ActionAfterProcess的移动操作。需检查日志确认是否有异常，同时完善错误处理配置。

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