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 2021/07/27 13:35:53 UTC

[camel-kamelets] 01/02: Azure Storage Blob Source: Don't use to-d but work through headers

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch azure-storage-blob-source-fix
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 0292e01a655a45c0878f4b4cee3e7f5a86620339
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Jul 27 15:33:30 2021 +0200

    Azure Storage Blob Source: Don't use to-d but work through headers
---
 azure-storage-blob-source.kamelet.yaml | 18 ++++++++++++++++--
 1 file changed, 16 insertions(+), 2 deletions(-)

diff --git a/azure-storage-blob-source.kamelet.yaml b/azure-storage-blob-source.kamelet.yaml
index 3c30be7..c8281da 100644
--- a/azure-storage-blob-source.kamelet.yaml
+++ b/azure-storage-blob-source.kamelet.yaml
@@ -65,7 +65,21 @@ spec:
           - set-property:
               name: azureBlobName
               simple: ${body.name}
-          - to-d: "azure-storage-blob:{{accountName}}/{{containerName}}?accessKey=RAW({{accessKey}})&operation=getBlob&blobName=${exchangeProperty.azureBlobName}"
+          - set-header:
+              name: CamelAzureStorageBlobBlobName
+              simple: ${exchangeProperty.azureBlobName}
+          - to:
+              uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+              parameters:
+                operation: "getBlob"
+                accessKey: "{{accessKey}}"
           - to: "kamelet:sink"
-          - to-d: "azure-storage-blob:{{accountName}}/{{containerName}}?accessKey=RAW({{accessKey}})&operation=deleteBlob&blobName=${exchangeProperty.azureBlobName}"
+          - set-header:
+              name: CamelAzureStorageBlobBlobName
+              simple: ${exchangeProperty.azureBlobName}
+          - to:
+              uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+              parameters:
+                operation: "deleteBlob"
+                accessKey: "{{accessKey}}"