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/04/14 12:49:29 UTC

[camel-kamelets] branch azure-storage-queue-sink created (now f1421ed)

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

acosentino pushed a change to branch azure-storage-queue-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git.


      at f1421ed  Added Azure Storage Queue Sink Kamelet

This branch includes the following new commits:

     new fe7ea5f  Added Azure Storage Queue Sink Kamelet
     new 7765411  Added Azure Storage Queue Sink Kamelet
     new decb92b  Added Azure Storage Queue Sink Kamelet
     new f1421ed  Added Azure Storage Queue Sink Kamelet

The 4 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] 04/04: Added Azure Storage Queue Sink Kamelet

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-queue-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit f1421ed099a30db670d4927dcc1f598e73d09ec1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 14 14:49:10 2021 +0200

    Added Azure Storage Queue Sink Kamelet
---
 .../images/kamelets/azure-storage-queue-sink.svg   |  1 +
 .../ROOT/pages/azure-storage-queue-sink.adoc       | 70 ++++++++++++++++++++++
 2 files changed, 71 insertions(+)

diff --git a/docs/modules/ROOT/assets/images/kamelets/azure-storage-queue-sink.svg b/docs/modules/ROOT/assets/images/kamelets/azure-storage-queue-sink.svg
new file mode 100644
index 0000000..3d7400f
--- /dev/null
+++ b/docs/modules/ROOT/assets/images/kamelets/azure-storage-queue-sink.svg
@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" viewBox="0 0 91 81" fill="#fff" fill-rule="evenodd" stroke="#000" stroke-linecap="round" stroke-linejoin="round"><use xlink:href="#A" x=".5" y=".5"/><symbol id="A" overflow="visible"><path d="M70.053 34.634H50.58l9.736 7.805zm-39.42 10.488c-.238 0-.475 0-.713-.244l-9.024-7.317v11.951h20.66V37.317l-9.736 7.561c-.475.244-.95.244-1.187.244zm29.683 0c-.238 0-.713 0-.713-.244l-9.261-7.317v11.951h20.66V37.317l-9 [...]
\ No newline at end of file
diff --git a/docs/modules/ROOT/pages/azure-storage-queue-sink.adoc b/docs/modules/ROOT/pages/azure-storage-queue-sink.adoc
new file mode 100644
index 0000000..1bca7e6
--- /dev/null
+++ b/docs/modules/ROOT/pages/azure-storage-queue-sink.adoc
@@ -0,0 +1,70 @@
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT
+= image:kamelets/azure-storage-queue-sink.svg[] Azure Storage Queue Sink
+
+*Provided by: "Apache Software Foundation"*
+
+Send Messages to Azure Storage queues.
+
+The Kamelet is able to understand the following headers to be set:
+
+- `expiration` / `ce-expiration`: as the time to live of the message in the queue.
+
+If the header won't be set the default of 7 days will be used.
+
+== Configuration Options
+
+The following table summarizes the configuration options available for the `azure-storage-queue-sink` Kamelet:
+[width="100%",cols="2,^2,3,^2,^2,^3",options="header"]
+|===
+| Property| Name| Description| Type| Default| Example
+| *accessKey {empty}* *| Access Key| The Azure Storage Queue access Key.| string| | 
+| *accountName {empty}* *| Account Name| The Azure Storage Queue account name.| string| | 
+| *queueName {empty}* *| Queue Name| The Azure Storage Queue container name.| string| | 
+|===
+
+NOTE: Fields marked with ({empty}*) are mandatory.
+
+== Usage
+
+This section summarizes how the `azure-storage-queue-sink` can be used in various contexts.
+
+=== Knative Sink
+
+The `azure-storage-queue-sink` Kamelet can be used as Knative sink by binding it to a Knative object.
+
+.azure-storage-queue-sink-binding.yaml
+[source,yaml]
+----
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+  name: azure-storage-queue-sink-binding
+spec:
+  source:
+    ref:
+      kind: InMemoryChannel
+      apiVersion: messaging.knative.dev/v1
+      name: mychannel
+  sink:
+    ref:
+      kind: Kamelet
+      apiVersion: camel.apache.org/v1alpha1
+      name: azure-storage-queue-sink
+    properties:
+      accessKey: "The Access Key"
+      accountName: "The Account Name"
+      queueName: "The Queue Name"
+
+----
+
+Make sure you have xref:latest@camel-k::installation/installation.adoc[Camel K installed] into the Kubernetes cluster you're connected to.
+
+Save the `azure-storage-queue-sink-binding.yaml` file into your hard drive, then configure it according to your needs.
+
+You can run the sink using the following command:
+
+[source,shell]
+----
+kubectl apply -f azure-storage-queue-sink-binding.yaml
+----
+// THIS FILE IS AUTOMATICALLY GENERATED: DO NOT EDIT

[camel-kamelets] 03/04: Added Azure Storage Queue Sink Kamelet

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-queue-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit decb92b34a66c8a1f984b7821954f4af0839c0ae
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 14 14:48:53 2021 +0200

    Added Azure Storage Queue Sink Kamelet
---
 docs/modules/ROOT/nav.adoc | 1 +
 1 file changed, 1 insertion(+)

diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index 07ad84a..0d63e31 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -12,6 +12,7 @@
 * xref:ROOT:aws-sqs-source.adoc[image:kamelets/aws-sqs-source.svg[] AWS SQS Source]
 * xref:ROOT:azure-storage-blob-sink.adoc[image:kamelets/azure-storage-blob-sink.svg[] Azure Storage Blob Sink]
 * xref:ROOT:azure-storage-blob-source.adoc[image:kamelets/azure-storage-blob-source.svg[] Azure Storage Blob Source]
+* xref:ROOT:azure-storage-queue-sink.adoc[image:kamelets/azure-storage-queue-sink.svg[] Azure Storage Queue Sink]
 * xref:ROOT:bitcoin-source.adoc[image:kamelets/bitcoin-source.svg[] Bitcoin Source]
 * xref:ROOT:dropbox-sink.adoc[image:kamelets/dropbox-sink.svg[] Dropbox Sink]
 * xref:ROOT:dropbox-source.adoc[image:kamelets/dropbox-source.svg[] Dropbox Source]

[camel-kamelets] 02/04: Added Azure Storage Queue Sink Kamelet

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-queue-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 7765411da3905b79d4fdde44e35729787f1328a4
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 14 14:48:40 2021 +0200

    Added Azure Storage Queue Sink Kamelet
---
 azure-storage-queue-sink.kamelet.yaml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/azure-storage-queue-sink.kamelet.yaml b/azure-storage-queue-sink.kamelet.yaml
index 1e59e03..81f956d 100644
--- a/azure-storage-queue-sink.kamelet.yaml
+++ b/azure-storage-queue-sink.kamelet.yaml
@@ -3,7 +3,7 @@ kind: Kamelet
 metadata:
   name: azure-storage-queue-sink
   annotations:
-    camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgOTEgODEiIGZpbGw9IiNmZmYiIGZpbGwtcnVsZT0iZXZlbm9kZCIgc3Ryb2tlPSIjMDAwIiBzdHJva2UtbGluZWNhcD0icm91bmQiIHN0cm9rZS1saW5lam9pbj0icm91bmQiPjx1c2UgeGxpbms6aHJlZj0iI0EiIHg9Ii41IiB5PSIuNSIvPjxzeW1ib2wgaWQ9IkEiIG92ZXJmbG93PSJ2aXNpYmxlIj48cGF0aCBkPSJNNjcuNTU4IDBIMjIuNDQxTDAgNDBsMjIuNDQxIDQwaDQ1LjExN0w5MCA0MCA2Ny [...]
+    camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgOTEgODEiIGZpbGw9IiNmZmYiIGZpbGwtcnVsZT0iZXZlbm9kZCIgc3Ryb2tlPSIjMDAwIiBzdHJva2UtbGluZWNhcD0icm91bmQiIHN0cm9rZS1saW5lam9pbj0icm91bmQiPjx1c2UgeGxpbms6aHJlZj0iI0EiIHg9Ii41IiB5PSIuNSIvPjxzeW1ib2wgaWQ9IkEiIG92ZXJmbG93PSJ2aXNpYmxlIj48cGF0aCBkPSJNNzAuMDUzIDM0LjYzNEg1MC41OGw5LjczNiA3LjgwNXptLTM5LjQyIDEwLjQ4OG [...]
     camel.apache.org/provider: "Apache Software Foundation"
   labels:
     camel.apache.org/kamelet.type: "sink"

[camel-kamelets] 01/04: Added Azure Storage Queue Sink Kamelet

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-queue-sink
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit fe7ea5f1ff3761c95b2afb2dbf629c333338e357
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 14 14:46:29 2021 +0200

    Added Azure Storage Queue Sink Kamelet
---
 azure-storage-queue-sink.kamelet.yaml | 59 +++++++++++++++++++++++++++++++++++
 1 file changed, 59 insertions(+)

diff --git a/azure-storage-queue-sink.kamelet.yaml b/azure-storage-queue-sink.kamelet.yaml
new file mode 100644
index 0000000..1e59e03
--- /dev/null
+++ b/azure-storage-queue-sink.kamelet.yaml
@@ -0,0 +1,59 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+  name: azure-storage-queue-sink
+  annotations:
+    camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgOTEgODEiIGZpbGw9IiNmZmYiIGZpbGwtcnVsZT0iZXZlbm9kZCIgc3Ryb2tlPSIjMDAwIiBzdHJva2UtbGluZWNhcD0icm91bmQiIHN0cm9rZS1saW5lam9pbj0icm91bmQiPjx1c2UgeGxpbms6aHJlZj0iI0EiIHg9Ii41IiB5PSIuNSIvPjxzeW1ib2wgaWQ9IkEiIG92ZXJmbG93PSJ2aXNpYmxlIj48cGF0aCBkPSJNNjcuNTU4IDBIMjIuNDQxTDAgNDBsMjIuNDQxIDQwaDQ1LjExN0w5MCA0MCA2Ny [...]
+    camel.apache.org/provider: "Apache Software Foundation"
+  labels:
+    camel.apache.org/kamelet.type: "sink"
+spec:
+  definition:
+    title: "Azure Storage Queue Sink"
+    description: |-
+      Send Messages to Azure Storage queues.
+
+      The Kamelet is able to understand the following headers to be set:
+
+      - `expiration` / `ce-expiration`: as the time to live of the message in the queue.
+
+      If the header won't be set the default of 7 days will be used.
+    required:
+      - accountName
+      - queueName
+      - accessKey
+    properties:
+      accountName:
+        title: Account Name
+        description: The Azure Storage Queue account name.
+        type: string
+      queueName:
+        title: Queue Name
+        description: The Azure Storage Queue container name.
+        type: string
+      accessKey:
+        title: Access Key
+        description: The Azure Storage Queue access Key.
+        type: string
+        x-descriptors:
+        - urn:alm:descriptor:com.tectonic.ui:password
+  flow:
+    from:
+      uri: "kamelet:source"
+      steps:
+      - choice:
+          when:
+          - simple: "${header[expiration]}"
+            steps:
+            - set-header:
+                name: CamelAzureStorageQueueTimeToLive
+                simple: "${header[expiration]}"
+          - simple: "${header[ce-expiration]}"
+            steps:
+            - set-header:
+                name: CamelAzureStorageQueueTimeToLive
+                simple: "${header[ce-expiration]}"
+      - to:
+          uri: "azure-storage-queue://{{accountName}}/{{queueName}}"
+          parameters:
+            accessKey: "{{accessKey}}"