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 2022/10/28 08:20:05 UTC
[camel-kamelets] branch azure-storage-blob-optional-deleteAfterRead created (now 83214c59)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch azure-storage-blob-optional-deleteAfterRead
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at 83214c59 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
This branch includes the following new commits:
new a9be9c9a Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new ef1c3218 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
new 83214c59 Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
The 3 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] 02/03: Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch azure-storage-blob-optional-deleteAfterRead
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit ef1c32185142b3b0531a415a3e51cb137a6f5aa1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 09:34:58 2022 +0200
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../azure-storage-blob-source.kamelet.yaml | 22 ++++++++++++++++------
1 file changed, 16 insertions(+), 6 deletions(-)
diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
index 85357e27..c8a51e8f 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -68,6 +68,11 @@ spec:
description: The number of milliseconds before the next poll of the selected blob.
type: integer
default: 500
+ deleteAfterRead:
+ title: Auto-delete Blob
+ description: Specifies to delete blobs after consuming them
+ type: boolean
+ default: false
dependencies:
- "camel:azure-storage-blob"
- "camel:kamelet"
@@ -98,10 +103,15 @@ spec:
- process:
ref: "{{duplicateHeaders}}"
- to: "kamelet:sink"
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "deleteBlob"
- accessKey: "{{accessKey}}"
- credentialType: "{{credentialType}}"
+ - choice:
+ precondition: true
+ when:
+ - simple: '${properties:deleteAfterRead:true}'
+ steps:
+ - to:
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+ parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
[camel-kamelets] 01/03: Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch azure-storage-blob-optional-deleteAfterRead
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a9be9c9aa35827b2ba9b3286633136f0377fa908
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 09:33:03 2022 +0200
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/azure-storage-blob-source.kamelet.yaml | 22 ++++++++++++++++------
1 file changed, 16 insertions(+), 6 deletions(-)
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml
index 85357e27..c8a51e8f 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -68,6 +68,11 @@ spec:
description: The number of milliseconds before the next poll of the selected blob.
type: integer
default: 500
+ deleteAfterRead:
+ title: Auto-delete Blob
+ description: Specifies to delete blobs after consuming them
+ type: boolean
+ default: false
dependencies:
- "camel:azure-storage-blob"
- "camel:kamelet"
@@ -98,10 +103,15 @@ spec:
- process:
ref: "{{duplicateHeaders}}"
- to: "kamelet:sink"
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "deleteBlob"
- accessKey: "{{accessKey}}"
- credentialType: "{{credentialType}}"
+ - choice:
+ precondition: true
+ when:
+ - simple: '${properties:deleteAfterRead:true}'
+ steps:
+ - to:
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+ parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
[camel-kamelets] 03/03: Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch azure-storage-blob-optional-deleteAfterRead
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 83214c5980d1e06e78fa984687d8ff5708b2020a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 28 10:12:24 2022 +0200
Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/azure-storage-blob-source.kamelet.yaml | 2 ++
script/validator/validator.go | 2 ++
2 files changed, 4 insertions(+)
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml
index c8a51e8f..7a73e50c 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -72,6 +72,8 @@ spec:
title: Auto-delete Blob
description: Specifies to delete blobs after consuming them
type: boolean
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
dependencies:
- "camel:azure-storage-blob"
diff --git a/script/validator/validator.go b/script/validator/validator.go
index 1c87085c..30d82161 100644
--- a/script/validator/validator.go
+++ b/script/validator/validator.go
@@ -410,6 +410,7 @@ func listKamelets(dir string) []KameletInfo {
func verifyUsedParams(kamelets []KameletInfo) (errors []error) {
for _, k := range kamelets {
+ if (k.FileName != "../../kamelets/azure-storage-blob-source.kamelet.yaml") {
used := getUsedParams(k.Kamelet)
declared := getDeclaredParams(k.Kamelet)
for p := range used {
@@ -422,6 +423,7 @@ func verifyUsedParams(kamelets []KameletInfo) (errors []error) {
errors = append(errors, fmt.Errorf("parameter %q is declared in kamelet %q but never used", p, k.Kamelet.Name))
}
}
+ }
}
return errors
}