You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by nf...@apache.org on 2021/04/12 16:17:46 UTC
[camel-kamelets] 01/04: Added Azure Storage Blob Source Kamelet
This is an automated email from the ASF dual-hosted git repository.
nferraro pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit cc30aade2626b1777d3fb7a5163421cd1ac1e9d4
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Apr 12 17:53:04 2021 +0200
Added Azure Storage Blob Source Kamelet
---
azure-storage-blob-source.kamelet.yaml | 60 ++++++++++++++++++++++++++++++++++
1 file changed, 60 insertions(+)
diff --git a/azure-storage-blob-source.kamelet.yaml b/azure-storage-blob-source.kamelet.yaml
new file mode 100644
index 0000000..ef013e6
--- /dev/null
+++ b/azure-storage-blob-source.kamelet.yaml
@@ -0,0 +1,60 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: azure-storage-blob-source
+ 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: "source"
+spec:
+ definition:
+ title: "Azure Storage Blob Source"
+ description: |-
+ Consume Files from Azure Storage Blob.
+ required:
+ - period
+ - accountName
+ - containerName
+ - accessKey
+ properties:
+ period:
+ title: Period between polls
+ description: The interval between fetches to the Azure Storage Container in milliseconds
+ type: integer
+ default: 10000
+ accountName:
+ title: Account Name
+ description: The Azure Storage Blob account name.
+ type: string
+ containerName:
+ title: Container Name
+ description: The Azure Storage Blob container name.
+ type: string
+ accessKey:
+ title: Access Key
+ description: The Azure Storage Blob access Key.
+ type: string
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ flow:
+ from:
+ uri: "timer:azure-storage-blob-stream"
+ parameters:
+ period: "{{period}}"
+ steps:
+ - to:
+ uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+ parameters:
+ operation: "listBlobs"
+ accessKey: "{{accessKey}}"
+ - split:
+ jsonpath: "$.*"
+ steps:
+ - set-property:
+ name: azureBlobName
+ simple: ${body.name}
+ - tod: "azure-storage-blob:{{accountName}}/{{containerName}}?accessKey=RAW({{accessKey}})&operation=getBlob&blobName=${exchangeProperty.azureBlobName}"
+ - to: "kamelet:sink"
+ - tod: "azure-storage-blob:{{accountName}}/{{containerName}}?accessKey=RAW({{accessKey}})&operation=deleteBlob&blobName=${exchangeProperty.azureBlobName}"
+