You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Yi Yan <yy...@talend.com> on 2018/01/03 02:06:43 UTC

AWS_S3 consumer unable to delect object with another S3 producer

Hi,

I want to move(copy+delete) some objects from one AWS S3 bucket to another, so I created the configuration like below, but the source object was not deleted after running.

from("aws-s3:SOURCE_BUCKET_NAME?amazonS3Client=#s3_client&fileName=test1.txt&deleteAfterRead =true")
.setHeader("CamelAwsS3Key", constant("test1_copy.txt"))
.setHeader("CamelAwsS3ContentLength", constant(5))
.to("TARGET_BUCKET_NAME?amazonS3Client=#s3_client&includeBody=false);


Thanks,
Yi Yan

RE: AWS_S3 consumer unable to delect object with another S3 producer

Posted by Yi Yan <yy...@talend.com>.
Hi Willem,

Thanks for your reply, it contains the 'aws-s3:' prefix actually just missing it when I renamed the bucket name, the result is the same.

from("aws-s3:source_bucket?amazonS3Client=#AWSConnection1&fileName=test1.txt&deleteAfterRead=true") 
.setHeader("CamelAwsS3Key", constant("test1_copy.txt"))
.setHeader("CamelAwsS3ContentLength", constant(5)) 
.to("aws-s3:target_bucket?amazonS3Client=#AWSConnection1&includeBody=false");


Thanks,

Yi Yan

-----Original Message-----
From: Willem Jiang [mailto:willem.jiang@gmail.com] 
Sent: Wednesday, January 03, 2018 10:41
To: users@camel.apache.org
Subject: Re: AWS_S3 consumer unable to delect object with another S3 producer

Hi,

I don't see the aws-s3: prefix in you to endpoint. Can you double check it?


Willem Jiang

Blog: http://willemjiang.blogspot.com (English)
          http://jnn.iteye.com  (Chinese)
Twitter: willemjiang
Weibo: 姜宁willem

On Wed, Jan 3, 2018 at 10:06 AM, Yi Yan <yy...@talend.com> wrote:

> Hi,
>
> I want to move(copy+delete) some objects from one AWS S3 bucket to 
> another, so I created the configuration like below, but the source 
> object was not deleted after running.
>
> from("aws-s3:SOURCE_BUCKET_NAME?amazonS3Client=#s3_
> client&fileName=test1.txt&deleteAfterRead =true") 
> .setHeader("CamelAwsS3Key", constant("test1_copy.txt")) 
> .setHeader("CamelAwsS3ContentLength", constant(5)) 
> .to("TARGET_BUCKET_NAME?amazonS3Client=#s3_client&includeBody=false);
>
>
> Thanks,
> Yi Yan
>
>

Re: AWS_S3 consumer unable to delect object with another S3 producer

Posted by Willem Jiang <wi...@gmail.com>.
Hi,

I don't see the aws-s3: prefix in you to endpoint. Can you double check it?


Willem Jiang

Blog: http://willemjiang.blogspot.com (English)
          http://jnn.iteye.com  (Chinese)
Twitter: willemjiang
Weibo: 姜宁willem

On Wed, Jan 3, 2018 at 10:06 AM, Yi Yan <yy...@talend.com> wrote:

> Hi,
>
> I want to move(copy+delete) some objects from one AWS S3 bucket to
> another, so I created the configuration like below, but the source object
> was not deleted after running.
>
> from("aws-s3:SOURCE_BUCKET_NAME?amazonS3Client=#s3_
> client&fileName=test1.txt&deleteAfterRead =true")
> .setHeader("CamelAwsS3Key", constant("test1_copy.txt"))
> .setHeader("CamelAwsS3ContentLength", constant(5))
> .to("TARGET_BUCKET_NAME?amazonS3Client=#s3_client&includeBody=false);
>
>
> Thanks,
> Yi Yan
>
>