在 Mule Quartz Invoked Mule Flow 中调用 SFTP 流入答案

【问题标题】：Invoke SFTP Inflow in a Mule Quartz Invoked Mule Flow在 Mule Quartz Invoked Mule Flow 中调用 SFTP 流入
【发布时间】：2016-06-23 16:01:37
【问题描述】：

这是否可以让 Mule 在流程中间执行 SFTP 调用。我需要在一天中的特定时间读取文件。我注意到有 Quartz Polling Job 的示例，但注意到只能读取 1 个文件的限制。我正在寻找一个 SFTP 活动来按照某种模式读取文件。任何方向都会有所帮助。

Nottinging Mule 只允许入站或出站端点。

谢谢

【问题讨论】：

中途添加 SFTP 端点会引发错误。表示 SFTP 正在等待输入。虽然我希望 SFTP 创建连接并根据消息输入生成流行为。 mep=REQUEST_RESPONSE，properties={}，transactionConfig=Transaction{factory=null，action=INDIFFERENT，timeout=0}，deleteUnacceptedMessages=false，initialState=started，responseTimeout=10000，endpointEncoding=UTF-8，disableTransportTransformer=false}。消息负载的类型：NullPayload
这是一个限制。添加 SFTP，SFTP 中途需要有效负载。我在事件生成器作业中添加了一个字符串。现在有效载荷正在目标上生成为文件。 dummy )
在两者之间添加任何文件端点都将作为出站端点，因此它需要有效负载来写入文件。
我正在探索 MuleRequestor。已将其导入 Anypoint 工作室。然而，仍然有一个学习曲线。 1 例如文件没有从 SFTP 中删除。如何在没有请求者的情况下实现这一点。我再次需要使用调度程序调用 SFTP。在特定时间点从某个位置读取文件。任何帮助都会有所帮助。
嗨阿努帕姆。添加 SFTP 中间流会生成以下错误 Root Exception stack trace: java.lang.IllegalArgumentException: Unexpected message type: java.io.InputStream, byte[], or String expected.得到了 org.mule.transport.NullPayload。表示 Mule 期待输入。虽然我只是希望它执行提取而不是提交。

标签： mule

【解决方案1】：

您可以使用 Mule 请求器模块在流程之间获取资源。详情可见Mule Requester Module

请参阅以下代码以安排流程以从 SFTP 位置检索文件

    <flow name="testmappingFlow2">
        <poll doc:name="Poll">
            <schedulers:cron-scheduler expression="0 0 0 * * ?"/>
            <logger message="Sheduled job invoked" level="INFO" doc:name="Logger"/>
        </poll>
        <!-- Your flow logic goes her  -->
        <mulerequester:request-collection config-ref="Mule_Requester" resource="{sftp.resource}" count="10" doc:name="Mule Requester"/>
        <!-- Your flow logic for processing files. above code will return 10 files at time.   -->
    </flow>

希望这会有所帮助。

【讨论】：

谢谢。试图执行相同的操作。如何处理请求者找不到文件的情况。我注意到 null 有效负载类型的对象现在正在目标上加载。
添加选择表达式有效。 #[!(payload instanceof org.mule.transport.NullPayload)]

【解决方案2】：

使用 Mule Requestor 已经奏效。谢谢阿努帕姆。

【讨论】：