From 6fa8ae7d848e35fd9fedf73ae0efbb8c7714380a Mon Sep 17 00:00:00 2001 From: gitea_admin Date: Wed, 11 Mar 2026 14:24:22 +0000 Subject: [PATCH] Add kamelet definition: azure-storage-queue-source --- kamelet.yaml | 129 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 129 insertions(+) create mode 100644 kamelet.yaml diff --git a/kamelet.yaml b/kamelet.yaml new file mode 100644 index 0000000..5ca8097 --- /dev/null +++ b/kamelet.yaml @@ -0,0 +1,129 @@ + +apiVersion: camel.apache.org/v1 +kind: Kamelet +metadata: + name: azure-storage-queue-source + annotations: + camel.apache.org/kamelet.support.level: "Stable" + camel.apache.org/catalog.version: "4.10.2" + camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgOTEgODEiIGZpbGw9IiNmZmYiIGZpbGwtcnVsZT0iZXZlbm9kZCIgc3Ryb2tlPSIjMDAwIiBzdHJva2UtbGluZWNhcD0icm91bmQiIHN0cm9rZS1saW5lam9pbj0icm91bmQiPjx1c2UgeGxpbms6aHJlZj0iI0EiIHg9Ii41IiB5PSIuNSIvPjxzeW1ib2wgaWQ9IkEiIG92ZXJmbG93PSJ2aXNpYmxlIj48cGF0aCBkPSJNNzAuMDUzIDM0LjYzNEg1MC41OGw5LjczNiA3LjgwNXptLTM5LjQyIDEwLjQ4OGMtLjIzOCAwLS40NzUgMC0uNzEzLS4yNDRsLTkuMDI0LTcuMzE3djExLjk1MWgyMC42NlYzNy4zMTdsLTkuNzM2IDcuNTYxYy0uNDc1LjI0NC0uOTUuMjQ0LTEuMTg3LjI0NHptMjkuNjgzIDBjLS4yMzggMC0uNzEzIDAtLjcxMy0uMjQ0bC05LjI2MS03LjMxN3YxMS45NTFoMjAuNjZWMzcuMzE3bC05LjczNiA3LjU2MWMtLjQ3NS4yNDQtLjcxMy4yNDQtLjk1LjI0NHpNNjcuNjc4IDBIMjIuNTU5TDAgNDBsMjIuNTU5IDQwSDY3LjQ0TDkwIDQwIDY3LjY3OCAwem03LjgzNiA1Ny4wNzNIMTQuMDExYy0xLjkgMC0zLjMyNS0xLjcwNy0zLjMyNS0zLjY1OVYyOS4yNjhjMC0xLjk1MSAxLjQyNS0zLjY1OCAzLjMyNS0zLjY1OGg2MS41MDRjLjcxMyAwIDEuOSAwIDkuOTc0IDE1LjYxbC4yMzcuNzMyLS4yMzcuNzMyYy04LjA3NCAxNC4zOS05LjI2MSAxNC4zOS05Ljk3NCAxNC4zOXpNNDAuMzcgMzQuNjM0SDIwLjY2bDkuNzM2IDcuODA1em0tMjYuMzU5LTYuMzQxYy0uNDc1IDAtLjk1LjQ4OC0uOTUuOTc2djI0LjE0NmMwIC40ODguNDc1IDEuMjIuOTUgMS4yMkg3NS4wNGMxLjE4OC0xLjIyIDQuNzQ5LTcuMDczIDcuODM3LTEyLjY4My0zLjA4Ny02LjA5OC02Ljg4Ni0xMi40MzktNy44MzctMTMuNjU5SDE0LjAxMXptMjkuOTIxIDIyLjQzOWMwIC43MzItLjcxMyAxLjQ2My0xLjY2MyAxLjQ2M0gxOC45OThjLS43MTMgMC0uOTUtLjczMi0uOTUtMS40NjNWMzIuOTI3YzAtLjczMi4yMzgtLjk3Ni45NS0uOTc2SDQyLjI3Yy43MTIgMCAxLjY2My4yNDQgMS42NjMuOTc2djE3LjgwNXptMjkuMjA5IDBjMCAuNzMyLS40NzUgMS40NjMtMS4xODggMS40NjNINDguOTE5Yy0uNzEyIDAtMS4xODctLjczMi0xLjE4Ny0xLjQ2M1YzMi45MjdjMC0uNzMyLjQ3NS0uOTc2IDEuMTg3LS45NzZoMjMuMDM0Yy43MTMgMCAxLjE4OC4yNDQgMS4xODguOTc2djE3LjgwNXoiIGZpbGw9IiMwMDc4ZDciIHN0cm9rZT0ibm9uZSIvPjwvc3ltYm9sPjwvc3ZnPg==" + camel.apache.org/provider: "Apache Software Foundation" + camel.apache.org/kamelet.group: "Azure Storage Queue" + camel.apache.org/kamelet.namespace: "Azure" + labels: + camel.apache.org/kamelet.type: "source" +spec: + definition: + title: "Azure Storage Queue Source" + description: |- + Receive events from Azure Storage queues. + + One header will be duplicated with different names for clarity at sink level, CamelAzureStorageQueueMessageId will be duplicated into azure.storage.queue.message.id + required: + - accountName + - queueName + - accessKey + type: object + properties: + accountName: + title: Account Name + description: The Azure Storage Queue account name. + type: string + x-descriptors: + - urn:camel:group:credentials + 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 + format: password + x-descriptors: + - urn:camel:group:credentials + maxMessages: + title: Maximum Messages + description: The maximum number of messages to get. You can specify a value between 1 and 32. The default is 1 (one message). If there are fewer than the maximum number of messages in the queue, then all the messages are returned. + type: integer + default: 1 + credentialType: + title: Credential Type + description: Determines the credential strategy to adopt. + type: string + enum: ["SHARED_ACCOUNT_KEY", "SHARED_KEY_CREDENTIAL", "AZURE_IDENTITY"] + default: "SHARED_ACCOUNT_KEY" + dataTypes: + out: + default: text + headers: + CamelAzureStorageQueueMessageId: + title: Azure Storage Queue Message Id + description: The id of the message + type: string + CamelAzureStorageQueueInsertionTime: + title: Azure Storage Queue Message Insertion Time + description: The time the Message was inserted into the Queue. + type: OffsetDateTime + CamelAzureStorageQueueExpirationTime: + title: Azure Storage Queue Message Expiration Time + description: The time that the Message will expire and be automatically deleted. + type: OffsetDateTime + CamelAzureStorageQueuePopReceipt: + title: Pop Receipt + description: |- + Unique identifier that must match for the message to be deleted or updated. If deletion fails using this pop receipt then the message has been dequeued by another client. + type: string + CamelAzureStorageQueueTimeNextVisible: + title: Azure Storage Queue Message Time Next Visible + description: The time that the message will again become visible in the Queue. + type: OffsetDateTime + CamelAzureStorageQueueDequeueCount: + title: Dequeue Count + description: The number of times the message has been dequeued + type: long + types: + text: + format: "text-plain" + description: Default text representation of the Message dequeued from the queue. + mediaType: text/plain + cloudevents: + format: "azure-storage-queue:application-cloudevents" + description: |- + Output data type represents Azure Storage Queue receive messages operation as CloudEvent V1. The data type sets Camel + specific CloudEvent headers on the exchange. + headers: + CamelCloudEventID: + title: CloudEvent ID + description: The Camel exchange id set as event id + type: string + CamelCloudEventType: + title: CloudEvent Type + description: The event type + default: "org.apache.camel.event.azure.storage.queue.receiveMessages" + type: string + CamelCloudEventSource: + title: CloudEvent Source + description: The event source. By default, the Message Id of the message received with prefix "azure.storage.queue.". + type: string + CamelCloudEventSubject: + title: CloudEvent Subject + description: The event subject. Usually the Pop receipt of the message dequeued. + type: string + CamelCloudEventTime: + title: CloudEvent Time + description: The exchange creation timestamp as event time. + type: string + dependencies: + - "camel:azure-storage-queue" + - "camel:kamelet" + - "camel:core" + template: + from: + uri: "azure-storage-queue://{{accountName}}/{{queueName}}" + parameters: + accessKey: "{{accessKey}}" + maxMessages: "{{maxMessages}}" + credentialType: "{{credentialType}}" + steps: + - to: "kamelet:sink"