WSO2 VFS параллельная обработка - PullRequest
Новая
       65

WSO2 VFS параллельная обработка

0 голосов
/ 16 января 2019

Я использую 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?

Спасибо за вашу поддержку! Julien

...