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 6a8f7715f59fea1e5c417f2f22f34fa795bb73e6 Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Dec 5 10:04:25 2022 +0100 Azure Storage Blob CDC: Add RAW to toD accessKey parameter Signed-off-by: Andrea Cosentino <[email protected]> --- kamelets/azure-storage-blob-cdc-source.kamelet.yaml | 3 ++- .../resources/kamelets/azure-storage-blob-cdc-source.kamelet.yaml | 4 +++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/kamelets/azure-storage-blob-cdc-source.kamelet.yaml b/kamelets/azure-storage-blob-cdc-source.kamelet.yaml index 5636411e..de50695e 100644 --- a/kamelets/azure-storage-blob-cdc-source.kamelet.yaml +++ b/kamelets/azure-storage-blob-cdc-source.kamelet.yaml @@ -135,11 +135,12 @@ spec: - set-property: name: azure-storage-blob-blob-name simple: '${exchangeProperty.azure-storage-blob-subject.substring(${exchangeProperty.azure-storage-blob-subject.lastIndexOf("/")}++)}' + - log: "${exchangeProperty.azure-storage-blob-event-type} - ${exchangeProperty.azure-storage-blob-subject} - ${exchangeProperty.azure-storage-blob-blob-name}" - choice: when: - simple: '${exchangeProperty.azure-storage-blob-event-type} == "Microsoft.Storage.BlobCreated" && ${exchangeProperty.azure-storage-blob-subject} contains "{{containerName}}"' steps: - toD: >- - azure-storage-blob:{{accountName}}/{{containerName}}?accessKey={{accessKey}}&operation=getBlob&blobName=${exchangeProperty.azure-storage-blob-blob-name}&credentialType={{credentialType}} + azure-storage-blob:{{accountName}}/{{containerName}}?accessKey=RAW({{accessKey}})&operation=getBlob&blobName=${exchangeProperty.azure-storage-blob-blob-name}&credentialType={{credentialType}} - to: 'kamelet:sink' diff --git a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-cdc-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-cdc-source.kamelet.yaml index 5636411e..93420e63 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-cdc-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-cdc-source.kamelet.yaml @@ -135,11 +135,13 @@ spec: - set-property: name: azure-storage-blob-blob-name simple: '${exchangeProperty.azure-storage-blob-subject.substring(${exchangeProperty.azure-storage-blob-subject.lastIndexOf("/")}++)}' + - log: "${exchangeProperty.azure-storage-blob-event-type} - ${exchangeProperty.azure-storage-blob-subject} - ${exchangeProperty.azure-storage-blob-blob-name}" - choice: when: - simple: '${exchangeProperty.azure-storage-blob-event-type} == "Microsoft.Storage.BlobCreated" && ${exchangeProperty.azure-storage-blob-subject} contains "{{containerName}}"' steps: + - log: "Cia {{accessKey}}" - toD: >- - azure-storage-blob:{{accountName}}/{{containerName}}?accessKey={{accessKey}}&operation=getBlob&blobName=${exchangeProperty.azure-storage-blob-blob-name}&credentialType={{credentialType}} + azure-storage-blob:{{accountName}}/{{containerName}}?accessKey=RAW({{accessKey}})&operation=getBlob&blobName=${exchangeProperty.azure-storage-blob-blob-name}&credentialType={{credentialType}} - to: 'kamelet:sink'
