You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/09/09 09:49:56 UTC
(camel-kamelets) branch aws2-s3-moveAfterRead created (now 1363f39e)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch aws2-s3-moveAfterRead
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at 1363f39e AWS S3 Source Kamelets: Support moveAfterRead parameter
This branch includes the following new commits:
new dd238e8e AWS S3 Source Kamelets: Support moveAfterRead parameter
new 1363f39e AWS S3 Source Kamelets: Support moveAfterRead parameter
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(camel-kamelets) 01/02: AWS S3 Source Kamelets: Support moveAfterRead parameter
Posted by ac...@apache.org.
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 <an...@gmail.com>
AuthorDate: Mon Sep 9 11:47:43 2024 +0200
AWS S3 Source Kamelets: Support moveAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@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}}"
(camel-kamelets) 02/02: AWS S3 Source Kamelets: Support moveAfterRead parameter
Posted by ac...@apache.org.
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 1363f39ee1239d8013875127412690f63c2e1d02
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Sep 9 11:49:31 2024 +0200
AWS S3 Source Kamelets: Support moveAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../src/main/resources/kamelets/aws-s3-source.kamelet.yaml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 81acdb4b..9373eeb5 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
@@ -224,7 +224,7 @@ spec:
region: "{{region}}"
ignoreBody: "{{ignoreBody}}"
deleteAfterRead: "{{deleteAfterRead}}"
- deleteAfterRead: "{{moveAfterRead}}"
+ moveAfterRead: "{{moveAfterRead}}"
destinationBucket: "{{?destinationBucket}}"
destinationBucketPrefix: "{{?destinationBucketPrefix}}"
destinationBucketSuffix: "{{?destinationBucketSuffix}}"