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/26 13:29:46 UTC

[camel-kamelets] branch fix-1120-0.9.x created (now 1b28acaa)

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

acosentino pushed a change to branch fix-1120-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git


      at 1b28acaa Switch Azure Storage Blob Source from timer producer style to a pure consumer

This branch includes the following new commits:

     new bb6f0090 Switch Azure Storage Blob Source from timer producer style to a pure consumer
     new 1a395d74 Switch Azure Storage Blob Source from timer producer style to a pure consumer
     new 1b28acaa Switch Azure Storage Blob Source from timer producer style to a pure consumer

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] 03/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch fix-1120-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 1b28acaae72fe40f547584f9c3f3cd6b023ec860
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 12 14:19:10 2022 +0200

    Switch Azure Storage Blob Source from timer producer style to a pure consumer
---
 .../main/resources/kamelets/azure-storage-blob-source.kamelet.yaml  | 6 ------
 1 file changed, 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 fabbfb9a..a8cb5d09 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
@@ -33,17 +33,11 @@ spec:
     description: |-
       Consume files from Azure Storage Blob.
     required:
-      - period
       - accountName
       - containerName
       - accessKey
     type: object
     properties:
-      period:
-        title: Period between Polls
-        description: The interval (in milliseconds) between fetches to the Azure Storage Container.
-        type: integer
-        default: 10000
       accountName:
         title: Account Name
         description: The Azure Storage Blob account name.


[camel-kamelets] 02/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch fix-1120-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 1a395d740f87ff3905f615869557059c17d2b472
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 12 14:17:30 2022 +0200

    Switch Azure Storage Blob Source from timer producer style to a pure consumer
---
 kamelets/azure-storage-blob-source.kamelet.yaml | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/kamelets/azure-storage-blob-source.kamelet.yaml b/kamelets/azure-storage-blob-source.kamelet.yaml
index fabbfb9a..a8cb5d09 100644
--- a/kamelets/azure-storage-blob-source.kamelet.yaml
+++ b/kamelets/azure-storage-blob-source.kamelet.yaml
@@ -33,17 +33,11 @@ spec:
     description: |-
       Consume files from Azure Storage Blob.
     required:
-      - period
       - accountName
       - containerName
       - accessKey
     type: object
     properties:
-      period:
-        title: Period between Polls
-        description: The interval (in milliseconds) between fetches to the Azure Storage Container.
-        type: integer
-        default: 10000
       accountName:
         title: Account Name
         description: The Azure Storage Blob account name.


[camel-kamelets] 01/03: Switch Azure Storage Blob Source from timer producer style to a pure consumer

Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch fix-1120-0.9.x
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit bb6f00902b7331788ecb5a7151844081b8c14b10
Author: Andrea Cosentino <an...@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 7e206d55..fabbfb9a 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 7e206d55..fabbfb9a 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}}"