Azure Publish

Azure Publish

Certified

Publish messages to an Azure Service Bus queue

Sends one or more messages, provided via from, to the configured Service Bus queue.

yaml
type: io.kestra.plugin.azure.servicebus.Publish
yaml
id: azure_cosmos_service_bus_publish
namespace: company.team

tasks:
  - id: create
    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

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 kestra for internal storage files, file for host local files, and nsfile for namespace files.
  • A JSON String that will then be serialized either as a single item or a list of items.
Definitions
applicationPropertiesobject

Application properties

bodyobject

Body

messageIdstring

Message id

subjectstring

Subject

timeToLivestring
Formatduration

Time to live

Azure AD tenant ID (GUID)

Client ID of the Azure AD application

Application (client) ID used for service principal authentication.

Client secret for the Azure AD application

Secret value associated with the client ID; store in a Kestra secret.

Connection string for the Service Bus namespace or entity; overrides client credential authentication

PEM-encoded certificate content for client authentication

PEM text for certificate-based auth; alternative to clientSecret.

Reference (ref) of the pluginDefaults to apply to this task.

Name of the Service Bus queue to connect to; queueName and topicName are mutually exclusive

DefaultSTRING
Possible Values
STRINGJSON

Payload serializer

Serializer/deserializer for the message body; defaults to STRING

Subscription name when connecting to a topic

Name of the Service Bus topic to connect to; queueName and topicName are mutually exclusive

Messages count

Unitmessages

Number of messages published to the Service Bus queue.

Unitmessages

Number of messages published to the Service Bus topic.

More Plugins in this Category

NetBox (EE)
NetBox
Enterprise

Enterprise NetBox tasks to create, update, and query devices, IP addresses, and sites over the NetBox API.

Infrastructure

7 tasks

4 blueprints

Clickhouse
Clickhouse

Tasks that connect to ClickHouse via JDBC to run queries and loads.

Data

5 tasks

2 blueprints