是否可以将Azure Service Bus添加到队列云到设备消息?当我收到消息时,我必须确保所有消息的顺序与它们到达IoTHub的顺序相同。我找不到IoTHub中的标准队列是否提供了它。我想使用ServiceBus的第二个原因也是过期时间更长,IoTHub只提供48小时的消息。我知道,通过在DeviceMessages配置中添加端点和路由,可以很容易地在IoTHub中使用ServiceBus,但是C2D消息怎么办呢?
我一直在寻找资源,但似乎找不到我需要的东西。我有一个具有服务总线触发器的Azure函数。在此基础上,我使用Service Bus消息中的一个值进行HTTP调用。
我还有一个额外的要求,那就是如果HTTP调用失败,就给消息写死信。但据我所知,该消息不再出现在订阅中,因为它被正确地接收了。有没有办法将消息保留在订阅中,然后在消息成功后将其处理(如果没有,则转移到DLQ?)
我找到了这段代码,但我不确定它是如何发送到DLQ?的。
"""
Example to show receiving dead-lettered messages from a Service Bus Qu
我有一个Azure函数,每当消息放在IoT集线器上时,它就会触发。我希望该函数从消息中提取一些信息,然后将其放置到另一个事件中心。这是我的代码:
#r "Microsoft.ServiceBus"
using System;
using System.Text;
using Microsoft.ServiceBus.Messaging;
public static void Run(EventData eventData, out string outputEventHubMessage, TraceWriter log)
{
// Get some system p
我有一个由ServiceBusTrigger触发的函数,我一直在使用Service Bus Explorer加载消息并触发我的函数来测试它。这工作得很好,但我现在正在尝试自动化该过程,但我为向SB上传消息而编写的代码超时。
终结点类:
public class ServiceBusEndPoint
{
private readonly string _serviceBus;
public ServiceBusEndPoint()
{
_serviceBus = TestContext.Parameters[
我们希望使用Azure逻辑应用程序定期清理ServiceBus DeadLetter队列。其思想是每天循环遍历所有DeadLetter消息一次,并删除超过x天的消息。
我用"Get messages from a queue (peek lock)“实现了周期性的”循环“任务。当它们满足我的条件时,它们就完成了,因此从队列中删除。这适用于几百条消息。但当我用数千条消息测试它时,它开始返回在当前运行期间已经访问过的消息。我包含了一个条件,如果再次处理相同的messageId,则终止处理。
有没有办法实现我们想要的?那么,在不重复访问任何一条消息的情况下,循环遍历所有消息、删除一些消息并保
在我的当前项目中,我想在主题订阅自定义重试策略时使用过滤器/规则。
我从Azure函数中的主题中获得一条消息,并尝试将其发送到远程服务。如果服务抛出超时异常,我希望向消息中添加一个名为PostponeUntil的自定义属性,该属性具有特定的日期-时间(例如,在一个小时内),再次将其添加到主题中,然后使用订阅规则筛选出此消息,直到重试为止。是否可以用SqlFilter来做这样的事情:
var filter = new Microsoft.Azure.ServiceBus.SqlFilter("GETDATE() = PostponedUntilDateTime");
如果没有,