Azure Publish
CertifiedPublish messages to an Azure Service Bus queue
Azure Publish
Publish messages to an Azure Service Bus queue
Sends one or more messages, provided via from, to the configured Service Bus queue.
type: io.kestra.plugin.azure.servicebus.PublishExamples
id: azure_service_bus_publish
namespace: company.team
tasks:
- id: publish
type: io.kestra.plugin.azure.servicebus.Publish
queueName: your-queue-name
tenantId: "{{ secret('AZURE_TENANT_ID') }}"
clientId: "{{ secret('AZURE_CLIENT_ID') }}"
clientSecret: "{{ secret('AZURE_CLIENT_SECRET') }}"
from:
timeToLive: PT10S
body: "messageBody"
Properties
from *stringarray
Structured data items, either as a map, a list of map, a URI, or a JSON string
Structured data items can be defined in the following ways:
- A single item as a map (a document).
- A list of items as a list of maps (a list of documents).
- A URI, supported schemes are
kestrafor internal storage files,filefor host local files, andnsfilefor namespace files. - A JSON String that will then be serialized either as a single item or a list of items.
io.kestra.plugin.azure.servicebus.Message
Application properties
Body
Message id
Subject
durationTime to live
tenantId *string
Azure AD tenant ID (GUID)
assets
Assets this task consumes as inputs or produces as outputs, for lineage tracking and the asset graph (Enterprise Edition). A flow declaring this property on a task is rejected in the open-source edition.
io.kestra.core.models.assets.AssetsDeclaration
IGNOREFAILWARNAsset failure behavior
Behavior applied to the task state when a declared asset fails to render, emit, or be persisted (e.g. a lock conflict): FAIL escalates it to FAILED, WARN (default) warns it if it would otherwise succeed, IGNORE leaves the state untouched.
Whether to auto-register assets referenced dynamically at runtime that are not statically declared in inputs or outputs.
The assets consumed as inputs.
io.kestra.core.models.assets.AssetIdentifier
1The assets produced as outputs.
io.kestra.plugin.ee.assets.Dataset
1150{}1150io.kestra.plugin.ee.assets.File
1150{}1150io.kestra.plugin.ee.assets.Table
1150{}1150io.kestra.plugin.ee.assets.VM
1150{}1150io.kestra.core.models.assets.External
1150{}1150io.kestra.core.models.assets.Custom
11501Custom asset type
{}1150clientId string
Client ID of the Azure AD application
Application (client) ID used for service principal authentication.
clientSecret string
Client secret for the Azure AD application
Secret value associated with the client ID; store in a Kestra secret.
connectionString string
Connection string for the Service Bus namespace or entity; overrides client credential authentication
pemCertificate string
PEM-encoded certificate content for client authentication
PEM text for certificate-based auth; alternative to clientSecret.
queueName string
Name of the Service Bus queue to connect to; queueName and topicName are mutually exclusive
serdeType string
STRINGSTRINGJSONPayload serializer
Serializer/deserializer for the message body; defaults to STRING
subscriptionName string
Subscription name when connecting to a topic
topicName string
Name of the Service Bus topic to connect to; queueName and topicName are mutually exclusive
Outputs
messagesCount integer
Messages count
Metrics
servicebus.publish.queue.messages counter
messagesNumber of messages published to the Service Bus queue.
servicebus.publish.topic.messages counter
messagesNumber of messages published to the Service Bus topic.
