Как переместить файлы с Amazon s3 на локальный, используя WSO2 EI Proxy? - PullRequest
Новая
       87

Как переместить файлы с Amazon s3 на локальный, используя WSO2 EI Proxy?

0 голосов
/ 20 января 2020

Мне нужно сделать PO C с WSO2 6.5 EI - Amazon S3 Connector.

Моя задача: «Необходимо получить файлы из Amazon s3 на локальный компьютер, а затем загрузить значения этих файлов в базу данных»

Просто нужно наблюдать за корзиной amazon s3 каждые 5 минут, если объекты загружаются в корзину. переместите эти файлы в локальный, а затем продолжите для дальнейшей обработки.

Пожалуйста, сообщите мне, чтобы сделать дальше. Я сталкиваюсь с ошибкой и проблемами.

Настоящим я прикрепил свой пример прокси (Примечание: с помощью Task я запускаю прокси).

Пожалуйста, посмотрите на него.

В ожидании положительный ответ. 

    <target>
        <inSequence>
            <property expression="get-property('transport', 'FILE_NAME')" name="fname" scope="default" type="STRING"/>       
            <property name="contentType" value="text/plain"/>
            <property name="filename" expression="get-property('transport', 'FILE_NAME')"/>
            <log level="custom">
                <property name="log" value="====S3 to Local===="/>
            </log>
            <amazons3.init>
                <accessKeyId>****</accessKeyId>
                <secretAccessKey>****</secretAccessKey>
                <region>****</region>
                <methodType>GET</methodType>
                <contentType>{$ctx:contentType}</contentType>
                <host>BUCKETNAME.s3.REGION.amazonaws.com</host>
                <isXAmzDate>true</isXAmzDate>
                <bucketName>BUCKETNAME</bucketName>
            </amazons3.init>
            <log level="custom">
                <property name="log" value="====After Amazon S3 Init===="/>
            </log>
            <amazons3.getObjectsInBucket>
                <bucketUrl>http://s3.REGION.amazonaws.com/BUCKETNAME</bucketUrl>                
            </amazons3.getObjectsInBucket>
            <log level="custom">
                <property name="log" value="==== After getObjectsInBucket ===="/>                  
                <property name="Notification " value="File - Objects Taken From S3 - Completed"/>
                <property name="filename " expression="get-property('filename')"/>
            </log>
            <send>
                <endpoint name="S3_Response_EP">
                    <address uri="vfs:file:///E:/FromS3"/>
                </endpoint>
            </send>
            <log level="custom">
                <property expression="get-property('filename')" name="filename "/>
                <property name="Notification" value="File - Objects Moved to Local - Completed"/>
            </log>
            <drop/>
        </inSequence>
        <outSequence/>           
        <faultSequence/>
    </target>  
</proxy>
...