azureservicebus

    2热度

    1回答

    我有一个用Python编写的具有服务总线(主题)输出绑定的Azure函数。该函数由另一个队列触发,我们处理blobl存储中的一些文件,然后将另一个消息放入队列中。 我function.json文件看起来像这样: { "bindings": [ { "type": "serviceBus", "connection": "Omnibus_Input_Send_Serv

    0热度

    2回答

    我正在使用Azure事件中心。我打算发送活动并使用SendBatchAsync。我看到事件中心有256KB的限制(无论是单独或批量发送) 所以,如果我的数据> 256KB,什么是最佳实践来处理呢?我们是否应该单独发送消息(这将保证它是< 256KB)? 另外,如何将事件分成256KB块并发送到Event Hub? 我看了看Azure文档,看到他们推荐使用EventHubClient.CreateB

    0热度

    1回答

    是否有任何传统方法使用ASPNET.CORE Web上的Service Bus或EventHub消息?除非你开始自己的线程或长时间运行的任务,否则我似乎无法找到任何关于此的信息。

    0热度

    2回答

    我刚刚尝试升级到serviceBus的4.1.3版,现在我的SAS生成的令牌失败。我正在使用这些令牌与servicebus中的WCF中继进行连接。 我得到的错误是“超时间隔必须小于2^32-2” 令牌的肯定在版本3.4.3工作。 当我生成令牌时,我正在计算一个1970年到3000年的timeToLive。我相信这是我的问题,如果我将其设置为较低的值,我可以生成新的令牌(10天)。这对我不起作用,因

    0热度

    1回答

    因此,我们希望卸载应用程序中的某些处理以提供更好的用户体验,同时仍然完成那些繁重的任务,并且已经找到了Azure服务总线队列。 我明白如何将数据推送到队列和消息队列背后的基本思想,但我正在努力理解的是如何处理它们。在考虑它时,听起来应该有某种方式实现和Azure函数,侦听消息何时进入,但我怎么做,而不需要不断的轮询?我知道你可以使用OnMessage订阅队列,但是如何使用Azure功能呢? 比如我

    0热度

    1回答

    这里是我的情况: 我已经在我的WSO2 ESB 4.8.1配置messageStore如下: <messageStore class="org.apache.synapse.message.store.impl.jms.JmsStore" name="JMSTest"> <parameter name="java.naming.factory.initial">org.apache.qp

    -1热度

    1回答

    我有一个现有的系统,通过MassTransit发布消息到一些Azure服务总线主题名为CompanyName.SystemName.Messages.SomethingGotUpdated。如何使用Rebus配置新系统作为该特定主题的订阅者,然后将所有消息发送到相应的IHandleMessages<SomethingGotUpdated>处理程序? 我查看了文档,但无法真正弄清楚如何完成此操作。任

    0热度

    2回答

    我使用蔚蓝服务总线话题与订阅机制,并要处理这些都是死信队列中的消息。 而且我想通过处理网络湛蓝工作在C#中的消息,并送他们回queue.So我想知道这些消息是否手动或通过自动化流程处理。如果可能的话,如何通过代码手动将它们自动化?

    0热度

    1回答

    Webjob是否有可能在每个新消息之后用一小段延迟来侦听队列并消耗所有相关消息(基于消息ID或会话ID或其他内容)? 例如,三个用户编辑和更新三个时间表。两个是同一个员工。每个计划生成一个PayrollUpdated事件:1)员工100,第1周,2017年,2)员工200,第1周,2017年,3)员工100,第1周,2017年。 我想webjob收听队列并执行两个并发的webjobs,每个员工,每

    -2热度

    1回答

    是否有Python读取当前队列中所有消息的API?我发现API为.NET: https://docs.microsoft.com/en-us/dotnet/api/microsoft.servicebus.messaging.queueclient.peekbatch?view=azure-dotnet#Microsoft_ServiceBus_Messaging_QueueClient_Peek