问题标签 [azure-eventhub]

我将消息从 Windows 窗体应用程序发送到 azure 事件中心。在我使用数据流分析进行一些实时操作并从事件中心获取数据之后。在该操作之后，我将结果消息发送到事件中心。现在我想使用移动应用程序（android 或 windows 移动应用程序）通过 azure 通知中心向用户显示结果消息。我们可以直接连接 azure 通知中心和 azure 事件中心吗？

我将消息发送到天蓝色事件中心。但我无法从事件中心下载消息。

它显示以下错误聚合异常处理。发生一个或多个错误。消息详细信息：不知道这样的主机 EventProcessor 主机名是什么？

它在这一行显示错误： eventProcessorHost.RegisterEventProcessorAsync().Wait();

它没有调用 IEventprocessor。是否有其他方法可以从事件中心消费消息？

我在天蓝色的事件中心工作。我有些疑惑。

1. Azure 事件中心接收器中的分区 ID 是什么？此 ID 是否与 Azure 事件中心发布者中的分区键相同？

2. 什么是偏移量？,它在 azure event hub 消费者中有什么用？

3. 我可以在不使用消费者组的情况下使用消息吗？

4. 我可以使用单个接收者来消费消息吗？

5. 事件中心使用者中 blob 的用途是什么？我只想查看我发送的消息。

据我了解，eventhub 每秒可以处理/摄取数百万条消息。为了调整摄取，我们可以使用吞吐量。

更高的吞吐量 = 更多的摄取能力。

但是在接收/消费端，您最多可以创建 32 个接收器（因为我们可以创建 32 个分区，一个分区可以被一个接收器消费）。

综上所述，如果一条消息需要 100 毫秒来处理，那么一个消费者每秒可以处理 10 条消息，而 32 个消费者每秒可以处理 32*10=320 条消息。

如何让我的接收器消耗更多消息（例如每秒 5-10k）。

1）要么我必须在 ProcessEventsAsync 中异步处理消息。但在这种情况下，我将无法维持订购。

2) 或者我必须要求微软允许我创建更多分区。

请指教

Scott Guthrie宣布的 Azure 事件中心显示了下图，其中包括一个称为“现场网关”的东西。

我一直无法找到这个概念的含义的定义。我希望它是一个用于将事件发送到 Azure 事件中心的设备端 SDK。是吗？

需要有关在以下场景中使用 Azure 事件中心的帮助。我认为消费者群体可能是这种情况下的正确选择，但我无法在网上找到具体的例子。

这是问题的粗略描述和使用事件中心的建议解决方案（我不确定这是否是最佳解决方案。感谢您的反馈）

我有多个事件源，它们会生成大量事件数据（来自传感器的遥测数据），这些数据需要保存到我们的数据库中，并且应该并行执行一些分析，例如运行平均值、最小值-最大值。

发送方只能将数据发送到单个端点，但事件中心应该使这些数据对两个数据处理程序都可用。

我正在考虑使用两个消费者组，第一个将是一组工作角色实例，负责将数据保存到我们的键值存储中，第二个消费者组将是一个分析引擎（可能与 Azure 流分析一起使用）。

首先，我如何设置消费者组，我需要在发送方/接收方做些什么，以使事件的副本出现在所有消费者组上？

我确实在网上阅读了许多示例，但它们要么使用client.GetDefaultConsumerGroup();和/或让所有分区都由同一工作角色的多个实例处理。

对于我的场景，当一个事件被触发时，它需要由两个不同的工作角色并行处理（一个是保存数据，另一个是做一些分析）

谢谢你！

我有以下问题。

我们使用事件中心。在下面的类中，我们从 IEventProcessor 继承，如您所见，我们使用 Service Locator 。我们不能让它与构造函数/属性注入一起工作。当旨在从 IEventProcessor 继承的类时，Castle Windsor 似乎无法解决依赖关系。这是一个已知问题还是我需要做些什么才能让它工作？

下面是代码：

谢谢

显然（基于异常）EventHubClient.SendBatch和EventHubClient.SendBatchAsync仅支持每次操作发送到单个分区。这似乎通过方法摘要“将一批事件数据发送到由 PartitionId 表示的逻辑分区”在文档中指出，该方法摘要似乎是从分区特定的EventHubSender.SendBatch复制的。

让更高级别的客户端不根据需要重新批处理是否有设计考虑（与仅编写更少的代码相比）？EventHubClient 可以控制分区键散列/分布，这对于希望发送具有不同键的一批数据的 EventHubClient 调用者不可用，这些数据可能位于同一分区上。留给自己重新批处理，我需要按消息数量的顺序进行调用，而不是按分区数量进行调用，而分区数量很容易出现两个数量级的差异。

由于已经有必要重新批处理，因此情况可能会更糟。

我一直在学习事件中心，只是想确认或纠正我对事件中心的看法？我习惯于利用 Azure 服务总线队列和主题为我提供的正常企业消息传递解决方案的重试、有害消息、至少一次传递等。似乎事件中心旨在为非常高的规模提供不同的工具，在这种情况下，您必须放弃一些更多的“企业”功能才能获得更高的规模。

我是否正确地考虑了这一点？我还需要考虑其他细节吗？我意识到事件中心和主题可能存在一些功能重叠，但我只是想弄清楚如何考虑使用事件中心。

我们正在开发一个多租户应用程序，其中 eventthub 将在不同租户之间共享。我们将在租户之间分配分区。每个租户都会在不同的分区上发送消息。我们想在分区级别对租户进行身份验证。如 Microsoft 网站上所述，我们根据租户 ID 定义了分区键。但问题不仅仅是一个分区键在同一个分区上发送消息。不应该是这样。理想情况下，每个分区键都应该映射到不同的分区。

请帮助我了解我的方法有什么问题。