wso2 - WSO2 VFS 并行处理
问题描述
我正在使用 WSO2 ESB 来处理文件:带有轮询的入站端点,检测文件并将其传递给序列。该序列读取文件并处理记录(写入数据库)。
我的问题是关于一次处理多个文件。现在我有这个配置:
<?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint name="AssuresContratsGtIEP" onError="TechnicalExceptionSEQ" protocol="file" sequence="AssuresContratsGtSEQ" suspend="false" xmlns="http://ws.apache.org/ns/synapse">
<parameters>
<parameter name="interval">5000</parameter>
<parameter name="sequential">true</parameter>
<parameter name="coordination">true</parameter>
<parameter name="transport.vfs.FileProcessCount">2</parameter>
<parameter name="transport.vfs.ContentType">application/binary;charset=UTF-8</parameter>
<parameter name="transport.vfs.LockReleaseSameNode">false</parameter>
<parameter name="transport.vfs.AutoLockRelease">false</parameter>
<parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
<parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
<parameter name="transport.vfs.FileURI">/home/istya/Flux/REF_PERS/Input/</parameter>
<parameter name="transport.vfs.MoveAfterFailure">/home/istya/Flux/REF_PERS/Failure/</parameter>
<parameter name="transport.vfs.DistributedLock">false</parameter>
<parameter name="transport.vfs.FileNamePattern">.*ASSURES_CONTRATS_GT.*.csv</parameter>
<parameter name="transport.vfs.MoveAfterProcess">/home/istya/Flux/REF_PERS/Process/</parameter>
<parameter name="transport.vfs.Locking">disable</parameter>
<parameter name="transport.vfs.FileSortAttribute">none</parameter>
<parameter name="transport.vfs.FileSortAscending">true</parameter>
<parameter name="transport.vfs.CreateFolder">true</parameter>
<parameter name="transport.vfs.Streaming">true</parameter>
<parameter name="transport.vfs.Build">false</parameter>
</parameters>
</inboundEndpoint>
当我将顺序参数更改为“false”时,程序崩溃:序列上的第一个调解器说该文件不存在(尽管该文件仍在轮询文件夹中......)。
有谁知道如何在 WSO2 ESB 中处理具有相同入站和序列的多个文件?有可能还是我们需要安装一个 ESB 集群?
谢谢你的支持 !朱利安
解决方案
推荐阅读
- javascript - 使用 NodeJS 中的类将联系人从 server.js 文件存储到 json 文件中
- python - 如何在熊猫中选择几个带有间隔的连续行?
- python - 使用 pyzmq 广播到子网地址
- python-3.x - 异步队列多生产者(同步)单消费者
- java - 序言中不允许内容,我找不到我的 XSD 文件
- laravel - laravel 如何从会话中获取用户 ID?
- java - Jasypt 和 .war 部署问题:缺少 jasypt.encryptor.password
- python - python gspread,不同的用户权限
- sql - 时间和出勤率
- multithreading - 当客户端是多线程的时,客户端对 HTTP 429 的正确反应是什么?