This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aws2-s3-moveAfterRead
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit dd238e8e37e8d8b2a8b0de18ee283c080b08b6c7
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Mon Sep 9 11:47:43 2024 +0200
AWS S3 Source Kamelets: Support moveAfterRead parameter
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
kamelets/aws-s3-source.kamelet.yaml | 21 +++++++++++++++++++++
.../resources/kamelets/aws-s3-source.kamelet.yaml | 21 +++++++++++++++++++++
2 files changed, 42 insertions(+)
diff --git a/kamelets/aws-s3-source.kamelet.yaml
b/kamelets/aws-s3-source.kamelet.yaml
index 5ba88fa5..9373eeb5 100644
--- a/kamelets/aws-s3-source.kamelet.yaml
+++ b/kamelets/aws-s3-source.kamelet.yaml
@@ -53,6 +53,23 @@ spec:
description: Specifies to delete objects after consuming them.
type: boolean
default: true
+ moveAfterRead:
+ title: Move Objects After Delete
+ description: Move objects from S3 bucket to a different bucket after
they have been retrieved.
+ type: boolean
+ default: false
+ destinationBucket:
+ title: Destination Bucket
+ description: Define the destination bucket where an object must be
moved when moveAfterRead is set to true.
+ type: string
+ destinationBucketPrefix:
+ title: Destination Bucket Prefix
+ description: Define the destination bucket prefix to use when an
object must be moved, and moveAfterRead is set to true.
+ type: string
+ destinationBucketSuffix:
+ title: Destination Bucket Suffix
+ description: Define the destination bucket suffix to use when an
object must be moved, and moveAfterRead is set to true.
+ type: string
accessKey:
title: Access Key
description: The access key obtained from AWS.
@@ -207,6 +224,10 @@ spec:
region: "{{region}}"
ignoreBody: "{{ignoreBody}}"
deleteAfterRead: "{{deleteAfterRead}}"
+ moveAfterRead: "{{moveAfterRead}}"
+ destinationBucket: "{{?destinationBucket}}"
+ destinationBucketPrefix: "{{?destinationBucketPrefix}}"
+ destinationBucketSuffix: "{{?destinationBucketSuffix}}"
prefix: "{{?prefix}}"
useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
useProfileCredentialsProvider: "{{useProfileCredentialsProvider}}"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
index 5ba88fa5..81acdb4b 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
@@ -53,6 +53,23 @@ spec:
description: Specifies to delete objects after consuming them.
type: boolean
default: true
+ moveAfterRead:
+ title: Move Objects After Delete
+ description: Move objects from S3 bucket to a different bucket after
they have been retrieved.
+ type: boolean
+ default: false
+ destinationBucket:
+ title: Destination Bucket
+ description: Define the destination bucket where an object must be
moved when moveAfterRead is set to true.
+ type: string
+ destinationBucketPrefix:
+ title: Destination Bucket Prefix
+ description: Define the destination bucket prefix to use when an
object must be moved, and moveAfterRead is set to true.
+ type: string
+ destinationBucketSuffix:
+ title: Destination Bucket Suffix
+ description: Define the destination bucket suffix to use when an
object must be moved, and moveAfterRead is set to true.
+ type: string
accessKey:
title: Access Key
description: The access key obtained from AWS.
@@ -207,6 +224,10 @@ spec:
region: "{{region}}"
ignoreBody: "{{ignoreBody}}"
deleteAfterRead: "{{deleteAfterRead}}"
+ deleteAfterRead: "{{moveAfterRead}}"
+ destinationBucket: "{{?destinationBucket}}"
+ destinationBucketPrefix: "{{?destinationBucketPrefix}}"
+ destinationBucketSuffix: "{{?destinationBucketSuffix}}"
prefix: "{{?prefix}}"
useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
useProfileCredentialsProvider: "{{useProfileCredentialsProvider}}"
