azureservicebus相关内容
我们在项目中使用服务总线队列.当管理员选择清除队列时,我们需要一个从队列中删除所有消息的功能.我在网上搜索,但找不到在 QueueClient 类中执行此操作的任何函数. 我是否必须将所有消息一一弹出,然后将它们标记为完成以清除队列,还是有更好的方法? QueueClient queueClient = _messagingFactory.CreateQueueClient(queueNa
..
我在 Azure 上使用会话队列,当我在队列中推送一些数据时,我编写了一个 Azure 函数来触发. 请注意,我创建了基于状态/会话的队列. 问题是当我将数据推送到队列时,我得到了类似的错误 函数“xxx"的监听器无法启动.Microsoft.ServiceBus:对于需要的实体来说是不可能的创建非会话消息接收器的会话 所以我的问题是我不能在会话中使用队列/主题的功能吗?
..
我将 Azure Functions V2 与使用 C# Functions SDK 1.0.23 的服务总线触发器一起使用.我正在使用以下方法从 KeyVault 获取机密并在触发器的设置中使用它们:如何从 Key Vault 自动映射 Azure Functions 机密 该函数,特别是当它有一段时间没有做任何事情时,当订阅上有消息时不会触发.如果我然后转到门户并手动执行(是的,该特定执
..
试图确定窥视锁在服务总线中的工作方式时,我感到有些困惑.特别是我将 Microsoft.Azure.ServiceBus 与 Azure Functions 和 ServiceBusTrigger 一起使用. 据我所知,消息被锁定的时间是在队列本身上设置的,默认为 30 秒,尽管它可以设置为最长 5 分钟. 当从队列中窥视消息时,此锁将启动. 然后在 Extensions:Ser
..
我有一个由 Azure 服务总线队列触发的 Azure Function - Azure Function App 托管在消费计划中. 队列中出现新消息时,最多需要多长时间才能唤醒 Azure Function?(假设过去 20 分钟内没有消息). 它是否在任何地方指定?我在 文档 中发现: 对于非 HTTP 触发器,新实例最多每 30 秒分配一次. 这是否意味着我无法在
..
..
我在 Azure 中创建了一个 ServiceBus 命名空间,以及一个主题和一个订阅.我还有一个简单的 Azure 版本 1 函数,它在 ServiceBus 中触发接收到的主题,如下所示: [FunctionName("MyServiceBusTriggerFunction")]public static void Run([ServiceBusTrigger("myTopic", "myS
..
我目前有一个使用 ServiceBusTrigger 绑定的天蓝色函数 [ServiceBusTrigger("%TopicName%", "%SubscripionName%", Connection = "MyConnection")]字符串 catclogueEventMsgs、ILogger 日志、ExecutionContext 上下文) 使用这个 local.settings.j
..
我有两个服务总线队列和 Azure 服务总线队列触发器. 该函数从队列中读取 1000 条消息并将它们转发给另一个(用于测试)发布到 Azure(计划消费)时,即使队列中只有 1000 条消息,我也会获得 1030 多个函数命中.我认为这与函数实例的数量有关. 问:如何对 1 个函数实例只处理 1 个唯一消息一次? [FunctionName("Function1")]公共静态异
..
我正在尝试将我的 v1 函数转换为 v2 函数,但我找不到延迟消息的替代方法. 在 Azure Functions V1 中,它是 BrokeredMesage 上的一个方法,称为 .DeferAsync().在 V2 中不再有 BrokeredMessage 而是只有一个 Microsoft.Azure.ServiceBus.Message 并且不包含 .DeferAsync().
..
首先让我解释一下我有什么.我自己有一个带有 Azure Function App 的 Azure 服务总线.服务总线设置为使用 SQL 过滤器将特定消息类型推送到特定主题.然后使用我的 Azure Function App 这些将获取最新消息然后处理它. 一个基本的例子 1:我向我的 EmailAPI 发送请求 2:EmailAPI 然后将一条新消息推送到具有“电子邮件"类型的服
..
我打开一个全新的 azure 函数项目,我的包是: Microsoft.Azure.WebJobs 3.0.0-beta4 Microsoft.Azure.WebJobs.ServiceBus 3.0.0-beta4 Microsoft.NET.Sdk.Functions 1.0.7 NETStandardLibrary 2.0.1 我使用的是servicebustrigger,
..
我有一个 Azure 函数(基于新的 C# 函数而不是旧的 .csx 函数),每当消息进入 Azure 服务总线队列时就会触发该函数.一旦函数被触发,它就会开始处理服务总线消息.它解码消息,读取一堆数据库,更新一堆其他的,等等......这有时可能需要 30 分钟以上. 由于这不是一个时间敏感的过程,30 分钟甚至 60 分钟都不是问题.问题在于,与此同时,Azure Function 似乎
..
有没有办法在本地模拟器上使用和发现 Azure 服务总线,而无需注册到真正的 Azure 服务? 我正在关注一个关于使用 Azure 服务总线的教程,但在某个时候 Namespace 和一个 Issuer Name 和 密钥是必需的.我没有这些数据,因为我没有注册到 Azure 服务并且我现在不想这样做(当我准备好开发/测试一些真实的东西时,我会得到我的试用版). 解决方案 很遗憾,
..
我们正在使用 .Net 框架 4.6.x,并正在寻找一种从 azure.management sdk 创建 azure 服务总线命名空间的方法.我们在使用 C# 在 .Net 中以编程方式实现时遇到问题,任何参考或直接文档都会有所帮助.msdn 上的文档似乎使用了旧的 REST api,我们现在需要升级,因为 windows 已经做了同样的事情.任何不在物理门户中创建服务总线或使用 REST ap
..
我使用的是 Window Server Service Bus 1.1.我能够使用以下基地址从 Window Server Service Bus 生成 OAuth 令牌 string baseAddressHttp = "https://" + ServerName + ":9355/" + Namespace + "/$STS/OAuth/"; 对于用于向队列发送消息的 Window A
..
我知道有一种方法可以确定 Azure 队列(存储帐户)中的消息数量(或近似数量);但是,有没有办法查询 Azure Service Bus 队列中待处理消息的数量? 解决方案 var nsmgr = Microsoft.ServiceBus.NamespaceManager.CreateFromConnectionString(connectionString);长计数 = nsmgr.G
..
我有一个前段时间写的客户端,它使用旧库,并在接收消息时调用 GetBody() 来读取正文. 现在我有了新客户端 Microsoft.Azure.ServiceBus(发送消息),据我所知,它总是使用 Stream. 所以旧客户端只是因为它期望字符串主体类型而崩溃.我找到了很多关于相反场景(新读者,旧作者)的信息,但无法弄清楚如何让新客户端以所需格式发送数据. 相关链接:
..
一直在寻找具有发布/订阅功能的消息总线.发现AWS SQS不支持FIFO,只好放弃.使用 Azure 服务总线,发现队列确实支持 FIFO,但似乎主题不支持 FIFO.主题正是我们所需要的,它们的发布到多订阅模型 :( 这只是我缺少的设置吗?我尝试从我的 C# 客户端发送 100 条消息,但订阅者以错误的顺序收到消息.任何提示将不胜感激.谢谢! 解决方案 您应该能够通过将 Suppo
..
我正在使用 EventProcessorHost 和 IEventProcessor 类(称为:MyEventProcessor)从 EventHub 接收事件.我通过在两台服务器上运行我的 EPH 将其扩展到两台服务器,并让它们使用相同的 ConsumerGroup 连接到集线器,但使用唯一的主机名(使用机器名称). 问题是:在白天/黑夜的随机时间,应用程序记录: 异常信息:异常类型:R
..