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/12 12:20:04 UTC

[camel-kamelets] branch azure-storage-blob-source-pure-consumer created (now f9779257)

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

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


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

This branch includes the following new commits:

     new 05347841 Switch Azure Storage Blob Source from timer producer style to a pure consumer
     new 01f59659 Switch Azure Storage Blob Source from timer producer style to a pure consumer
     new f9779257 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 azure-storage-blob-source-pure-consumer
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit f977925712aa6209b1dfbabfb0c2737e99f15d80
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 d4ed8cd1..14eee2fb 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 azure-storage-blob-source-pure-consumer
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 01f59659a19f0b659571f610bff98c6266f1ad30
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 d4ed8cd1..14eee2fb 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 azure-storage-blob-source-pure-consumer
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 053478418a5f647665e4dbbd2f2658a2cd1651bf
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 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}}"