Mule

Question

我正在使用 collection-splitter 来拆分我的列表。现在我应该如何将负载设置为 SFTP 出站端点。

        <sftp:inbound-endpoint connector-ref="sftp-inbound" host="${SFTP_HOST}" port="${SFTP_PORT}" 
        path="/files/" user="${SFTP_USER}" password="${SFTP_PASS}" 
        responseTimeout="10000" pollingFrequency="30000" fileAge="20000" sizeCheckWaitTime="5000" 
        archiveDir="/files/archive/" doc:name="SFTP"  >
             <file:filename-regex-filter pattern="Test(.*).zip" caseSensitive="true"/>
        </sftp:inbound-endpoint>

        <set-variable variableName="regexVal" value="${REGEX}" doc:name="Variable"/>
        <set-variable variableName="sourceFileName" value="#[flowVars.originalFilename]" doc:name="Variable"/>

        <custom-transformer name="zipTxt" class="com.mst.transform.UnzipTransformer" doc:name="Java" mimeType="image/gif">
            <spring:property name="filenamePattern" value="*.csv,*.txt" />
        </custom-transformer>

        <set-variable variableName="fileContents" value="#[payload]" />

        <collection-splitter enableCorrelation="IF_NOT_SET" />

        <logger message="#[payload]" level="INFO" doc:name="Logger"/>

        <sftp:outbound-endpoint connector-ref="sftp-inbound" 
            host="${SFTP_HOST}" port="${SFTP_PORT}" 
            path="/files/" user="${SFTP_USER}" password="${SFTP_PASS}"  
            responseTimeout="10000" doc:name="SFTP" 
            exchange-pattern="one-way"/>

 </flow>

Answer 1

如果您在收集拆分器之前的有效负载是 SFTP 出站端点（如 InputStream）可以使用的对象列表，那么在拆分器之后，您可以将记录器、sftp 包装在处理器链中。拆分器将每个对象一个一个地发送到处理器链。如果它是 InputSream，SFTP 应该能够写入它。

<collection-splitter enableCorrelation="IF_NOT_SET" />

<processor-chain doc:name="Processor Chain">
        <logger message="#[payload]" level="INFO" doc:name="Logger"/>

        <sftp:outbound-endpoint connector-ref="sftp-inbound" 
            host="${SFTP_HOST}" port="${SFTP_PORT}" 
            path="/files/" user="${SFTP_USER}" password="${SFTP_PASS}"  
            responseTimeout="10000" doc:name="SFTP" 
            exchange-pattern="one-way"/>
</processor-chain>

如果您只想在拆分器之后放置一个处理器（例如 SFTP），则不需要处理器链。

如果这不起作用，请将错误详细信息添加到问题中。

Mule - 收集拆分后发送 SFTP 出站消息

Mule - Send SFTP outbound message after Collection Split

sftp

outbound