服务总线
连接到 Azure 服务总线以发送和接收消息。 可以执行诸如发送到队列、发送到主题、从队列接收、从订阅接收等操作。
此连接器在以下产品和区域中可用:
| 服务 | Class | 区域 |
|---|---|---|
| Copilot Studio | 高级 | 除以下各项外的所有 Power Automate 区域 : - 美国政府 (GCC High) |
| 逻辑应用程序 | 标准 | 所有 逻辑应用区域 |
| Power Apps | 高级 | 除以下各项外的所有 Power Apps 区域 : - 美国政府 (GCC High) |
| Power Automate | 高级 | 除以下各项外的所有 Power Automate 区域 : - 美国政府 (GCC High) |
| 联系人 | |
|---|---|
| Name | Microsoft |
| URL |
Microsoft LogicApps 支持 Microsoft Power Automate 支持 Microsoft Power Apps 支持 |
| 连接器元数据 | |
|---|---|
| 发布者 | Microsoft |
| 网站 | https://azure.microsoft.com/services/service-bus/ |
常规已知问题和限制
无限循环
在同时选择具有相同连接器类型的触发器和作并将它们用于处理同一实体(例如队列或主题订阅)时,请谨慎使用。 此组合可以创建无限循环,这会导致工作流永不结束。
例如,假设工作流使用服务总线触发器,该触发器返回队列中新接收的消息,并遵循该服务总线作,该作将消息发送回同一队列。 此模式可以创建无限循环,从而导致一个未结束的工作流。
连接器缓存中保存的会话的限制
根据服务总线 消息传送实体(例如订阅或主题),服务总线连接器一次最多可将 1,500 个唯一会话保存到连接器缓存。 如果会话计数超过此限制,则将从缓存中删除旧会话。 有关详细信息,请参阅消息会话。
长轮询触发器
对于 Azure 服务总线托管连接器,所有触发器都是 长时间轮询。 此触发器类型处理所有消息,然后等待 30 秒,使更多消息出现在队列或主题订阅中。 如果在 30 秒内未显示任何消息,则会跳过触发器运行。 否则,该触发器将继续读取消息,直到队列或主题订阅为空。 下一次触发器轮询将基于在触发器的属性中指定的重复周期间隔。
Microsoft Entra ID 身份验证
若要使用 Microsoft Entra ID 身份验证,用户帐户需要特定的角色分配。 有关详细信息,请参阅 分配 Azure 角色以获取访问权限 - Azure 服务总线。
托管标识身份验证
目前,仅 Azure 逻辑应用支持 托管标识身份验证 。
若要使用对从逻辑应用工作流访问服务总线命名空间和消息传送实体进行身份验证的托管标识,请确保在相应的级别分配角色权限。 例如,若要访问某个队列,托管标识需要一个对该队列拥有所需权限的角色。
访问不同消息传送实体的每个托管标识都应与该实体建立单独的连接。 如果使用不同的 Azure 服务总线作发送和接收消息,并且这些作需要不同的权限,请确保使用不同的连接。
若要启用托管标识以用于 Azure 服务总线,请执行以下步骤:
为逻辑应用资源启用或创建托管标识。 有关详细信息,请参阅在 Azure 逻辑应用中使用托管标识对 Azure 资源的身份验证访问。
授予对 Azure 服务总线资源的标识访问权限。 有关详细信息,请参阅 分配 Azure 角色以获取访问权限 - Azure 服务总线
对于用户分配的标识,请将标识添加到逻辑应用资源。 有关 Azure 逻辑应用中的托管标识的详细信息,请参阅在 Azure 逻辑应用中使用托管标识对 Azure 资源的访问进行身份验证
连接器深入
本文介绍适用于 Azure 逻辑应用、Power Automate 和 Power Apps 的 Azure 服务总线 托管 连接器的作。 Azure 服务总线 内置 连接器仅适用于 Azure 逻辑应用中的标准逻辑应用工作流。
有关 Azure 逻辑应用中的 Azure 服务总线内置连接器和托管连接器的详细信息,请参阅 从 Azure 逻辑应用中的工作流连接到 Azure 服务总线。
正在创建连接
连接器支持以下身份验证类型:
| 访问密钥 | 提供用于访问 Azure 服务总线的连接字符串。 | 除 Azure 政府和国防部(DoD)以外的所有区域(Azure 政府和美国政府(GCC)和美国政府(GCC-High) | 不可共享 |
| 访问密钥 (Azure 政府版) | 提供用于访问 Azure 服务总线的连接字符串。 | Azure 政府和国防部(DoD)仅在 Azure 政府和美国政府(GCC)和美国政府(GCC-High) | 不可共享 |
| 客户端证书身份验证 | 使用 PFX 证书和密码提供Microsoft Entra ID 凭据 | 所有区域 | 可共享 |
| 逻辑应用托管标识 | 使用 LogicApps 托管标识创建连接 | 仅限 LOGICAPPS | 可共享 |
| Microsoft Entra ID 集成 | 使用 Microsoft Entra ID 访问 Azure 服务总线。 | 除 Azure 政府和国防部(DoD)以外的所有区域(Azure 政府和美国政府(GCC)和美国政府(GCC-High) | 不可共享 |
| Microsoft Entra ID 集成(Azure 政府版) | 使用 Microsoft Entra ID 访问 Azure 服务总线。 | Azure 政府和国防部(DoD)仅在 Azure 政府和美国政府(GCC)和美国政府(GCC-High) | 不可共享 |
| 默认值 [已弃用] | 此选项仅适用于没有显式身份验证类型的较旧连接,并且仅用于向后兼容性。 | 所有区域 | 不可共享 |
访问密钥
身份验证 ID:connectionstringauth
适用:除 Azure 政府和国防部(DoD)以外的所有区域(Azure 政府和美国政府(GCC)和美国政府(GCC-High)
提供用于访问 Azure 服务总线的连接字符串。
这是不可共享的连接。 如果 Power App 与另一个用户共享,系统会提示其他用户显式创建新连接。
| Name | 类型 | Description | 必选 |
|---|---|---|---|
| 连接字符串 | securestring | Azure 服务总线连接字符串 | True |
访问密钥 (Azure 政府版)
身份验证 ID:connectionstringauth
适用:Azure 政府和国防部(DoD)仅在 Azure 政府和美国政府(GCC)和美国政府(GCC-High)
提供用于访问 Azure 服务总线的连接字符串。
这是不可共享的连接。 如果 Power App 与另一个用户共享,系统会提示其他用户显式创建新连接。
| Name | 类型 | Description | 必选 |
|---|---|---|---|
| 连接字符串 | securestring | Azure 服务总线连接字符串 | True |
客户端证书身份验证
身份验证 ID:CertOauth
适用:所有区域
使用 PFX 证书和密码提供Microsoft Entra ID 凭据
这是可共享的连接。 如果 Power App 与其他用户共享,则连接也会共享。 有关详细信息,请参阅 画布应用的连接器概述 - Power Apps |Microsoft Docs
| Name | 类型 | Description | 必选 |
|---|---|---|---|
| 租户 | 字符串 | True | |
| 客户 ID | 字符串 | Microsoft Entra ID 应用程序的客户端 ID | True |
| 客户端证书机密 | clientCertificate | 此应用程序允许的客户端证书机密 | True |
| 命名空间终结点 | 字符串 | 提供服务总线命名空间终结点(例如:sb://testsb.servicebus.windows.net/) | True |
逻辑应用托管标识
身份验证 ID:managedIdentityAuth
适用:仅限 LOGICAPPS
使用 LogicApps 托管标识创建连接
这是可共享的连接。 如果 Power App 与其他用户共享,则连接也会共享。 有关详细信息,请参阅 画布应用的连接器概述 - Power Apps |Microsoft Docs
| Name | 类型 | Description | 必选 |
|---|---|---|---|
| LogicApps 托管标识 | managedIdentity | 使用逻辑应用托管标识登录 | True |
| 命名空间终结点 | 字符串 | 提供服务总线命名空间终结点(例如:sb://testsb.servicebus.windows.net/) | True |
已集成 Microsoft Entra ID
身份验证 ID:aadAuth
适用:除 Azure 政府和国防部(DoD)以外的所有区域(Azure 政府和美国政府(GCC)和美国政府(GCC-High)
使用 Microsoft Entra ID 访问 Azure 服务总线。
这是不可共享的连接。 如果 Power App 与另一个用户共享,系统会提示其他用户显式创建新连接。
| Name | 类型 | Description | 必选 |
|---|---|---|---|
| 命名空间终结点 | 字符串 | 提供服务总线命名空间终结点(例如:sb://testsb.servicebus.windows.net/) | True |
Microsoft Entra ID 集成(Azure 政府版)
身份验证 ID:aadAuth
适用:Azure 政府和国防部(DoD)仅在 Azure 政府和美国政府(GCC)和美国政府(GCC-High)
使用 Microsoft Entra ID 访问 Azure 服务总线。
这是不可共享的连接。 如果 Power App 与另一个用户共享,系统会提示其他用户显式创建新连接。
| Name | 类型 | Description | 必选 |
|---|---|---|---|
| 命名空间终结点 | 字符串 | 提供服务总线命名空间终结点(例如:sb://testsb.servicebus.windows.net/) | True |
默认值 [已弃用]
适用:所有区域
此选项仅适用于没有显式身份验证类型的较旧连接,并且仅用于向后兼容性。
这是不可共享的连接。 如果 Power App 与另一个用户共享,系统会提示其他用户显式创建新连接。
| Name | 类型 | Description | 必选 |
|---|---|---|---|
| 连接字符串 | securestring | Azure 服务总线连接字符串 | True |
限制
| 名称 | 调用 | 续订期 |
|---|---|---|
| 每个连接的 API 调用数 | 6000 | 60 秒 |
操作
| 主题订阅中的消息死信 |
该作将消息移动到主题 Dead-Letter 队列。 |
| 从主题订阅获取延迟消息 |
该作从主题订阅获取延迟的消息。 |
| 从主题订阅获取消息(速览锁定) |
该作从具有速览锁的主题订阅接收消息。 如果未提供最大消息计数,则会读取 20 条消息。 |
| 从队列获取延迟消息 |
该作从队列中获取延迟的消息。 |
| 从队列获取消息(速览锁定) |
该作从具有速览锁的队列接收消息。 如果未提供最大消息计数,则会读取 20 条消息。 |
| 关闭主题中的会话 |
该作关闭主题中的会话。 |
| 关闭队列中的会话 |
该作关闭队列中的会话。 |
| 创建主题订阅 |
该作将创建主题订阅。 |
| 删除主题订阅 |
该作将删除主题订阅。 |
| 发送一个或多个消息 |
此作将一个或多个消息发送到队列或主题。 |
| 发送消息 |
此作将消息发送到队列或主题。 |
| 在主题订阅中续订会话锁定 |
该作会续订主题订阅中的会话。 |
| 在主题订阅中续订对消息的锁定 |
该作会续订主题订阅中消息的锁定。 |
| 在队列中的会话上续订锁定 |
该作会续订队列中的会话。 |
| 完成主题订阅中的消息 |
该作在主题订阅中完成消息。 |
| 完成队列中的消息 |
该作在队列中完成消息。 |
| 延迟主题订阅中的消息 |
该作延迟主题订阅中的消息。 |
| 延迟队列中的消息 |
该作延迟队列中的消息。 |
| 放弃主题订阅中的消息 |
该作放弃主题订阅中的消息。 |
| 放弃队列中的消息 |
该作放弃队列中的消息。 |
| 死信队列中的消息 |
该作会将消息移动到 Dead-Letter 队列。 |
| 续订队列中消息的锁定 |
该作会续订队列中消息的锁定。 |
主题订阅中的消息死信
该作将消息移动到主题 Dead-Letter 队列。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
将消息的锁定令牌锁定为死信 |
|
会话 ID
|
sessionId | string |
会话 ID |
|
|
死信原因
|
deadLetterReason | string |
死信原因 |
|
|
死信错误说明
|
deadLetterErrorDescription | string |
死信错误说明 |
从主题订阅获取延迟消息
该作从主题订阅获取延迟的消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
消息的序列号
|
sequenceNumber | True | integer |
消息的序列号 |
|
订阅类型
|
subscriptionType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
返回
服务总线消息
- Body
- ServiceBusMessage
从主题订阅获取消息(速览锁定)
该作从具有速览锁的主题订阅接收消息。 如果未提供最大消息计数,则会读取 20 条消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
最大消息计数
|
maxMessageCount | integer |
要在批处理中返回的最大消息数 |
|
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
返回
- response
- array of ServiceBusMessage
从队列获取延迟消息
该作从队列中获取延迟的消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
消息的序列号
|
sequenceNumber | True | integer |
消息的序列号 |
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
返回
服务总线消息
- Body
- ServiceBusMessage
从队列获取消息(速览锁定)
该作从具有速览锁的队列接收消息。 如果未提供最大消息计数,则会读取 20 条消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
最大消息计数
|
maxMessageCount | integer |
要在批处理中返回的最大消息数 |
|
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
返回
- response
- array of ServiceBusMessage
关闭主题中的会话
该作关闭主题中的会话。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
会话 ID
|
sessionId | True | string |
会话 ID |
关闭队列中的会话
该作关闭队列中的会话。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
会话 ID
|
sessionId | True | string |
会话 ID |
创建主题订阅
该作将创建主题订阅。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
过滤器
|
subscriptionFilter | True | dynamic |
订阅筛选器 |
|
筛选器类型
|
subscriptionFilterType | string |
筛选器类型 |
返回
主题订阅。
- Body
- Subscription
删除主题订阅
该作将删除主题订阅。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
发送一个或多个消息
此作将一个或多个消息发送到队列或主题。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列/主题名称
|
entityName | True | string |
队列或主题的名称 |
|
Content
|
ContentData | byte |
消息的内容 |
|
|
内容类型
|
ContentType | string |
消息内容的内容类型 |
|
|
属性
|
Properties | object |
每个中转属性的键值对 |
|
|
消息 ID
|
MessageId | string |
这是一个用户定义的值,服务总线可用于标识重复的消息(如果已启用)。 |
|
|
到
|
To | string |
发送到地址 |
|
|
回复
|
ReplyTo | string |
要答复的队列的地址 |
|
|
回复会话 ID
|
ReplyToSessionId | string |
要答复的会话的标识符 |
|
|
标签
|
Label | string |
应用程序特定的标签 |
|
|
ScheduledEnqueueTimeUtc
|
ScheduledEnqueueTimeUtc | date-time |
消息将添加到队列中的日期和时间(UTC) |
|
|
会话 ID
|
SessionId | string |
会话的标识符 |
|
|
相关 ID
|
CorrelationId | string |
关联标识符 |
|
|
序列号
|
SequenceNumber | integer |
序列号的标识符 |
|
|
锁定令牌
|
LockToken | string |
消息的锁定标记作为字符串。 |
|
|
生存时间
|
TimeToLive | integer |
这是消息有效的持续时间(以刻度为单位)。 持续时间从消息发送到服务总线时开始。 |
|
|
系统属性
|
systemProperties | string |
系统属性 - 无或运行详细信息。 运行详细信息会将运行元数据属性详细信息添加为消息中的自定义属性。 |
发送消息
此作将消息发送到队列或主题。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列/主题名称
|
entityName | True | string |
队列或主题的名称 |
|
Content
|
ContentData | byte |
消息的内容 |
|
|
内容类型
|
ContentType | string |
消息内容的内容类型 |
|
|
属性
|
Properties | object |
每个中转属性的键值对 |
|
|
消息 ID
|
MessageId | string |
这是一个用户定义的值,服务总线可用于标识重复的消息(如果已启用)。 |
|
|
到
|
To | string |
发送到地址 |
|
|
回复
|
ReplyTo | string |
要答复的队列的地址 |
|
|
回复会话 ID
|
ReplyToSessionId | string |
要答复的会话的标识符 |
|
|
标签
|
Label | string |
应用程序特定的标签 |
|
|
ScheduledEnqueueTimeUtc
|
ScheduledEnqueueTimeUtc | date-time |
消息将添加到队列中的日期和时间(UTC) |
|
|
会话 ID
|
SessionId | string |
会话的标识符 |
|
|
相关 ID
|
CorrelationId | string |
关联标识符 |
|
|
序列号
|
SequenceNumber | integer |
序列号的标识符 |
|
|
锁定令牌
|
LockToken | string |
消息的锁定标记作为字符串。 |
|
|
生存时间
|
TimeToLive | integer |
这是消息有效的持续时间(以刻度为单位)。 持续时间从消息发送到服务总线时开始。 |
|
|
系统属性
|
systemProperties | string |
系统属性 - 无或运行详细信息。 运行详细信息会将运行元数据属性详细信息添加为消息中的自定义属性。 |
在主题订阅中续订会话锁定
该作会续订主题订阅中的会话。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
会话 ID
|
sessionId | True | string |
会话 ID |
在主题订阅中续订对消息的锁定
该作会续订主题订阅中消息的锁定。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
要续订锁定的消息的锁定令牌 |
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
在队列中的会话上续订锁定
该作会续订队列中的会话。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
会话 ID
|
sessionId | True | string |
会话 ID |
完成主题订阅中的消息
该作在主题订阅中完成消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
要完成的消息的锁定令牌 |
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
完成队列中的消息
该作在队列中完成消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
要完成的消息的锁定令牌 |
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
延迟主题订阅中的消息
该作延迟主题订阅中的消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
锁定消息的令牌以延迟 |
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
延迟队列中的消息
该作延迟队列中的消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
锁定消息的令牌以延迟 |
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
放弃主题订阅中的消息
该作放弃主题订阅中的消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
要放弃的消息的锁定令牌 |
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
放弃队列中的消息
该作放弃队列中的消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
要放弃的消息的锁定令牌 |
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID |
死信队列中的消息
该作会将消息移动到 Dead-Letter 队列。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
将消息的锁定令牌锁定为死信 |
|
会话 ID
|
sessionId | string |
会话 ID |
|
|
死信原因
|
deadLetterReason | string |
死信原因 |
|
|
死信错误说明
|
deadLetterErrorDescription | string |
死信错误说明 |
续订队列中消息的锁定
该作会续订队列中消息的锁定。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
消息的锁定令牌
|
lockToken | True | string |
要续订锁定的消息的锁定令牌 |
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
触发器
| 在主题订阅中收到消息时(自动完成) |
此作在主题订阅中收到消息并自动完成消息时触发流。 |
| 在主题订阅中收到消息时(速览锁定) |
当在主题订阅中收到具有速览锁定模式的消息时,该作将触发流。 |
| 在队列中收到消息时(自动完成) |
此作在队列中收到消息并自动完成消息时触发流。 |
| 在队列中收到消息时(速览锁定) |
作在队列中收到具有速览锁定模式的消息时触发流。 |
| 当一个或多个消息到达主题时(自动完成) |
该作从主题接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。 |
| 当一个或多个消息到达主题时(速览锁定) |
该作从具有速览锁的主题接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。 |
| 当一个或多个消息到达队列时(自动完成) |
该作从队列接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。 |
| 当一个或多个消息到达队列时(速览锁定) |
该作从具有速览锁的队列接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。 |
在主题订阅中收到消息时(自动完成)
此作在主题订阅中收到消息并自动完成消息时触发流。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
返回
服务总线消息
- Body
- ServiceBusMessage
在主题订阅中收到消息时(速览锁定)
当在主题订阅中收到具有速览锁定模式的消息时,该作将触发流。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID - 无或下一个可用或提供会话 ID |
返回
服务总线消息
- Body
- ServiceBusMessage
在队列中收到消息时(自动完成)
此作在队列中收到消息并自动完成消息时触发流。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
返回
服务总线消息
- Body
- ServiceBusMessage
在队列中收到消息时(速览锁定)
作在队列中收到具有速览锁定模式的消息时触发流。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID - 无或下一个可用或提供会话 ID |
返回
服务总线消息
- Body
- ServiceBusMessage
当一个或多个消息到达主题时(自动完成)
该作从主题接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
最大消息计数
|
maxMessageCount | integer |
要在批处理中返回的最大消息数 |
|
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
返回
服务总线消息
- Body
- ServiceBusMessage
当一个或多个消息到达主题时(速览锁定)
该作从具有速览锁的主题接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
主题名称
|
topicName | True | string |
主题的名称 |
|
主题订阅名称
|
subscriptionName | True | string |
主题订阅的名称 |
|
最大消息计数
|
maxMessageCount | integer |
要在批处理中返回的最大消息数 |
|
|
订阅类型
|
subscriptionType | string |
订阅类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID - 无或下一个可用或提供会话 ID |
返回
服务总线消息
- Body
- ServiceBusMessage
当一个或多个消息到达队列时(自动完成)
该作从队列接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
最大消息计数
|
maxMessageCount | integer |
要在批处理中返回的最大消息数 |
|
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
返回
服务总线消息
- Body
- ServiceBusMessage
当一个或多个消息到达队列时(速览锁定)
该作从具有速览锁的队列接收一个或多个消息。 如果未提供最大消息计数,则会读取 20 条消息。
参数
| 名称 | 密钥 | 必需 | 类型 | 说明 |
|---|---|---|---|---|
|
队列名称
|
queueName | True | string |
队列的名称 |
|
最大消息计数
|
maxMessageCount | integer |
要在批处理中返回的最大消息数 |
|
|
队列类型
|
queueType | string |
队列类型 - Main 或 DeadLetter |
|
|
会话 ID
|
sessionId | string |
会话 ID - 无或下一个可用或提供会话 ID |
返回
服务总线消息
- Body
- ServiceBusMessage
定义
ServiceBusMessage
服务总线消息
| 名称 | 路径 | 类型 | 说明 |
|---|---|---|---|
|
Content
|
ContentData | byte |
消息的内容 |
|
内容类型
|
ContentType | string |
消息内容的内容类型 |
|
属性
|
Properties | object |
每个中转属性的键值对 |
|
消息 ID
|
MessageId | string |
这是一个用户定义的值,服务总线可用于标识重复的消息(如果已启用)。 |
|
到
|
To | string |
发送到地址 |
|
回复
|
ReplyTo | string |
要答复的队列的地址 |
|
回复会话 ID
|
ReplyToSessionId | string |
要答复的会话的标识符 |
|
标签
|
Label | string |
应用程序特定的标签 |
|
ScheduledEnqueueTimeUtc
|
ScheduledEnqueueTimeUtc | date-time |
消息将添加到队列中的日期和时间(UTC) |
|
会话 ID
|
SessionId | string |
会话的标识符 |
|
相关 ID
|
CorrelationId | string |
关联标识符 |
|
序列号
|
SequenceNumber | integer |
序列号的标识符 |
|
锁定令牌
|
LockToken | string |
消息的锁定标记作为字符串。 |
|
生存时间
|
TimeToLive | integer |
这是消息有效的持续时间(以刻度为单位)。 持续时间从消息发送到服务总线时开始。 |
Subscription
主题订阅。
| 名称 | 路径 | 类型 | 说明 |
|---|---|---|---|
|
订阅名称
|
SubscriptionName | string |
订阅名称。 |