首页 文章
  • 1 votes
     answers
     views

    Azure Service Bus和Azure功能队列触发器

    我有一个问题是在.NET核心2.0中使用 Queue Trigger 创建 Azure Function . 我想要什么 在 microservice 体系结构中,当在队列中创建用于创建用户的新消息时,服务必须接收此消息并基于其中的信息在数据库中创建用户 . 问题 在Visual Studio 2017中,我在 Azure Function 下创建了一个新项目 . 从 New Template...
  • 3 votes
     answers
     views

    从天蓝色功能发送天蓝色服务总线中的完整代理消息

    我面临的问题是在javascript中用azure函数向azure服务总线输出发送完整的代理消息 . 该文档仅显示一个简单的正文消息https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-service-bus,没有任何customerProperties . 到目前为止,我尝试创建一个完整的代理消息失败了...
  • 0 votes
     answers
     views

    使用Azure功能处理Azure Service Bus Queue消息

    因此,我们希望在我们的应用程序中卸载一些处理以提供更好的用户体验,同时仍然完成这些繁重的任务并找到了我们的Azure Service Bus Queues . 我理解如何将数据推送到队列和消息队列背后的基本思想,但我正在努力理解的是当它们进入时如何处理它们 . 在考虑它时听起来应该有一些方法来实现和Azure每当有消息进入时都会监听的功能,但如果没有持续的轮询,我该怎么做呢?我知道您可以使用OnM...
  • 0 votes
     answers
     views

    Azure功能与服务总线:无法“完成”和访问代理消息的属性

    这是我在控制台应用程序中的工作代码: Writer (working code): static void Main(string[] args) { Console.WriteLine("Starting.."); string connectionString = CloudConfigurationManager.GetSett...
  • 3 votes
     answers
     views

    Azure服务总线Azure功能触发并获取所有消息

    我有一个队列,其中放入了大量高频数据 . 我有一个azure函数,它会在新消息写入它时触发并将消息写入Azure sql数据库 . 我的问题是有太多的消息需要写,所以我想要做的就是“累积”消息,然后将它们全部写入数据库 . 我没有在Azure功能服务总线集成中看到任何类型的功能来获取所有(或x)消息并处理它们 . 这样的事情有可能吗? 任何帮助表示赞赏 .
  • 0 votes
     answers
     views

    Azure功能中接收服务总线消息

    我创建了一个ServicesBus队列并开始发送数千条消息 await queueClient.SendBatchAsync(brokeredMessagesList); 另一方面我创建了azure函数来接收来自ServicesBus队列的消息 . 这是我的代码 public static async Task RunAsync([ServiceBusTrigger("batch-in...
  • 1 votes
     answers
     views

    如何从Azure功能向Azure Service Bus发送消息?

    我正在玩Azure功能并尝试设置管道和过滤器(模式)的复杂构造 . 我正在使用Azure功能 . 我的出发点是HTTP触发的Azure功能 . 这会从请求正文中收集一些JSON,并将此消息传递给Azure Service Bus . 我必须在这里遗漏一些东西(我之前在使用控制台应用程序的RabbitMQ中完成了这个)但是如何从HTTP触发的Azure功能向服务总线发布消息 . 我找到了几个关于配置...
  • 0 votes
     answers
     views

    从Azure功能向Azure Service Bus队列写入消息

    我正在尝试从azure函数向azure消息队列添加消息 . 为此,我正在关注这篇文章,它让我添加对Microsoft.Azure.ServiceBus的引用 . https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-dotnet-get-started-with-queues 尝试添加此引用时,Visual...
  • 0 votes
     answers
     views

    使用azure功能服务总线触发器读取SB消息

    我刚刚使用服务总线触发器创建了一个简单的azure函数 . 我正在使用提供的默认示例 . 我可以在下面的代码中阅读messageid public static void Run(string mySbMsg, TraceWriter log) { log.Info($"C# ServiceBus topic trigger function processed message: {m...
  • 2 votes
     answers
     views

    azure功能服务总线输出消息属性

    我正在尝试使用服务总线绑定输出在JavaScript Azure功能中设置服务总线消息的元数据 . 不幸的是,看起来绑定只支持身体 . 查看文档,我看到您可以通过 context.bindingData 在服务总线触发器中访问此信息,但我没有看到任何相应的服务总线输出接口 . 有没有办法发送完整的代理消息并设置 message properties (ContentType)和 message c...
  • 2 votes
     answers
     views

    将Azure SAP或SharePoint-Connector连接到OnPremise失败

    我正在尝试将Azure连接到我们的OnPremise-SAP-Installation . 我们的目标:在LogicApp中通过SAP-Connector调用RFC . 到目前为止我们做了什么: 创建了一个Relay-ServiceBus . 在Azure Marketplace中创建了一个默认的SAP-Connector,并插入了所有必需的信息,包括ServiceBus-Connecti...
  • 3 votes
     answers
     views

    Azure函数输出服务总线绑定从计时器触发器

    我正在运行Visual Studio 2017 Preview并在本地运行功能代码,我正在使用开箱即用的Azure Function项目模板 . 我正在尝试使用定时器触发的Azure功能使用输出绑定将消息发送到服务总线队列,但看起来WebJob SDK无法将输出绑定到字符串类型 . Binding "bindings": [ { "type&quo...
  • 4 votes
     answers
     views

    如何使用自定义INameResolver配置由Service Bus触发的Azure功能?

    我希望能够控制Azure功能在运行时读取的服务总线队列或订阅的名称 . 使用WebJobs(Azure Functions基于),您可以通过实现和配置自定义 INameResolver 来执行此操作,请参阅:How to have a configuration based queue name for web job processing? 但是,对于Azure功能,我无法访问 JobHostC...
  • 0 votes
     answers
     views

    Azure服务总线获取所有队列消息

    我正在使用azure服务总线队列 . 但是我无法使用“获取所有队列消息(peek Lock)”从队列中获取所有消息:Microsoft内置了api . 有没有办法获取所有队列消息? {“$ connections”:{“value”:{“servicebus_1”:{“connectionId”:“/ subscriptions/c776fec3-6aec-4722-b099-b054c267b...
  • 0 votes
     answers
     views

    用于Python的Azure Service Bus SDK在向主题发送消息时导致读取超时

    在我的应用程序中,我根据本地事件向主题发送消息 . 这很有效,直到我遇到网络问题 . 在网络方面,我的设备正在通过一个提供互联网主/辅连接的接入点 . 主要连接是通过ADSL线路,但如果失败,则切换到LTE网络 . 发生切换时,我的设备的IP地址保持不变(因为它在本地网络上并通过DHCP分配) . 发生此切换时,我发现send命令出错 . 我收到本地活动,并尝试向服务总线发送消息 . 第一次发送导...
  • 2 votes
     answers
     views

    Python和Azure Service Bus

    我在设置从Python脚本到Azure Service Bus的连接时遇到问题 . C#中的类似代码(在Windows上)运行正常 . from azure.servicebus import * AZURE_SERVICEBUS_NAMESPACE='blablabla.servicebus.windows.net' AZURE_SERVICEBUS_ISSUER='RootManageSh...
  • 1 votes
     answers
     views

    AMQP上的ServiceBus关闭了消费者

    我们有ServiceBus和Java JMS QPID客户端0.26的本地安装 . 似乎SB中存在错误 - 它在 生产环境 者关闭连接时向消费者发送END命令 . 生产环境 者和消费者都必须在同一台机器上运行 . 首先启动侦听队列的消费者: static void consumeFromQueueForStackOverflow(Connection connection, Context co...
  • 2 votes
     answers
     views

    我可以获取异常或将消息放入死信/毒药队列吗?

    我正在使用Azure的服务总线和this tutorial中描述的带有死信(毒药)队列的Web作业SDK . 保持简单,我正在使用POCO队列消息 . 当消息处理功能失败足够多次时,消息将移动到死信队列 . 我有另一个webjob消耗死信队列通知团队出了什么问题 . 有没有办法获得消息被移入死信队列的异常/原因?例如,如果POCO消息序列化失败并因此被移动到死信队列,那么找到它的最佳方法是什么? ...
  • 23 votes
     answers
     views

    Azure WebJobs ServiceBus返回异常:在授权上下文中找到2个DNS声明

    我正在尝试使用Azure WebJob从Azure ServiceBus队列中读取消息,但它正在抛出异常: Unhandled Exception: System.InvalidOperationException: Found 2 DNS claims in authorization context. 我已经设置了名为“AzureWebJobsServiceBus”,“AzureWebJob...
  • 1 votes
     answers
     views

    在同步请求 - 响应模式中使用会话

    我试图让会话在以下架构中工作 . 多个异构工作者角色,用于监视和处理来自queue1的请求,并将其响应发送到queue2 . 一个前端Web角色,通过REST或SOAP接收来自外部的请求,将它们提交到queue1,并等待来自queue2的响应 . 收到后,响应将返回给调用者 . Web角色可以利用可扩展性并允许在负载过高时动态创建工作者角色(这就是为什么整个Ruth Goldberg机...
  • 2 votes
     answers
     views

    收听队列(事件驱动无轮询)服务总线/存储队列

    我试图找出如何监听队列中的事件(尤其是入队事件) . 假设我有一个控制台应用程序和一个服务总线队列/主题,我如何连接到队列并等待新消息? 我试图在没有 While(true) 和常量轮询的情况下实现这一点,我试图以一种非常倾听的方式做更多事情,就像一个保持连接到队列的套接字 . 我不想使用轮询的原因是我明白它会使服务器充满请求,我需要一个可以在很大负载下运行的解决方案 . 谢谢 . 我给出了问题简...
  • 3 votes
     answers
     views

    Service Bus队列令牌问题

    当我给出创建队列的密钥时,我收到此错误 System.UnauthorizedAccessException未处理Message =令牌提供程序在访问“https://sharan-sb.accesscontrol.windows.net/WRAPv0.9/”时无法提供安全令牌 . 令牌提供程序返回消息:'错误:代码:401:子代码:T0:详细信息:ACS50009:SWT令牌无效 . :Tra...
  • 0 votes
     answers
     views

    从ActiveMQ和发布到Azure Service Bus主题的消息

    我需要从ActiveMQ队列中使用JMS消息并将其发布到Azure Service Bus主题 . 我在这个项目中使用了Spring Boot,并使用Apache qpid通过AMQP协议连接Service Bus . 我面临的问题是,在发布消息到服务总线主题期间消耗来自ActiveMQ的消息后,如果由于任何原因发生异常,我无法在ActiveMQ中保留消息 . 我希望ActiveMQ保留消息,直到...
  • 1 votes
     answers
     views

    逻辑应用程序未接收消息

    我几天前发布了这个问题SMS Messaging from Azure IOT Hub 我试图实现已建议的逻辑应用程序,我的问题是逻辑应用程序没有通过服务总线接收消息,实际上没有消息到达服务总线 . 当我尝试在逻辑应用程序中运行触发器时,它会弹出一个“When_a_message_is_received_in_a_queue”弹出窗口 . 当我运行逻辑应用程序时,它表示工作流程在几分钟后超时 . ...
  • 1 votes
     answers
     views

    Azure Service Bus:队列中没有消息,只有请求

    我正在尝试使用服务总线队列作为Iot集线器 endpoints 将消息从IoT集线器路由到功能应用程序 . 我发送到IoT集线器的消息已在IoT集线器中注册,但不会路由到服务总线队列 . 当我监视服务总线队列时,我只看到成功的请求 . 我使用以下标准实现了两个路由规则: $._eventtype="meeting" 和 $body._eventtype="mee...
  • 0 votes
     answers
     views

    从ServiceBus触发的azure功能中检索IoT Hub Twin

    我们将数据从IoT设备发送到Azure IoT Hub,并尝试将某种类型的消息传递给Azure功能 . 目前,我们是通过创建Azure Service Bus endpoints 并在IoTHub中创建消息路由来实现的 . 它按预期工作,Azure功能正确接收消息 . 现在,我们想要在Azure功能中从IoT Hub获取DeviceId,以及在Device Twin中定义的标签,我完全不知道如何做...
  • 4 votes
     answers
     views

    EventHub异常:无法为当前会话或连接分配更多句柄

    我有C#控制台应用程序,通过它我经常将数据发送到事件中心 . 这个控制台应用程序基本上从SQL存储读取一些数据并开始将数据推送到事件中心 . 整个程序以无限循环/方式运行,就像在控制中一样,只要它在SQL中接收任何数据,它就从那里提取数据并开始发送到事件中心 . 但是有一刻我得到了这个错误 . “无法为当前会话或连接分配更多句柄 . 允许的最大句柄数为4999.请释放资源再试一次 . 在Micro...
  • 3 votes
     answers
     views

    了解Azure功能应用和服务总线成本

    我正在使用Azure服务总线主题和Azure功能应用程序创建Pub / Sub系统,其中功能使用ServiceBusTrigger进行修饰 . 我正在使用功能应用程序的服务总线和消费计划的标准层 . 这个概念工作正常并且可以满足我的目的,但是,我很难理解这将如何影响我的Azure成本 . 仅运行具有该属性的一个函数似乎每秒向服务总线生成一对请求 . 最后,我希望每个订阅都有相当多的订阅主题和Azu...
  • 2 votes
     answers
     views

    基于会话的服务总线与Azure功能

    我在Azure上使用会话队列,当我在队列上推送一些数据时,我写了一个Azure函数来触发 . 请注意,我已经创建了基于状态/会话的队列 . 问题是当我将数据推送到队列时,我得到了错误 函数'xxx'的侦听器无法启动 . Microsoft.ServiceBus:需要会话的实体不可能创建非会话消息接收器 所以我的问题是我无法使用带会话的队列/主题功能吗?
  • 0 votes
     answers
     views

    Azure服务总线队列设计

    我的应用程序中的每个用户都有gmail帐户 .应用程序需要与传入的电子邮件同步 .对于每1分钟的每个用户,应用程序应该询问gmail服务器是否有新内容 . 99%的时间没有什么是新的 . 据我所知,gmail不提供web-hooks 为了减少来自我的服务器,特别是来自DB的负载,我希望以下列方式使用服务总线队列 . queue properties: 查询方法:PEEK_AND_LOCK锁定时间...

热门问题