This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit e57bc823d72e9605f4097333841a70ebf52117fb
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Oct 12 14:07:32 2022 +0200
Switch Azure Storage Blob Source from timer producer style to a pure
consumer
---
kamelets/azure-storage-blob-source.kamelet.yaml | 41 ++++++----------------
.../azure-storage-blob-source.kamelet.yaml | 41 ++++++----------------
2 files changed, 20 insertions(+), 62 deletions(-)
diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml
b/kamelets/azure-storage-blob-source.kamelet.yaml
index 01c333c5..d4ed8cd1 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -75,37 +75,16 @@ spec:
- "camel:timer"
template:
from:
- uri: "timer:azure-storage-blob-stream"
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
parameters:
- period: "{{period}}"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
steps:
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "listBlobs"
- accessKey: "{{accessKey}}"
- credentialType: "{{credentialType}}"
- - split:
- jsonpath: "$.*"
- steps:
- - set-property:
- name: azureBlobName
- simple: ${body.name}
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "getBlob"
- accessKey: "{{accessKey}}"
- - to: "kamelet:sink"
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "deleteBlob"
- accessKey: "{{accessKey}}"
+ - to: "kamelet:sink"
+ - to:
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+ parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
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 01c333c5..d4ed8cd1 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
@@ -75,37 +75,16 @@ spec:
- "camel:timer"
template:
from:
- uri: "timer:azure-storage-blob-stream"
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
parameters:
- period: "{{period}}"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
steps:
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "listBlobs"
- accessKey: "{{accessKey}}"
- credentialType: "{{credentialType}}"
- - split:
- jsonpath: "$.*"
- steps:
- - set-property:
- name: azureBlobName
- simple: ${body.name}
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "getBlob"
- accessKey: "{{accessKey}}"
- - to: "kamelet:sink"
- - set-header:
- name: CamelAzureStorageBlobBlobName
- simple: ${exchangeProperty.azureBlobName}
- - to:
- uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
- parameters:
- operation: "deleteBlob"
- accessKey: "{{accessKey}}"
+ - to: "kamelet:sink"
+ - to:
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+ parameters:
+ operation: "deleteBlob"
+ accessKey: "{{accessKey}}"
+ credentialType: "{{credentialType}}"
