服务交换矩阵中的事件中心使用者
是指在云计算领域中使用事件中心服务的用户或组织。事件中心是一种分布式消息传递服务，用于在不同的应用程序和服务之间进行异步通信和事件驱动的架构。它可以帮助开发人员构建高可扩展、松耦合的应用程序，并实现实时数据处理和事件驱动的架构。
事件中心的使用者可以是开发人员、企业、组织或任何需要在应用程序和服务之间进行异步通信的实体。他们可以使用事件中心来发布和订阅事件，以实现实时数据传输、消息通知、日志记录、监控和分析等功能。
事件中心的优势包括：
- 异步通信：事件中心支持异步通信模式，可以实现高吞吐量和低延迟的数据传输，提高系统的性能和可伸缩性。
- 松耦合：通过使用事件中心，应用程序和服务之间可以解耦，降低它们之间的依赖性，使系统更加灵活和可维护。
- 实时数据处理：事件中心可以实时传输和处理数据，使应用程序能够及时响应事件和数据变化。
- 可靠性：事件中心提供可靠的消息传递机制，确保消息的可靠性和一致性。
事件中心的应用场景包括：
- 实时数据处理：事件中心可以用于处理实时数据流，例如实时分析、实时监控和实时报警等。
- 异步通信：事件中心可以用于应用程序和服务之间的异步通信，例如发布/订阅模式、消息队列等。
- 日志记录和审计：事件中心可以用于记录和审计系统中的事件和操作日志。
- 分布式系统集成：事件中心可以用于不同的分布式系统之间的集成和通信。
腾讯云提供的相关产品是腾讯云消息队列 CMQ，它是一种高可靠、高可用的消息队列服务，可以满足事件中心的需求。您可以通过以下链接了解更多关于腾讯云消息队列 CMQ 的信息：https://cloud.tencent.com/product/cmq
相关·内容
我在蔚蓝活动中心工作。我有点怀疑。
Azure事件中心接收器中的分区Id是什么？此Id与Azure事件中心发布服务器中的分区键相同吗？
什么是抵消？，它在蓝色事件中心消费者的用途是什么？
我可以使用使用者组来使用消息吗？
我可以用单个接收器来使用这个消息吗？
blob在事件中心消费者中的用途是什么？我只想查看我发送的信息。
浏览 4提问于2014-12-19得票数 3
1回答
我是Azure事件中心的新手，我很难理解分区。
我有以下情况：
1个事件中心名称空间
1个实际事件中心
事件中心中的2个分区
2消费者团体
1个事件生产者
2个事件消费者，每个消费者组1个
事件生成器向事件中心发送10个事件。事件通过循环机制被分发到分区。所以事件中心看起来是这样的：
Partition 1: [0] [2] [5] [6] [8]
Partition 2: [1] [3] [4] [7] [9]
当事件使用者开始阅读时，每个消费者最终只会看到事件的一部分，如下所示：
Consumer 1: Gets ev
浏览 4提问于2021-07-19得票数 1
回答已采纳
1回答
我计划使用rabbitmq联合插件将消息从主数据中心复制到备用数据中心，因此我不能使用集群镜像队列。是否可以将消息删除复制到自动同步队列？
浏览 2提问于2013-09-02得票数 0
1回答
我正在实现一个azure事件中心订阅服务器，它可以成功地连接，但它没有在事件中心命名空间中接收特定事件中心的消息。但是它可以像预期的那样工作在同一个名称空间中的另一个事件中心。日志中没有错误。有没有办法找出问题的根源？
我能够成功地发布具有相同配置的消息。
发布服务器和订阅服务器在同一台计算机上运行。
我已经在Dapr中实现了发布服务器和订阅服务器。
在Dapr中，发行者和订阅者日志都是完全相同的，所以我认为这是存储帐户的一个问题。
添加更多信息：
我已经用不同的存储帐户尝试了我的应用程序，它正在按预期工作。那么问题是什么呢？我该怎么解决呢？我想用我的旧存储账户工作。
浏览 3提问于2021-12-15得票数 1
回答已采纳
我有以下设想：
事件中心(EH1)配置为7天的保留策略。
生产者向EH1发布事件。
来自EH1的事件被从流分析(SA)路由到服务总线(在超过1小时的时间窗口执行某些计算之后)，服务总线获得原始事件(作为消息)以及摘要计算。
让我们说，超过24小时周期的第一天，制片人发布100万起事件的EH1。
SA启动并路由原始事件以及总结计算(超过1小时)到服务总线。
假设在第一天之后，在接下来的15天内没有任何事件被推送到EH1。
问题：
100万个原始事件(从第一天开始)将在EH1停留多长时间？
那一百万个原始事件(从第一天开始)会在第二天(第一小时之后)一直持续
浏览 3提问于2020-09-07得票数 1
回答已采纳
也许是一个相当简单的问题，但我做了一些搜索后还是找不到答案。 在我向Azure事件中心发送了一个事件(通过Java代码)之后，我如何在Azure门户中检查我发送的事件？(这样我就可以检查事件内容的头部和正文以进行验证)。 在Azure门户中，在我点击事件中心之后，有一个指标来显示传入的请求，但这只显示了计数，但我想检查接收到的单个事件。
浏览 44提问于2021-10-08得票数 0
我的理解是，Azure IoT集线器是建立在Azure事件集线器技术之上的，当创建IoT集线器时，就会在引擎盖下创建事件集线器。我创建了一个IoT集线器，并编写了一些C#代码来向它发送消息，并从中读取消息(使用C# EventHubClient库)。
在门户中，当我查看创建的所有事件集线器时，我没有看到任何事件中心(当然，我看到我创建的IoT集线器是一个不同的对象)。如果IoT中心确实创建了一个事件中心，为什么我看不到IoT中心应该创建的底层事件中心呢？
浏览 0提问于2018-02-21得票数 0
回答已采纳
我刚刚开始学习蔚蓝事件中心，并且正在学习本教程()，但是在阅读完文档之后，有些事情我还是不明白。
这篇文章有以下几段，我的问题是
它说的是"bob容器“，它是关于什么的，是否有必要有一个使用事件中心的"bob容器”？
什么是检查指向和分区，是否有必要拥有它使用事件中心？
在这个快速启动中，您使用Azure存储(特别是Blob存储)作为检查点存储。检查点是事件处理器在分区内标记或提交上一次成功处理事件的位置的过程。标记检查点通常在处理事件的函数中完成。
浏览 1提问于2021-02-06得票数 0
回答已采纳
1回答
我想用Db事务将事件发送到Microsoft事件中心：
解释：
用户命中订单创建的端点。
OrderService接受该命令，并将该订单放入数据库。
现在，Order服务希望使用事件中心将该orderId作为事件发送到另一个服务。
如何在步骤2和步骤3中实现事务性行为？
我知道这些解决方案：
发件箱模式:我在另一个表中放置了带有订单创建事务的消息。还有一个cron/调度程序，它从表中获取消息并标记它们的传递。下一次，cron将只接收未传递的消息。
使用数据库审核日志和库。库将将数据库表绑定到事件中心。然后，在每个更新库中，将该更改发送到事件中心。
我想知道事
浏览 18提问于2020-05-17得票数 0
除了Azure服务总线使用主题和Azure事件集线器是基于事件- Azure事件中心和Azure服务总线之间有什么根本区别吗？
对我来说，事件和消息之间没有真正的区别，因为两者只是一种不同类型的Json。
浏览 1提问于2021-01-16得票数 0
回答已采纳
3回答
谁能找出什么是消费者集团在Azure事件中心。那它有什么用呢？我已经冲浪了很多网站，但我无法得到一个明确的答案。
浏览 0提问于2019-01-27得票数 11
回答已采纳
下面是在ASP.net Core6.0API中开发的一个示例POC，它使用MassTransit和RabbitMQ来模拟使用MassTransit使用者的简单发布/订阅。然而，当代码被执行时，它会在RabbitMQ中创建2个交换和1个队列。
Program.cs
builder.Services.AddMassTransit(msConfig =>
{
msConfig.AddConsumers(Assembly.GetEntryAssembly());
msConfig.UsingRabbitMq((hostcontext, cfg) =>
{
浏览 11提问于2022-09-15得票数 0
我正在构建一个基于微服务的应用程序，其中包含两个通过RabbitMQ代理进行通信的微服务。每当创建、更新或删除图书时，都会发布一个事件。从第一个微服务发布可以正常工作，但在另一个微服务中没有消耗任何内容。虽然队列已启动并正在运行，但没有任何内容被放入队列。我在使用Visual Studio2019的.Net应用程序中使用MassTransit和RabbitMQ。以下是我在Startup.cs中的配置代码 services.AddMassTransit(x =>
{
x.AddConsumer<BookCreationConsumer>
浏览 7提问于2021-09-03得票数 1
回答已采纳
这是一个场景-有多个应用服务器。浏览器可以通过websocket连接到任何应用服务器。
应用服务器(消费者)都在监听特定队列。一旦接收到web套接字连接，特定的应用服务器就会将队列与路由密钥{userId}绑定到直接交换。
我希望仅由发生绑定的特定应用服务器接收发送到具有路由键{userId}的直接交换的消息。
在这种情况下，直接交换是正确的交换吗？还是应该使用其他类型的交换？
当websocket出现时，我使用spring创建动态绑定。
// create the RabbitMq queue and bind to it
String routingKey = MessageConstan
浏览 3提问于2016-03-03得票数 4
回答已采纳
1回答
我在用：
Azure platform为了运行一些微服务体系结构，solution.microservices正在使用Azure-EventHub在特殊的cases.Kubernetes中与两个集群进行通信(主、secondary)per应用程序名称空间)，每个集群运行一个事件侦听器荚，以供使用。
最后一点与我当前的问题相关:负载平衡器将在主集群和次集群之间共享通信量。这意味着每个应用程序同时运行2个事件监听器。因此，他们只是对事件做出反应，但有时他们使用来自事件中心的相同事件，这会导致一些重复的通知邮件。
最后，我的问题是:我如何避免在同一时间两次阅读同一事件？我认为事件中心指数总是在增加
浏览 4提问于2020-07-08得票数 1
回答已采纳
1回答
我正在开发一个Qt5服务器应用程序，并使用QAMQP库。我想做的是：
当用户发生变化时，另一台服务器应该发送消息。
我的服务器分布在多台机器之间，每台机器都有多个进程，需要将这些更新通知服务器。
问题是，我不确定我应该建立什么样的架构。我只知道，每当某些用户发生更改时，服务器需要向RabbitMQ代理发送一条消息，而我对该特定用户的更新感兴趣的所有进程都应该得到该消息。但是，我应该为每个进程创建一个队列，并为每个用户绑定一个单独的交换吗？或者在每个进程中为每个用户创建一个单独的队列，并以某种方式绑定到某个交换中。Fanout交易所浮现在脑海中，每个进程都有一个队列，我只是不确定
浏览 2提问于2014-01-25得票数 0
回答已采纳
当使用事件集线器时，我可以监视传出消息的数量(名称空间:microsoft.ventub/命名空间，metricID: OutgoingMessages)。
是否也可以监视IoTHub内建事件中心的传出消息数量？
有路由:消息传递到消息/事件(命名空间:metricID.设备/iothubs，metricID: d2c.endpoints.egress.builtIn.events)，但这只显示发送到事件中心的消息数量，而不显示从内置事件中心消耗了多少消息。
浏览 4提问于2022-02-10得票数 0
我有一个(ASA)的工作，我用它将事件从我的物联网集线器路由到一些功能应用程序和blob存储。最近，在我的ASA作业中选择了我的物联网集线器时，我在输入预览中得到了以下错误：
与EventHub通信时遇到的错误:超过了使用者组中每个分区允许的最大接收方数，即5.连接接收器列表- uids列表
我最初认为这是因为ASA中有太多的输出，因为我有6，但是我把输出减少到了5，仍然得到了错误。然后，经过一些研究，问题似乎是在物联网中心/事件集线器方面，太多的接收者试图访问同一个消费者群体。我从那里得到了这个假设
EventHubReceiverQuotaExceeded原因:流分析无法连接到分
浏览 6提问于2022-11-03得票数 0
回答已采纳
我使用RabbitMQ来协调服务集合之间的事件，如下所示：
用户管理器
当希望从单独的服务收集用户数据时，就会发出user.collect。
侦听由单独服务发出的user.collected
用户收集器
当user.collect应该收集一些用户数据时，侦听它，并且
收集数据时会发出user.collected。
还有其他的服务可以监听类似的事件
user.created，
user.updated，
user.deleted
此外，还有一些服务可以侦听更多的一般事件，例如
#.created
user.#
诸若此类。
所以我
浏览 1提问于2018-10-22得票数 1
回答已采纳
技术栈
.Net 4.6.1
二郎18.3
语言: C# 6
NServiceBus 6
RabbitMQ 3.6.3
Windows 7
Context：我们试图在RabbitMQ传输上实现一个在NServiceBus中具有智能订阅的哑事件发布服务器。
所有感兴趣的接收者都订阅一个事件。
发布者将事件发布到事件通道。
所有订阅者都会收到事件的副本。
请注意，我没有说每种类型的订阅者都收到消息的副本。如果有多个服务实例正在运行，并且它们都具有对某个事件的活动订阅，则订阅服务的每个实例都应该得到消息的副本。
然而，NServiceBus的发
浏览 2提问于2017-01-10得票数 0
2回答
我希望能为我的场景选择最合适的Azure服务--我刚刚开始使用Azure服务，我的知识非常有限。
我有来自多个来源和不同形状的数据，进入事件中心。我需要订阅事件集线器中的事件，并根据它们的格式处理它们，并最终将它们保存到SQL数据库中。所有组件--事件使用者，SQL数据库--都需要托管在云中。
我将如何在“面向蓝色的体系结构”中实现这一点？
在离云应用程序中，我会让竞争的消费者订阅事件中心。它们将是一些控制台应用程序或Windows服务，每个应用程序都将异步处理这些事件(由于事件处理是幂等的)，这进一步简化了。
理想情况下，上述用户的Azure等价物将自动伸缩，因此我不想使用托管控制台应用程序
浏览 2提问于2016-08-08得票数 1
回答已采纳
我正在学习Azure事件中心和kafka事件中心的概念。
一个消费者群体可以有一个或更多的消费者。来自消费者组的一个或多个使用者可以读取一个或多个分区。
消费者组的消费者应该从1分区中进行理想的消费。
我试图理解在什么情况下，来自同一个使用者组的多个使用者从同一个分区读取信息是有意义的？
浏览 5提问于2022-11-06得票数 0
目前，我有以下情况：
publisher.js：
var queue_connection = new amqp.createConnection( { host: config.rabbitmq.host, port: config.rabbitmq.port } );
queue_connection.on( 'ready', function () {
var exchange = queue_connection.exchange( 'http_worker', { type: 'topic' } );
e
浏览 3提问于2015-04-23得票数 3
回答已采纳
是否可以使用REST从Azure事件中心接收事件？我在Azure文档中只找到了发送事件API。怎么搞活动？
浏览 0提问于2018-11-22得票数 3
回答已采纳
不同的事件类型由主题/队列和消息头的某些组合来区分。在Kafka中，记录流仍然作为主题()分开。在阅读Azure事件中心文档时，我没有看到任何这样的想法。有分区，但根据文档，这些分区与使用者并行性()有关。您是否认为在Azure事件集线器中有一个名称空间，其中包含每个“主题”的事件中心？
浏览 2提问于2017-02-15得票数 3
回答已采纳
我计划利用Azure事件中心中的所有32个分区。要求:每个分区的“有序”处理至关重要。问题:如果我将所有32个分区的TU(吞吐量单位)增加到最多20个，我将得到40 MB的出入口。假设我计算出需要500个并行客户端线程并行处理(EventProcessorClient)才能满足吞吐量需求。如何使用EventProcessorClient实现这种级别的并行性，同时满足我的“订购”要求？顺便说一下，在Kafka中，我可以在一个主题中创建500个分区，而Kafka允许每个分区只允许一个线程，以保证事件顺序。
浏览 2提问于2020-12-07得票数 0
我正在为Azure事件中心在C#中实现订阅者，但它不起作用。
日志中没有错误，失败的原因可能是什么？
我的代码可以找到。
浏览 3提问于2021-12-10得票数 0
回答已采纳
引言
大家好，我们目前正在开发一个使用Azure EventHubs和事件在服务之间发送数据的微服务平台。让我们将这些服务命名为: CustomerService、OrderService和MobileBFF。
CustomerService主要发送更新(带有事件)，然后由OrderService和MobileBFF存储这些更新，以便能够响应查询，而不必为这些数据调用CustomerService。
所有这3项服务+我们在DEV环境中的开发人员都使用相同的ConsumerGroup连接到这些事件中心。
我们目前只使用一个分区，但计划在以后扩展到多个分区。(您可以看到，我们的代码已经能够从多个分
浏览 3提问于2021-09-06得票数 2
回答已采纳
在Azure流分析中，当试图从事件中心提取数据时，我收到以下错误
诊断:源“<unknown_location>”在“2020-11-19T04:08:35.3436931Z”和“2020-11-19T04:08:35.3686240Z”之间出现了1次“InputDeserializerError.InvalidData”。无法从给定的Avro记录架构创建记录
我想知道原因是什么？
有什么方法可以找到EVENTHUB中哪种类型的数据文件？
浏览 1提问于2020-11-20得票数 0
我是一个事件中心的新手，我尝试使用.Net核心进行集成。我能够成功地读取传入的事件数据，但是由于某些原因，我想重新读取数据，所以有可能吗？
浏览 6提问于2022-02-22得票数 0
3回答
在微服务架构中如何组织RabbitMQ交换/队列有什么最佳实践吗？
假设我有服务A、B、C、D。服务D需要使用来自A和B的事件，将命令发布到C。
我的解决方案--每个服务都声明它的交换。ExchangeA、ExchangeB、ExchangeC、ExchangeD。
客户端可以将命令发布到该交换，并使用来自这些交换的事件。这些是主题交换，因此对于命令，对于event ServiceA.Event.Event1，路由键将是ServiceA.Command.Command1。
对于我已经分享的例子：
ServiceD binds queue (with name ServiceD.ServiceA
浏览 8提问于2021-03-12得票数 0
我有一个拥有多个(比如2个)订阅者的Rabbit主题，它运行在一个负载均衡的应用服务器集群中(比如3个)。
那么，消息将传递给集群环境中所有侦听器的所有(2X3)订阅者，还是只传递给2个侦听器？
浏览 1提问于2015-07-07得票数 0
我试图用ASA ()编写一个查询，其中包含大量的左联接。它未能以下列错误启动作业：
流分析作业存在验证错误:作业将超过事件中心接收器的最大数量。
浏览 6提问于2016-08-02得票数 1
我需要从几千个设备发送消息到中央集线器，并能够从该中心获得特定设备的实时消息流。到目前为止，Azure事件中心似乎是消息计数方面最便宜的选择。事件集线器命名空间允许在其中创建不同的事件中心。
我能创建几千个这样的集线器，每个设备一个吗？
是个好主意吗？潜在的缺点是什么？
如何计算价格-每个名称空间还是每个事件中心？(我认为每个名称空间，但我找不到这个信息)
如果每个命名空间，是否意味着购买的吞吐量单位在所有事件中心之间共享？如果是，单个事件集线器命名空间和1000个事件集线器是否将消耗与具有单个事件集线器的单个事件集线器命名空间相同的资源，但该名称空间接收来自1000个设备的消
浏览 0提问于2018-03-22得票数 1
回答已采纳
我有一个生产者将消息写入Azure事件中心，还有一个使用者从事件中心读取消息。我将生产者升级为.Net核心，在此过程中，我从使用WindowsAzure.ServiceBus包切换到Azure.Messaging.EventHubs，将消息写入事件中心。
来自老生产者的事件仍在处理中，没有问题。但是，当使用者收到来自新生产者的任何消息时，我发现事件处理器在处理事件之前抛出了一个异常。
无法转换'System.Collections.Generic.List1[System.Diagnostics.Activity]' to type 'System.Collectio
浏览 4提问于2020-09-03得票数 2
回答已采纳
我正在编写一个pub/sub实现，它使用Azure EventHub作为底层事件摄取服务。在我的应用程序中，发布者将向特定的EventHub分区发布事件，订阅该特定分区的使用者将接收事件。通常，一个消费者将被分配给一个唯一的EventHub ConsumerGroup，在某些情况下，可以将多个使用者分配给同一个ConsumerGroup。
假设我有两个消费者(消费者-1，消费者-2)在同一个ConsumerGroup (消费者组-1)中，他们订阅了特定EventHub分区(事件中心-1的分区'0‘)的事件。
当我们将一个事件发送到“事件-集线器-1”的分区'0‘时，消息传递将如
浏览 6提问于2022-10-10得票数 0
1回答
我正在使用Azure事件中心来监听我的应用程序中的实时数据。大多数情况下，它可以正常工作，但有时它会抛出以下错误-
新的接收机具有较高的时代'3109‘被创造，因此电流接收器与时代'3108’被断开。如果您正在重新创建接收器，请确保使用了更高的时代。TrackingId:eb2a6f970000494500f379f85b484a9f_C-1553490498_B22，SystemTracker:xxxxxxxxxx:eventhub:xxxxxxx~2730|$default，时间戳:2018年7月13日6:48:54
应用程序停止处理数据。我在网上看过几篇文章，但没
浏览 1提问于2018-07-20得票数 9
我目前正在进行一个项目，在这个项目中，我需要在我的应用程序中使用第三方Web钩子。问题是，这个第三方服务不允许我选择通过这个web钩子将哪些事件推送到我的应用程序中，所以我必须对所有这些事件做出响应，即使它们都是无用的，如果我需要扩展我的应用程序或者将其划分为微服务，那么即使它们有不同的需求，我也会将相同的数据流到所有的服务中。此外，如果我的应用服务器出现问题，我将面临数据丢失。
解决方案是使用事件代理，它将收集Web钩子中的所有事件，用200 OK状态代码响应提供者，将事件推送到将存储的特定主题，直到所有相关订阅服务接收到该数据为止。
我在Azure中寻找一个完全管理的服务，到目前为止，我遇
浏览 1提问于2019-07-12得票数 0
回答已采纳
我在Wcf面临着一个奇怪的问题。当我传递一个在wcf中具有值的对象并在wcf服务中调试该对象时，它在所有int和datetime属性中显示空值，而string值则显示在string类型属性中。我正在使用wcf服务器端。
我已经检查了所有的配置和服务，但没有发现任何问题。如果有人知道的话请帮忙。
提前谢谢。
浏览 3提问于2013-12-27得票数 0
我要求在运行时使用Kafka IAdminClient或任何其他汇合Kafka公开的接口创建消费者组。我明白，通过实现allow.auto.create.topics就可以解决我的需求。
在我的例子中，正在连接到事件中心。在事件中心中，我们需要显式地创建一个使用者组。如果在使用消息时没有指定使用者组，则使用$Default使用者组。如果我提供了事件中心中不存在的使用者组，那么它会抛出一个错误。
你们能把我开在正确的道路上吗？
浏览 9提问于2022-06-28得票数 0
1回答
我遵循来发布事件。我有一个连接到活动中心的Logic App。我正在记录来自服务器和Azure函数的事件。来自服务器的事件是通过Logic App生成的，但是Azure函数事件没有生成。我如何调试事件中心并找出事件被删除的确切位置？
浏览 0提问于2019-03-02得票数 0
我有一些关于扩展Azure函数和事件集线器触发器的问题。我知道AF应用程序在某个地方存储了一个检查点号(我认为是Azure)，但我想知道当AF扩展或改变时，这适用于什么(亲和力)。
如果我有一个包含消息的现有事件中心并重新部署AF应用程序，那么它是从一开始就用一个新的检查点重新启动，还是从它停止的地方开始呢？似乎应该从那个AF应用程序的最后一个检查点开始。
如果我更改了AF应用程序中使用事件中心触发器的函数的名称，它是保持相同的检查点还是重新启动？
如果我停止/启动AF应用程序，它会失去它的位置吗？似乎不应该因为它是存储在外部，但我不知道他们如何映射到彼此。
当AF扩展时，多个
浏览 0提问于2017-09-26得票数 1
回答已采纳
1回答
我希望用户订阅事件，万一他们中的一人死亡，我希望为这位用户保留消息，所以一旦他们在线，他们就会收到消息。如果生产者创建N个队列，每个消耗器1个，那么它可以工作。但生产者不应关心是否有消费者和有多少消费者。完成者应该负责创建自己的队列，选择它想要接收的消息，并且队列将保持不变。你能给我指路吗？
它是否需要在制片人方面有什么具体要求？
RabbitMQ网站上的教程只以这样的方式讨论持久性:如果服务器死了，那么消息就会持久化，或者有一个队列的另一个例子，即N个用户，如果所有的用户都死了(因为消息没有被传递)，就会有持久性，但是这是一个感应器，在这里，消息只被传递给一个完美者(随机)，而我需要所有的用
浏览 2提问于2015-06-18得票数 0
回答已采纳
1回答
当创建一个新的Azure IOT集线器时，您会被问到您需要多少设备对云分区。您可以为标准层选择2-32个分区。
据我所知，SKU和单位数量决定了您可以发送到IOT中心的最大每日邮件配额。并建议将您的设备分割成多个IOT集线器，以平滑流量突发。然而，设备到云的分区需要澄清。
1>>，这些设备到云的分区在一个IOT集线器下的用途是什么？
2>>我们应该如何利用那些IOT集线器设备到云的分区？
谢谢。
浏览 5提问于2017-04-05得票数 12
我在RabbitMQ中使用MassTransit库。我希望将我的客户扩展到不同的机器中，但是我需要确保它们不会收到相同的消息。我将我的消费者部署在不同的服务器上，但他们得到了相同的消息。有没有办法解决这个问题？
浏览 22提问于2021-08-06得票数 0
回答已采纳
我们正在开发一个使用Azure函数、事件中心、Cosmos DB、SignalR的应用程序。我们设置了Event Hub来监听来自前端的所有事件。我们使用的是CosmosDB，它将数据存储在单个集合中。当我们向集合中添加新记录时，我们希望将此信息传递给前端，以便它们只能更新新添加的记录。但我们不知道如何做到这一点，因为它是一个单一的集合，它将返回所有数据。如果它有一个SQL数据库，那么我们可以选择最近添加的记录。
我们非常感谢您的任何建议。
浏览 2提问于2018-03-17得票数 0
我的linux与扩展一起安装，并配置为将syslog消息推送到事件中心。
我可以在事件中心进程数据刀片上查看我的syslog消息。现在，我正在尝试将这些日志发送到Azure，为此，我遵循以下步骤
在ADX中创建一个集群。创建了一个数据库(Syslog)和表(SyslogTable)，用于存储syslog ；为Syslog表创建了JSON映射，用于映射由事件中心数据连接的字段。创建了连接事件中心和ADX表的数据摄取连接。<code>G 211</code>
一切都进行得很顺利，没有任何错误，因为.show ingestion failures没有显示任何错误，但是我无法看
浏览 7提问于2020-05-19得票数 1
2回答
也许我问错了问题。
我要做的是:多个生产者将动态类别中的数据推入一个命名的exchange中。多个使用者需要从这些动态命名的队列中获取这些数据，并对它们进行操作。
问题是，我看到的所有消费示例都要求使用者/订阅者有一个特定的队列名，而我的消费者不知道队列的名称，他们也不需要知道这一点。
我为什么要这么做？原因有二：
I可以一次拥有N个动态类别。我希望排队的人能平等地为这些类别服务。目前，我们有一个队列(msmq)，它接受所有这些类别，并在FIFO中为它们提供服务(这意味着一些类别在一段时间内都处于饥饿状态)。能够平等地为所有类别服务，而不是fifo，这让我想出了一个有趣的QoS (默认情况下，
浏览 1提问于2011-12-02得票数 4
回答已采纳
我们有多个服务，并使用发布/订阅模式从服务A发送由其他服务(B & C)处理的事件。目标是允许多个队列通过匹配绑定键/主题从生产者接收消息。
如果服务B&C首先启动，这很好。在这种情况下，订阅方法创建交换和队列，以便在发布时接收消息。但是，如果服务A首先启动，则由于未创建接收队列，将丢失已发布的消息。
寻找确保在发布前创建队列的最佳实践方法。生产者不了解使用者，对于给定的消息类型，随着时间的推移，可能会有更多的使用者，所以我们不能让生产者代码负责队列创建。
我们当前的实现是在背板上使用RabbitMQ，但是我们希望随着时间的推移迁移到SQS和Azure服务总线，所以我们需要这样
浏览 5提问于2021-12-20得票数 1
回答已采纳
我们有多个使用者要处理股票的创建/更新/删除请求。
所有这些请求都是在rabbitmq处理的。问题是，有时当股票被创建并被立即删除时，“删除”消息首先被处理，而“创建”消息则会在之后被处理。
尽管我们在“删除”之前推动“创建”消息。这是因为我们有多个使用者在不同的服务器上运行。
我的问题是，与多个消费者一起运行这个程序本身违反了FIFO的队列原则。如何才能避免这种情况？
浏览 1提问于2017-05-03得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
