azure-servicebus-topics相关内容

如何清除用于服务总线主题订阅的消息

只是想知道从服务总线主题的订阅中清除消息的最佳方法(即使通过Portal,Powershell或C#). 想象一下,我们有一个包含4个订阅的主题,而我们只想清除其中一个订阅中的消息. 我觉得唯一的方法可能是在while循环中阅读消息,但是希望有更好的东西. 更新: 除了使用代码外,您还可以按照答案中的建议使用服务器资源管理器-右键单击订阅并清除消息: 解决方案 您当 ..
发布时间:2020-09-17 19:34:00 C#/.NET

在本地使用Azure Service Bus

我正在使用Azure Service Bus主题和订阅.它被用来在整个应用程序中发送控制消息.消息侦听器(订阅者)以工作角色运行,他们在提取消息并处理请求.即使有多个侦听器同时运行,总线中的每个消息也只能被提取一次. 使用服务总线没有问题;但是,在本地调试/测试应用程序时,我们会遇到一些问题.我们有2条服务总线,一条用于云计算,另一条用于本地调试.现在,如果有多个人同时调试应用程序,则该消息 ..

Azure服务总线实体吞吐量

根据本文: https://azure.microsoft.com/en ...,服务总线每个队列/主题每秒最多可处理2000条消息.本文: https://azure.microsoft.com/en ...说“这意味着分区队列或主题的整体吞吐量不再受单个消息代理或消息传递存储的性能的限制."如果我们创建分区队列/主题,我相信它会在内部创建16个分区.我的问题是:分区队列/主题的吞吐量是否线性增 ..

Azure服务总线-如何向消息添加元数据

我将.net核心Web应用程序用作发布者,并将.net核心控制台应用程序用作订阅者. 我能够使用托管门户在Azure门户中成功设置这两个系统之间的消息传递. 我的问题是我需要将元数据添加到正在发送的消息中.我该怎么办? 下面是我的发布者代码: string data = JsonConvert.SerializeObject(payloadEvents); Message mes ..
发布时间:2020-09-17 19:20:22 其他开发

使用azure逻辑应用程序以字符串形式将消息发送到azure服务总线

我正在使用逻辑应用程序操作“发送消息"将消息发送到服务总线主题.在控制台应用程序中读取时,如果执行此操作: SubscriptionClient subClient = SubscriptionClient.CreateFromConnectionString(connstr, topicName, subscriptionName); OnMessageOptions options = ..

有没有一种方法可以延迟Azure功能中对服务总线消息的重试?

我有一个函数可以从订阅中提取消息,并将其转发到HTTP端点.如果端点不可用,则会引发异常.发生这种情况时,我想将特定消息的下一次尝试延迟一定的时间,例如15分钟.到目前为止,我发现了以下解决方案: 捕获异常,睡觉,然后抛出.这是一个糟糕的解决方案,因为我需要为处于睡眠状态的CPU使用率付费,这会影响该函数的吞吐量. 捕获异常,克隆消息,设置ScheduledEnqueueTimeUtc属性 ..

使用会话ID将消息添加到IAsyncCollector主题输出中

当前是否可以将消息从Azure函数推送到IAsyncCollector主题输出,还可以设置会话ID?我的话题确实是关于FIFO排序的,所以我们必须设置会话.因此,我们曾想过只将Guid设置为唯一的会话ID.我知道如何通过此输出将消息推送到我的主题,但是由于我们没有明确设置会话ID,因此当然会出错.当我们将其发送到IAsyncCollector时,是否可以在代码中的某个位置进行设置? 这就是我 ..

哪种消息传递服务可与Azure功能扇出模式一起使用而无扇出功能?

我们是Azure消息服务和功能的新手,我们了解了不同消息服务的基本概念,例如存储队列,服务总线队列,服务总线主题和事件中心,我们还阅读了扇出模式由Microsoft提供,但是其工作方式更像是扇出,然后是扇回,这意味着在扇出过程中,当前功能仍会保留在那里,直到所有资源扇回为止. 一种简单的情况是,我们将对象保存在 azure函数启动器中,并成功保存到存储中后,我们想向实施的3个不同的目的地/消 ..

设计您的Azure Service Bus主题-您是否应该赞成使用更多主题或更多筛选器?

我正处于设计高级结构的早期阶段,该结构将如何将我们的两个企业应用程序广播到Azure Service Bus中的主题.我是该技术的新手,在对文档进行初步阅读之后,我很想使用一种简单的解决方案:对于要广播的每种不同事件类型,请使用单独的主题. 我更喜欢这种解决方案(而不是使用过滤器),因为它提供了对共享访问密钥的最精细控制,消息吞吐量最小,并且还允许按主题轻松添加删除订阅. 另一种解决方 ..

在Azure Service Bus中获取消息统计信息

我正在编写一个实用程序来监视我们的Azure Service Bus主题和订阅. 我可以获取主题详细信息,例如名称,排队的邮件数和空字母邮件数,但是我想获取已处理的邮件数. 这是我正在使用的代码: var sub = namespaceManager.GetSubscription(topicPath, subscriptionName); var name = sub.Nam ..

Azure主题并通过MQTT发送消息

是否可以通过mqtt将消息发送给天蓝色的任何自定义主题.到目前为止,我发现的所有示例都适用于标准主题 'devices/' + hubName + '/messages/events/' 'devices/' + hubName + '/messages/devicebound/#' 顺便说一句,尽管连接成功,我还是尝试通过MQTT.fx应用程序发送/订阅上面的主题/订阅,并且从未收到消 ..
发布时间:2020-05-12 20:18:36 其他开发

如何将Rebus配置为具有基于处理程序类型的主题

我正在使用Rebus,我想介绍 CQRS旅程中所述的内容在"避免多次处理事件"中,但我无法弄清楚. 我将Rebus配置为将SQL Server用于 Transport ,将MongoDB用于 Subscriptions 和 Sagas . 路由配置为 TypeBased ,并将所有命令处理程序的类型映射到 Transport 中配置的队列. var bus = Configure.W ..

Azure Service Bus主题分区

我正在尝试向创建了同时选中启用重复检测和启用分区选项的主题创建消息.我没有在BrokeredMessage实例上设置SessionId和PartitionKey属性.根据此: 如果队列或主题具有 QueueDescription.RequiresDuplicateDetection属性设置为true和 BrokeredMessage.SessionId或BrokeredMessage.Par ..
发布时间:2020-05-09 01:36:10 C#/.NET

如何从Azure服务总线主题订阅中接收JSON对象

我对实施Azure Service Bus接收来自主题订阅的消息有疑问. 我们在组织中使用多个应用程序,我们需要在一个子系统与其他子系统之间共享数据,以便使用Azure Service Bus.在这里,我的一个应用程序经常向服务总线主题订阅发送一条消息.每当在我们的应用程序中创建新的用户帐户时,每次用户配置文件数据都会将数据发送到相应的服务总线主题订阅.我在下面提到了必须接收JSON对象的快照.该 ..
发布时间:2019-11-26 23:35:35 JavaScript

在哪里登陆已发送的Azure服务总线主题订阅消息/送货上门吗?

在徒劳搜索...我在哪里可以看到日志/列表,其中的Azure服务总线的消息(内容?)已发送到给定主题+认购,哪些已经交付后?我必须激活一个特殊的功能?如果是这样,哪个?新的或“经典”Azure管理门户? 谢谢! 解决方案 您不能这样做,在任何门户网站我的知识。您可以使用类似服务总线资源管理器中的http://blogs.msdn.com/b/paolos/archive/2015/03/ ..
发布时间:2016-07-29 18:05:14 云存储

使用Azure的ARM模板来创建服务总线主题订阅与SQL过滤?

我已经能够找出创建/蔚蓝色的ARM模板如何建立一个管理的Azure服务总线命名空间,主题和订阅接收所有邮件。但是,微软文档极度缺乏仍然在ARM Tempates,我无法弄清楚如何定义一个名为sqlfilter模板内的订阅,您可以管理使用.NET SDK。 有谁知道如何在SQL过滤器的ARM模板中添加一个服务总线主题订阅? 下面是对ARM模板我创建的服务总线主题及认购不SQL过滤链接: ..
发布时间:2016-07-29 17:18:02 云存储