【发布时间】:2018-05-08 15:43:22
【问题描述】:
我正在开发一个流程,当由 HTTP 请求触发时,该流程将从 FTP 服务器下载文件。为了根据请求而不是轮询执行此操作,我使用了 Mule Requester。
我发现如果没有请求者,FTP 连接器将为每个文件在 inboundProperties 集合上设置“incomingFilename”。与 Mule Requester 一起使用时,未设置文件名属性,因此我不知道我正在处理什么文件......或者在这种情况下保存到文件系统。在下面的代码中,我使用 'counter' 变量作为文件名,以防文件名无法通过。
知道如何解决这个问题吗?下面是流程:
<ftp:connector name="FTPConfig" pollingFrequency="3000" validateConnections="true" doc:name="FTP"></ftp:connector>
<flow name="FileRequestFlow">
<http:listener config-ref="HTTP_Listener_Configuration" path="csvfilesready" allowedMethods="GET" doc:name="HTTP"></http:listener>
<mulerequester:request-collection config-ref="Mule_Requester" resource="ftp://username:pswd@127.0.0.1:21/Incoming?connector=FTPConfig" doc:name="Mule Requester"></mulerequester:request-collection>
<foreach collection="#[payload]" doc:name="For Each">
<set-variable variableName="thefilename" value="#[message.inboundProperties.originalFilename==null ? counter.toString()+'.csv' : message.inboundProperties.originalFilename] " doc:name="Variable"/>
<file:outbound-endpoint path="/IncomingComplete" outputPattern="#[flowVars.thefilename]" responseTimeout="10000" doc:name="File"></file:outbound-endpoint>
<logger message="#['File saved as: ' + payload]" level="INFO" doc:name="Logger"></logger>
</foreach>
<logger message="#[payload]" level="INFO" doc:name="Logger"></logger>
</flow>
【问题讨论】: