azureservicebus

    0热度

    1回答

    我正在使用azure服务总线主题机制。此外,我已将 发送给主题的消息,并希望通过编程检查是否将消息发送到主题。 代码: message.Properties.Add("Name", "Test"); message.Properties.Add("Country", "India"); message.Properties.Add("JsonData",json);

    0热度

    1回答

    我有一个具有将数据陷入到服务总线队列中的自定义终端节点的IoT集线器。因为我通过物联网集线器&服务总线队列中的自定义终端实现了自定义路由。当我尝试创建Azure流分析(ASA)作业时,Azure门户中的输入面板不会列出自定义终结点,而只会列出仅用于默认消息终结点的使用者组。 有没有办法让ASA从物联网集线器中的服务总线队列或自定义终端选择消息,因此我不需要修改我已有的自定义路由。 感谢并期待着您的

    0热度

    1回答

    我正在尝试迁移到服务结构现有解决方案。其中一部分是监听队列的工作人员数量。例如,我有一些队列: Task1_Queue, Task2_Queue ... TaskN_Queue 对于每个队列都有一些逻辑处理它们的消息,比方说工作人员。他们做不同的任务,如生成巨大的报告文件,并上传到Azure Storage或在数据库中做小更新。 问题是如何设计服务,以便具有良好的可扩展性的工作人员。我的想法是

    0热度

    1回答

    我正尝试使用REST API更新Azure服务总线订阅。 当我在请求XML中包含"ForwardTo"属性时,出现Service Bus中的Authorization Failure (401)错误。 这里是我的请求XML的样子: <?xml version="1.0" encoding="utf-8" standalone="yes"?> <entry xmlns="http://ww

    1热度

    1回答

    我已经使用Azure IoT Hub设置了到服务总线队列的路由。我遵循这个教程来使它工作:https://azure.microsoft.com/en-gb/blog/how-to-use-azure-functions-with-iot-hub-message-routing/。 在我的函数中我试图获取DeviceId,以便我可以验证消息来自的设备。我有一个名为message的字符串参数,它接收

    0热度

    1回答

    我的产品有一个长时间的工作流程,需要在后台完成。我们有一个UI应用程序和部署在Azure应用程序服务中的单独的宁静服务。 我们希望为我们的业务功能实现这个工作流程(某些任务可以并行完成),这些工作在链式安宁调用中很难处理。所以看起来服务巴士使用主题是要走的路。我想我们会在服务总线上放置“事件”,必要的消费者会处理它们。我不确定消费者应用程序是如何订阅/监视主题的,以及这个应用程序将被部署在什么上。

    0热度

    1回答

    将规则添加到SubscriptionClient时,如果我不删除所有空白,则会出现语法错误。我读过的大量例子都没有这样做。任何想法为什么? // This works (whitespace stripped from expression) var rd= new RuleDescription("ZonesRule", new SqlFilter("Zone='All'")); subsc

    2热度

    3回答

    我在多实例Web应用程序中需要的一种非常常见的模式是使所有实例的MemoryCache无效 - 并等待确认已完成此操作。 (因为用户可能在刷新后否则突然看到在另一个实例上的旧数据) 我们可以组合使这个: AzureServicebus, 发送消息到一个主题 其他实例发回消息回复原始实例 有一个等待循环等待消息返回, 请注意有多少其他实例在杉木st地方。 可能有些超时,因为如果一个实例在两者之间崩溃

    0热度

    1回答

    我有一个多租户系统,需要保证租户对排队消息的FIFO(先进先出)处理,即每个租户都会得到自己的MaxConcurrentCalls = 1。 要在Azure中完成并且技术不固定。 我知道这可以通过为每个租户创建单独的WebJob来实现,但这限制了可伸缩性。 是否有其他方法可以实现这样的行为?

    1热度

    1回答

    我是Azure Service Bus的新手,想知道我是否可以将多个订阅者加入队列或主题?在兔子MQ中,我可以有1个发布者的多个订阅者。 我想要做的是,我正在使用CQRS,并且当事件处理时某些命令进入系统时,我想将它们推送到消息队列中。 我希望2个订户能够从该队列中获取消息,一个供我内部处理。另一个用于处理并发送到外部。