azureservicebus相关内容

一次性清除 Azure 服务总线队列

我们在项目中使用服务总线队列.当管理员选择清除队列时,我们需要一个从队列中删除所有消息的功能.我在网上搜索,但找不到在 QueueClient 类中执行此操作的任何函数. 我是否必须将所有消息一一弹出,然后将它们标记为完成以清除队列,还是有更好的方法? QueueClient queueClient = _messagingFactory.CreateQueueClient(queueNa ..
发布时间:2022-01-21 11:55:27 C#/.NET

使用 Azure Function 的基于会话的服务总线

我在 Azure 上使用会话队列,当我在队列中推送一些数据时,我编写了一个 Azure 函数来触发. 请注意,我创建了基于状态/会话的队列. 问题是当我将数据推送到队列时,我得到了类似的错误 函数“xxx"的监听器无法启动.Microsoft.ServiceBus:对于需要的实体来说是不可能的创建非会话消息接收器的会话 所以我的问题是我不能在会话中使用队列/主题的功能吗? ..
发布时间:2022-01-17 16:39:14 其他开发

带有服务总线触发器的 v2 Azure 函数未触发

我将 Azure Functions V2 与使用 C# Functions SDK 1.0.23 的服务总线触发器一起使用.我正在使用以下方法从 KeyVault 获取机密并在触发器的设置中使用它们:如何从 Key Vault 自动映射 Azure Functions 机密 该函数,特别是当它有一段时间没有做任何事情时,当订阅上有消息时不会触发.如果我然后转到门户并手动执行(是的,该特定执 ..
发布时间:2022-01-17 16:37:48 其他开发

Azure 服务总线中的消息锁定和锁定续订如何工作?

试图确定窥视锁在服务总线中的工作方式时,我感到有些困惑.特别是我将 Microsoft.Azure.ServiceBus 与 Azure Functions 和 ServiceBusTrigger 一起使用. 据我所知,消息被锁定的时间是在队列本身上设置的,默认为 30 秒,尽管它可以设置为最长 5 分钟. 当从队列中窥视消息时,此锁将启动. 然后在 Extensions:Ser ..

《醒来》Service Bus Queue 触发 Azure Function 的时间

我有一个由 Azure 服务总线队列触发的 Azure Function - Azure Function App 托管在消费计划中. 队列中出现新消息时,最多需要多长时间才能唤醒 Azure Function?(假设过去 20 分钟内没有消息). 它是否在任何地方指定?我在 文档 中发现: 对于非 HTTP 触发器,新实例最多每 30 秒分配一次. 这是否意味着我无法在 ..
发布时间:2022-01-17 16:27:36 C#/.NET

如何在 Azure Function 中使用 Azure Managed Identity 通过触发器访问 Service Bus?

我在 Azure 中创建了一个 ServiceBus 命名空间,以及一个主题和一个订阅.我还有一个简单的 Azure 版本 1 函数,它在 ServiceBus 中触发接收到的主题,如下所示: [FunctionName("MyServiceBusTriggerFunction")]public static void Run([ServiceBusTrigger("myTopic", "myS ..

Azure Function Service Bus 触发器的触发次数多于队列中的消息

我有两个服务总线队列和 Azure 服务总线队列触发器. 该函数从队列中读取 1000 条消息并将它们转发给另一个(用于测试)发布到 Azure(计划消费)时,即使队列中只有 1000 条消息,我也会获得 1030 多个函数命中.我认为这与函数实例的数量有关. 问:如何对 1 个函数实例只处理 1 个唯一消息一次? [FunctionName("Function1")]公共静态异 ..

azure 服务总线的 Azure Function App 延迟重试

首先让我解释一下我有什么.我自己有一个带有 Azure Function App 的 Azure 服务总线.服务总线设置为使用 SQL 过滤器将特定消息类型推送到特定主题.然后使用我的 Azure Function App 这些将获取最新消息然后处理它. 一个基本的例子 1:我向我的 EmailAPI 发送请求 2:EmailAPI 然后将一条新消息推送到具有“电子邮件"类型的服 ..
发布时间:2022-01-17 16:00:11 C#/.NET

为同一服务总线队列消息多次运行的 Azure 函数

我有一个 Azure 函数(基于新的 C# 函数而不是旧的 .csx 函数),每当消息进入 Azure 服务总线队列时就会触发该函数.一旦函数被触发,它就会开始处理服务总线消息.它解码消息,读取一堆数据库,更新一堆其他的,等等......这有时可能需要 30 分钟以上. 由于这不是一个时间敏感的过程,30 分钟甚至 60 分钟都不是问题.问题在于,与此同时,Azure Function 似乎 ..
发布时间:2022-01-17 15:50:29 C#/.NET

在本地测试 Azure 服务总线,无需任何订阅或登录

有没有办法在本地模拟器上使用和发现 Azure 服务总线,而无需注册到真正的 Azure 服务? 我正在关注一个关于使用 Azure 服务总线的教程,但在某个时候 Namespace 和一个 Issuer Name 和 密钥是必需的.我没有这些数据,因为我没有注册到 Azure 服务并且我现在不想这样做(当我准备好开发/测试一些真实的东西时,我会得到我的试用版). 解决方案 很遗憾, ..
发布时间:2022-01-14 23:51:38 其他开发

有没有办法从 .Net 中创建一个 azure 服务总线命名空间?

我们正在使用 .Net 框架 4.6.x,并正在寻找一种从 azure.management sdk 创建 azure 服务总线命名空间的方法.我们在使用 C# 在 .Net 中以编程方式实现时遇到问题,任何参考或直接文档都会有所帮助.msdn 上的文档似乎使用了旧的 REST api,我们现在需要升级,因为 windows 已经做了同样的事情.任何不在物理门户中创建服务总线或使用 REST ap ..
发布时间:2021-12-06 19:01:36 C#/.NET

使用 BodyType - String 由旧库 (Microsoft.ServiceBus.Messaging) 读取的新库 (Microsoft.Azure.ServiceBus) 发送消息

我有一个前段时间写的客户端,它使用旧库,并在接收消息时调用 GetBody() 来读取正文. 现在我有了新客户端 Microsoft.Azure.ServiceBus(发送消息),据我所知,它总是使用 Stream. 所以旧客户端只是因为它期望字符串主体类型而崩溃.我找到了很多关于相反场景(新读者,旧作者)的信息,但无法弄清楚如何让新客户端以所需格式发送数据. 相关链接: ..
发布时间:2021-12-06 18:33:37 C#/.NET

如何使用 Azure 服务总线主题完成 FIFO

一直在寻找具有发布/订阅功能的消息总线.发现AWS SQS不支持FIFO,只好放弃.使用 Azure 服务总线,发现队列确实支持 FIFO,但似乎主题不支持 FIFO.主题正是我们所需要的,它们的发布到多订阅模型 :( 这只是我缺少的设置吗?我尝试从我的 C# 客户端发送 100 条消息,但订阅者以错误的顺序收到消息.任何提示将不胜感激.谢谢! 解决方案 您应该能够通过将 Suppo ..
发布时间:2021-12-06 18:33:21 C#/.NET

是什么导致 Azure 事件中心 ReceiverDisconnectedException/LeaseLostException?

我正在使用 EventProcessorHost 和 IEventProcessor 类(称为:MyEventProcessor)从 EventHub 接收事件.我通过在两台服务器上运行我的 EPH 将其扩展到两台服务器,并让它们使用相同的 ConsumerGroup 连接到集线器,但使用唯一的主机名(使用机器名称). 问题是:在白天/黑夜的随机时间,应用程序记录: 异常信息:异常类型:R ..
发布时间:2021-12-06 18:04:43 C#/.NET