在 WSO2 EI 6.1.1 中,如何将文件夹从一个位置移动到另一个位置?

问题描述 投票:0回答:1

我开发了一个API,用来下载图片到本地路径,并使用特定的文件夹名称,工作正常。我的需求是 将带有文件(图片)的文件夹移动到SFTP位置。. 什么都没有发生,文件驻留在同一输入路径。谁能帮帮我?

下载文件夹名称。 股票001,其中有图像文件(.jpg)

Download Folder which has imageFile

代理代码:

VFS:

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
       name="SFTP_Proxy"
       startOnLoad="true"
       statistics="disable"
       trace="disable"
       transports="http,https">
   <target>
      <inSequence>
         <log level="custom">
            <property name="STATUS:" value="---------SFTP Proxy Invoked-------------------"/>
         </log>
      </inSequence>
      <outSequence/>
      <faultSequence/>
   </target>
   <parameter name="transport.PollInterval">15</parameter>
   <parameter name="transport.vfs.FileURI">file:///D:/Test/CarSalesStockImages/Input/</parameter>
   <parameter name="transport.vfs.ContentType">text/plain</parameter>
   <parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
   <parameter name="transport.vfs.MoveAfterFailure">file:///D:/Test/CarSalesStockImages/Failed/</parameter>
   <parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
   <parameter name="transport.vfs.FileNamePattern">.*.*</parameter>
   <parameter name="transport.vfs.MoveAfterProcess">vfs:sftp://test-dev:[email protected]/wso2/QRSagProcess/VB/CarSalesStockImages</parameter>
   <description/>
</proxy>

FileConnetor:

<?xml version="1.0" encoding="UTF-8"?>
<proxy xmlns="http://ws.apache.org/ns/synapse"
       name="SFTP_Proxy"
       startOnLoad="true"
       statistics="disable"
       trace="disable"
       transports="http,https">
   <target>
      <inSequence>
         <log level="custom">
            <property name="STATUS:" value="---------SFTP Proxy Invoked-------------------"/>
         </log>
         <fileconnector.copy>
            <source>file:///D:/Test/CarSalesStockImages/Input/</source>
            <destination>sftp://test-dev:pwd@ipaddress/wso2/QRSagProcess/VB/CarSalesStockImages/</destination>
         </fileconnector.copy>
         <log level="custom">
            <property name="STATUS:" value="---------File Copied-------------------"/>
         </log>
         <fileconnector.delete>
            <source>file:///D:/Test/CarSalesStockImages/Input/</source>
            <setUserDirIsRoot>true</setUserDirIsRoot>
         </fileconnector.delete>
         <log level="custom">
            <property name="STATUS:"
                      value="---------File Deleted from Source-------------------"/>
         </log>
         <fileconnector.create>
            <source>file:///D:/Test/CarSalesStockImages/Input/</source>
         </fileconnector.create>
      </inSequence>
      <outSequence/>
      <faultSequence>
         <log level="custom">
            <property name="STATUS:"
                      value="------------faultSequence Invoked----------------"/>
         </log>
         <log level="full"/>
      </faultSequence>
   </target>
   <description/>
</proxy>

错误。

[2020-05-29 10:59:23,145] [] ERROR - VFSTransportListener Error resolving directory to move after processing : sftp://qrs-dev":***@"3.109.0.212/wso2/QRSagProcess/VB/CarSalesStockI
ages/
org.apache.commons.vfs2.FileSystemException: Could not connect to SFTP server at "sftp://test-dev:***@3.109.0.212/".
        at org.apache.commons.vfs2.provider.sftp.SftpFileProvider.doCreateFileSystem(SftpFileProvider.java:108)
        at org.apache.commons.vfs2.provider.AbstractOriginatingFileProvider.getFileSystem(AbstractOriginatingFileProvider.java:155)
        at org.apache.commons.vfs2.provider.AbstractOriginatingFileProvider.findFile(AbstractOriginatingFileProvider.java:119)
        at org.apache.commons.vfs2.provider.AbstractOriginatingFileProvider.findFile(AbstractOriginatingFileProvider.java:88)
        at org.apache.commons.vfs2.impl.DefaultFileSystemManager.resolveFile(DefaultFileSystemManager.java:747)
        at org.apache.commons.vfs2.impl.DefaultFileSystemManager.resolveFile(DefaultFileSystemManager.java:626)
        at org.apache.synapse.transport.vfs.VFSTransportListener.moveOrDeleteAfterProcessing(VFSTransportListener.java:662)
        at org.apache.synapse.transport.vfs.VFSTransportListener.scanFileOrDirectory(VFSTransportListener.java:499)
        at org.apache.synapse.transport.vfs.VFSTransportListener.poll(VFSTransportListener.java:188)
        at org.apache.synapse.transport.vfs.VFSTransportListener.poll(VFSTransportListener.java:134)
        at org.apache.axis2.transport.base.AbstractPollingTransportListener$1$1.run(AbstractPollingTransportListener.java:67)
        at org.apache.axis2.transport.base.threads.NativeWorkerPool$1.run(NativeWorkerPool.java:172)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.commons.vfs2.FileSystemException: Could not connect to SFTP server at "3.105.0.247".
        at org.apache.commons.vfs2.provider.sftp.SftpClientFactory.createConnection(SftpClientFactory.java:268)
        at org.apache.commons.vfs2.provider.sftp.SftpFileProvider.doCreateFileSystem(SftpFileProvider.java:97)
        ... 14 more
Caused by: com.jcraft.jsch.JSchException: Auth fail
        at com.jcraft.jsch.Session.connect(Session.java:512)
        at com.jcraft.jsch.Session.connect(Session.java:183)
        at org.apache.commons.vfs2.provider.sftp.SftpClientFactory.createConnection(SftpClientFactory.java:264)
        ... 15 more
[2020-05-29 10:59:23,150] [] ERROR - VFSTransportListener File object 'file:///D:/Test/CarSalesStockImages/Input/Test.txt'cloud not be moved, will remain in "locked" state
image file sftp wso2ei vfs
1个回答
1
投票

你能够验证目标的语法吗?我遇到的一个例子。http:/mrmalakasilva.blogspot.com201607automating-file-processing-with-wso2.html。谢谢你

© www.soinside.com 2019 - 2024. All rights reserved.