如何在 ARM 模板中为服务总线逻辑应用程序操作设置连接字符串?
我正在尝试部署一个 Azure 逻辑应用，其中包含使用 ARM 模板在服务总线上发送消息的操作. ARM 模板除了部署逻辑应用之外，还部署了一个服务总线命名空间、一个队列和两个 AuthorizationRule(一个用于发送，一个用于侦听). 我想动态设置发送服务总线消息操作的连接信息，以使用为支持发送的 AuthorizationRule 生成的连接字符串. 当我在门户编辑器
..
azure-servicebus-queues相关内容
Azure 服务总线队列消息处理
所以我有一个 azure 函数充当调用内部托管 API 的队列触发器. 在线似乎没有关于如何处理由于有毒以外的问题而无法处理的消息的明确答案. 示例: 收到我的消息，函数尝试调用 API.消息有效负载是正确的并且可以处理，但是无论出于何种原因 API/服务关闭(这次可能会超过 10 分钟).目前发生的情况是消息传递计数达到最大值(10)，然后被推送到死信队列，这反过来又发生在每条
..
服务总线会话ReceiveBatchAsync仅接收1条消息
我正在使用启用了会话的服务总线队列，并且正在发送具有相同SessionId的5条消息.我的接收代码使用 AcceptMessageSessionAsync 来获取会话锁定，以便它将接收该会话的所有消息.然后，它使用 session.ReceiveBatchAsync 尝试获取该会话的所有消息.但是，它似乎只获得第一个消息，然后再进行一次尝试时，它将获得所有其他消息.您应该可以看到，即使所有这些消息
..
Azure逻辑应用-无法完成队列中的消息
我在Azure Logic应用程序中有一个队列和几个Azure函数. Azure功能需要5分钟，并且当逻辑应用程序中运行事件“完成队列中的消息"时，它会失败.以下是输出. {“状态":400，"message":“无法完成带有锁令牌'{the-guid}'的消息.消息的锁已丢失."，“来源":"127.0.0.1"} 这不是一周前发生的事情. 解决方案 如果导航到“服务总线"
..
Azure Servicebus Queue函数触发器被调用两次
我有一个带有ServiceBusTrigger的Azure函数，该函数在部署到Azure时被调用两次.复制非常容易.只需创建一个新的ServiceBus触发器函数并将一条消息添加到队列中即可. 以下是发送消息的代码: 静态异步任务主(字符串[] args){IQueueClient qc = new QueueClient(_sbConnString，"testing");字符串数据=“你
..
Azure Function Service Bus触发器触发的次数比队列中的消息触发的次数更多
我有两个服务总线队列和Azure服务总线队列触发器. 该函数从队列中读取1000条消息并将其转发给另一个(用于测试)发布到Azure(计划使用量)时，即使队列中只有1000条消息，我也会得到1030+个功能命中.我认为这与功能实例的数量有关. 问:如何为一个功能实例仅处理一次唯一消息? 解决方案 它对我有用. 为host.json添加扩展名: “扩展名":{"servi
..
Azure Service Bus共享访问签名生成
我正在尝试为Azure服务总线队列生成共享访问签名.这是我用来生成SAS令牌的代码段. 使用系统；使用System.Globalization;使用System.Security.Cryptography;使用System.Text;使用System.Web;命名空间SASTokenGeneration{班级计划{静态void Main(string [] args){字符串resourceUr
..
控制Azure Service Bus队列消息接收
我们有一个分布式体系结构，并且有一个本地系统需要调用.挑战在于系统的容量不可扩展，并且无法同时承担更多的请求负载.我们已经实现了服务总线队列，其中有一个消息处理程序正在侦听此队列并调用本机系统.当前的挑战是，每当一条消息发布到队列中时，消息处理程序就会立即处理该请求.但是，我们希望有一个方案，一次只能处理两个请求.选择两个，对其进行处理，然后继续进行下两个.Service Bus Queue是否提
..
基于Service Bus触发消息内容的Azure Functions动态输入/输出绑定
我正在尝试创建具有多个绑定的Azure Function 2.0.该功能由 Azure Service Bus Queue 消息触发，我想根据此消息内容阅读 Blob .我已经尝试过以下代码: 公共静态类函数{[FunctionName(nameof(MyFunctionName))]公共静态异步任务MyFunctionName([ServiceBusTrigger(Consts.QueueNa
..
ServiceBus RetryExponential属性含义
我很难理解与QueueClients一起使用的RetryExponential类(我也假定为SubscriptionClients). 此处列出了这些属性，但我认为我对它们的描述的解释不正确. 这是我的解释... var minBackoff = TimeSpan.FromMinutes(5);//等待5分钟以进行第一次尝试?var maxBackoff = TimeSpan.Fr
..
通过REST将消息发送到Azure服务总线
Azure队列公开给REST API.要使REST调用起作用.我在POSTMAN上进行了样本测试.POST呼叫 https://yournamespace.servicebus.windows.net/yourentity/messages 此外，在下面的2个标头和值中传递. 标题1: 授权:SharedAccessSignature sr = https％3A％2F％2F.ser
..
如何使用Java将错误消息移动到Azure死信队列?
我们正在使用Azure Service Bus队列在不同系统之间交换消息.我们想使用Java代码将无效消息移至Dead Letter Queue. 我能够将邮件移至主队列，但不能移至死信队列.我试图将队列名称命名为"BasicQueue/$ deadletterqueue"，但出现错误. 解决方案 Azure Service总线运行时可能会将消息自动移动到死信队列的原因很多，例如:
..
我应该使用哪个.NET Azure Service Bus库作为队列?
Microsoft在NuGet上有两个Azure Service Bus程序包: WindowsAzure.ServiceBus 将其用于Microsoft Azure Service Bus队列，主题，EventHub和中继后端操作. Microsoft.Azure.ServiceBus 这是下一代Azure Service Bus .NET Standard客户端库，其
..
Azure Service Bus队列在获取的消息中提供控制字符
我正在使用BizTalk Server SB消息适配器来从Azure Service Bus队列检索消息.我已经成功地(使用相同的适配器)成功地将消息发送到队列中，并从队列中检索消息并进行了进一步处理. 当第三方软件供应商将消息发送到队列中，并且BizTalk Server检索和处理消息时，就会出现问题.然后，我在消息的开头收到以下其他“标题"信息和控制字符: 在文本中:@ACKstr
..
通过订阅在本地测试Azure Service Bus队列
如何在本地测试Azure Service Bus队列? 1.我必须将Queue重命名为其他名称，因为其他一些开发人员或已经运行的功能可能会使用它 Example: a) Original Queue: Product b) Test Queue: Test 2.我们还具有Azure功能来拾取队列，因此也要重命名服务总线触发器. 但是，它仍然无法正常工作吗? 是否需
..
Azure Service Bus队列在NodeJs中向.NET客户端发送消息
我正在从C#工作者向队列发送消息，然后在另一C#工作者上获取消息并致电 string body = message.GetBody(); 这有效，后来我反序列化了字符串/JSON消息. 现在，我正尝试以JSON消息的形式从NodeJS发送相同的消息.当我尝试接收它和 string body = message.GetBody(); 打电
..
如何在azureservicebus中窥视并删除Deadletter中的消息
我创建了一个Azure Service Bus主题应用程序，该应用程序可以查看 deadletter 中的所有消息.我偷看过的某些特定消息(具有特定messageid)需要从死信队列中删除.请提供实施此帮助. 解决方案 首先，如果您需要了解如何创建服务总线主题和订阅: 如何使用服务总线主题和订阅 要接收来自订阅的消息，您需要创建一个消息接收者: //Create the
..
Azure服务总线:如何续订锁?
如何更新接收队列消息处理程序上的锁定? 在事件处理程序上，测试消息不具有续订锁定属性. Message testMessage; https ://docs.microsoft.com/zh-cn/dotnet/api/microsoft.servicebus.messaging.brokeredmessage.renewlock?view = azure-dotnet 解决方案
..
如何轮询azure服务总线队列中的消息?
我如何轮询azure服务总线以连续检查消息?这是我从队列中接收消息的方式. from azure.servicebus import QueueClient client = QueueClient.from_connection_string( q_string, q_name) msg = None with client.get
..
Azure服务总线“活动连接"，“连接已打开"和“连接已关闭"
我试图在Azure Service Bus指标中找到有关“活动连接"，“打开的连接"和“关闭的连接"的更多信息. 有人可以帮我找到一个好的文档，以了解Azure Service Bus中的这些“活动连接"，“打开的连接"和“关闭的连接"吗? 解决方案 活动连接数-名称空间和实体上的活动连接数. 打开的连接数-打开的连接数. 已关闭的连接-已关闭的连接数. 来源: Azure
..