Connect to Azure Service Bus from Azure Logic Apps

Artikkel
03/08/2022
9 minutter å lese

With Azure Logic Apps and the Azure Service Bus connector, you can create automated tasks and workflows that transfer data, such as sales and purchase orders, journals, and inventory movements across applications for your organization. The connector not only monitors, sends, and manages messages, but also performs actions with queues, sessions, topics, subscriptions, and so on, for example:

Monitor when messages arrive (auto-complete) or are received (peek-lock) in queues, topics, and topic subscriptions.
Send messages.
Create and delete topic subscriptions.
Manage messages in queues and topic subscriptions, for example, get, get deferred, complete, defer, abandon, and dead-letter.
Renew locks on messages and sessions in queues and topic subscriptions.
Close sessions in queues and topics.

You can use triggers that get responses from Service Bus and make the output available to other actions in your logic app workflows. You can also have other actions use the output from Service Bus actions. If you're new to Service Bus and Azure Logic Apps, review What is Azure Service Bus? and What is Azure Logic Apps?

Prerequisites

An Azure account and subscription. If you don't have an Azure subscription, sign up for a free Azure account.
A Service Bus namespace and messaging entity, such as a queue. If you don't have these items, learn how to create your Service Bus namespace and a queue.
Basic knowledge about how to create logic app workflows
The logic app workflow where you use the Service Bus namespace and messaging entity. To start your workflow with a Service Bus trigger, create a blank logic app. To use a Service Bus action in your workflow, start your logic app workflow with another trigger, for example, the Recurrence trigger.

Considerations for Azure Service Bus operations

Infinite loops

Important

Use caution when you select both a trigger and action that have the same connector type and use them to work with the same entity, such as a messaging queue or topic subscription. This combination can create an infinite loop, which results in a logic app that never ends.

Large messages

Large message support is available only when you use the built-in Service Bus operations with single-tenant Azure Logic Apps (Standard) workflows. You can send and receive large messages using the triggers or actions in the built-in version.

For receiving a message, you can increase the timeout by changing the following setting in the Azure Functions extension:

{
   "version": "2.0",
   "extensionBundle": {
      "id": "Microsoft.Azure.Functions.ExtensionBundle.Workflows",
      "version": "[1.*, 2.0.0)"
   },
   "extensions": {
      "serviceBus": {
         "batchOptions": {
            "operationTimeout": "00:15:00"
         }
      }  
   }
}

For sending a message, you can increase the timeout by adding the ServiceProviders.ServiceBus.MessageSenderOperationTimeout app setting.

Check permissions

Confirm that your logic app resource has permissions for accessing your Service Bus namespace.

In the Azure portal, sign in with your Azure account.
Go to your Service Bus namespace. On the namespace page, under Settings, select Shared access policies. Under Claims, check that you have Manage permissions for that namespace.
Get the connection string for your Service Bus namespace. You need this string when you provide the connection information in your logic app.
1. On the Shared access policies pane, select RootManageSharedAccessKey.
2. Next to your primary connection string, select the copy button. Save the connection string for later use.
Tip

To confirm whether your connection string is associated with your Service Bus namespace or a messaging entity, such as a queue, search the connection string for the EntityPath parameter. If you find this parameter, the connection string is for a specific entity, and isn't the correct string to use with your logic app workflow.

Add Service Bus trigger

When you add a trigger or action that connects to a service or system, and you don't have an existing or active connection, Azure Logic Apps prompts you to provide the connection information, which varies based on the connection type, for example:

A name to use for the connection
Your account credentials
The server or system name
A connection string
The authentication type to use

Sign in to the Azure portal, and open your blank logic app in the workflow designer.
In the portal search box, enter azure service bus. From the triggers list that appears, select the trigger that you want.

For example, to trigger your logic app workflow when a new item gets sent to a Service Bus queue, select the When a message is received in a queue (auto-complete) trigger.

Here are some considerations for when you use a Service Bus trigger:
- All Service Bus triggers are long-polling triggers. This description means that when the trigger fires, the trigger processes all the messages and then waits 30 seconds for more messages to appear in the queue or topic subscription. If no messages appear in 30 seconds, the trigger run is skipped. Otherwise, the trigger continues reading messages until the queue or topic subscription is empty. The next trigger poll is based on the recurrence interval specified in the trigger's properties.
- Some triggers, such as the When one or more messages arrive in a queue (auto-complete) trigger, can return one or more messages. When these triggers fire, they return between one and the number of messages that's specified by the trigger's Maximum message count property.
  
  Note
  
  The auto-complete trigger automatically completes a message, but completion happens only at the next call to Service Bus. This behavior can affect your logic app's design. For example, avoid changing the concurrency on the auto-complete trigger because this change might result in duplicate messages if your logic app workflow enters a throttled state. Changing the concurrency control creates these conditions: throttled triggers are skipped with the WorkflowRunInProgress code, the completion operation won't happen, and next trigger run occurs after the polling interval. You have to set the service bus lock duration to a value that's longer than the polling interval. However, despite this setting, the message still might not complete if your logic app workflow remains in a throttled state at next polling interval.
- If you turn on the concurrency setting for a Service Bus trigger, the default value for the maximumWaitingRuns property is 10. Based on the Service Bus entity's lock duration setting and the run duration for your logic app workflow, this default value might be too large and might cause a "lock lost" exception. To find the optimal value for your scenario, start testing with a value of 1 or 2 for the maximumWaitingRuns property. To change the maximum waiting runs value, see Change waiting runs limit.
If your trigger is connecting to your Service Bus namespace for the first time, follow these steps when the workflow designer prompts you for connection information.
1. Provide a name for your connection, and select your Service Bus namespace.
  
  To manually enter the connection string instead, select Manually enter connection information. If you don't have your connection string, learn how to find your connection string.
2. Select your Service Bus policy, and select Create.
3. Select the messaging entity you want, such as a queue or topic. For this example, select your Service Bus queue.
Provide the necessary information for your selected trigger. To add other available properties to the action, open the Add new parameter list, and select the properties that you want.

For this example's trigger, select the polling interval and frequency for checking the queue.

For more information about available triggers and properties, see the connector's reference page.
Continue building your logic app workflow by adding the actions that you want.

For example, you can add an action that sends email when a new message arrives. When your trigger checks your queue and finds a new message, your logic app workflow runs your selected actions for the found message.

Add Service Bus action

A name to use for the connection
Your account credentials
The server or system name
A connection string
The authentication type to use

In the Azure portal, open your logic app in the workflow designer.
Under the step where you want to add an action, select New step.

Or, to add an action between steps, move your pointer over the arrow between those steps. Select the plus sign (+) that appears, and select Add an action.
Under Choose an action, in the search box, enter azure service bus. From the actions list that appears, select the action that you want.

For this example, select the Send message action.
If your action is connecting to your Service Bus namespace for the first time, follow these steps when the workflow designer prompts you for connection information.
1. Provide a name for your connection, and select your Service Bus namespace.
  
  To manually enter the connection string instead, select Manually enter connection information. If you don't have your connection string, learn how to find your connection string.
2. Select your Service Bus policy, and select Create.
3. Select the messaging entity you want, such as a queue or topic. For this example, select your Service Bus queue.
Provide the necessary details for your selected action. To add other available properties to the action, open the Add new parameter list, and select the properties that you want.

For example, select the Content and Content Type properties so that you add them to the action. Then, specify the content for the message that you want to send.

For more information about available actions and their properties, see the connector's reference page.
Continue building your logic app workflow by adding any other actions that you want.

For example, you can add an action that sends email to confirm that your message was sent.
Save your logic app. On the designer toolbar, select Save.

Send correlated messages in order

When you need to send related messages in a specific order, you can use the sequential convoy pattern by using the Azure Service Bus connector. Correlated messages have a property that defines the relationship between those messages, such as the ID for the session in Service Bus.

When you create a logic app, you can select the Correlated in-order delivery using service bus sessions template, which implements the sequential convoy pattern. For more information, see Send related messages in order.

Delays in updates to your logic app taking effect

If a Service Bus trigger's polling interval is small, such as 10 seconds, updates to your logic app workflow might not take effect for up to 10 minutes. To work around this problem, you can disable the logic app, make the changes, and then enable the logic app workflow again.

Connector reference

From a service bus, the Service Bus connector can save up to 1,500 unique sessions at a time to the connector cache, per Service Bus messaging entity, such as a subscription or topic. If the session count exceeds this limit, old sessions are removed from the cache. For more information, see Message sessions.

For other technical details about triggers, actions, and limits, which are described by the connector's Swagger description, review the connector reference page. For more about Azure Service Bus Messaging, see What is Azure Service Bus?

Next steps

Learn about other Azure Logic Apps connectors