From ec0eef7b8f6ab449ce674b5b4b0d58de185bed25 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 4 Dec 2024 11:40:47 +0100 Subject: [PATCH] Add Prefix and Filter parameters to Google Cloud Storage Source Kamelet Signed-off-by: Andrea Cosentino --- kamelets/google-storage-source.kamelet.yaml | 10 ++++++++++ .../kamelets/google-storage-source.kamelet.yaml | 10 ++++++++++ 2 files changed, 20 insertions(+) diff --git a/kamelets/google-storage-source.kamelet.yaml b/kamelets/google-storage-source.kamelet.yaml index 61c554dc7..512cb5f08 100644 --- a/kamelets/google-storage-source.kamelet.yaml +++ b/kamelets/google-storage-source.kamelet.yaml @@ -58,6 +58,14 @@ spec: description: Specifies to automatically create the Google Cloud Storage bucket. type: boolean default: false + prefix: + title: Prefix + description: The prefix which is used in the BlobListOptions to only consume objects we are interested in. + type: string + filter: + title: Filter + description: A regular expression to include only blobs with name matching it. + type: string dataTypes: out: default: binary @@ -124,5 +132,7 @@ spec: autoCreateBucket: "{{autoCreateBucket}}" serviceAccountKey: "base64:{{?serviceAccountKey}}" deleteAfterRead: "{{deleteAfterRead}}" + filter: "{{?filter}}" + prefix: "{{?prefix}}" steps: - to: kamelet:sink diff --git a/library/camel-kamelets/src/main/resources/kamelets/google-storage-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/google-storage-source.kamelet.yaml index 61c554dc7..512cb5f08 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/google-storage-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/google-storage-source.kamelet.yaml @@ -58,6 +58,14 @@ spec: description: Specifies to automatically create the Google Cloud Storage bucket. type: boolean default: false + prefix: + title: Prefix + description: The prefix which is used in the BlobListOptions to only consume objects we are interested in. + type: string + filter: + title: Filter + description: A regular expression to include only blobs with name matching it. + type: string dataTypes: out: default: binary @@ -124,5 +132,7 @@ spec: autoCreateBucket: "{{autoCreateBucket}}" serviceAccountKey: "base64:{{?serviceAccountKey}}" deleteAfterRead: "{{deleteAfterRead}}" + filter: "{{?filter}}" + prefix: "{{?prefix}}" steps: - to: kamelet:sink