问题标签 [azure-eventhub]

我正在构建一个 azure Web 应用程序，我想将活动日志发送到 Azure 事件中心。如果应用程序主机和事件中心之间的连接丢失会怎样？事件中心客户端是否实现某种本地队列？

请帮我澄清一下。

• 当处理来自 Azure 事件中心的事件并使用 ConsumerGroupName X 创建 EventProcessorHost 时。如果我在多个进程（而不是线程）上执行此操作，并且我创建多个 EventProcessorHost 都使用 ConsumerGroupName X。然后他们会从同一个分区中读取，因此多次获得相同的事件（在比赛条件下）？
• 当使用 ConsumerGroupName X 和另一个 ConsumerGroupName Y 处理事件时，两个 ConsumerGroup 是获取所有事件还是每个都只从某个分区获取事件？
• 在 IEventProcessor 的 ProcessEventsAsync 中处理事件时。什么 await context.CheckpointAsync(); 实际上呢？它是仅为 ConsumerGroup 设置检查点，还是为 EventHub 设置全局设置，以便永远不会再查看这些事件。这里的上下文是租用的分区吗？

编辑：好的，所以我取得了一些进展（如果我错了，请纠正我）：

1. 每个消费者都会收到所有的消息。
2. 租约被分配了一个 EventProcessorHost，因此它需要一个唯一的名称，因此消费者组名称在这里并不真正相关。
3. 仍然不能 100% 确定 context.CheckpointAsync，但我相信它只适用于 ConsumerGroup？

如果我有 1 个吞吐量单位（允许 1000 msg/sec 或 1Mb/sec）用于事件中心并尝试发送超过 1000 msg/sec 的 Azure Python SDK 是否会引发异常或有某种返回代码会通知我超出了我的配额？

我正在为 NodeJS 寻找一个稳定的 AMQP 1.0 客户端，以便我可以使用来自 Azure 事件中心的事件。

我曾尝试使用https://github.com/noodlefrenzy/node-amqp10，但它在某些有效负载上偶尔会出现malformed payload: Unknown code prefix: 0x30和malformed payload: Unable to decode bytes from message body: 005375b00002810c5b7b226576656e7474797065223（...）之类的消息。

我将不胜感激人们可以为 NodeJS 中稳定的 AMQP 1.0 客户端提供的任何方向。我很惊讶到目前为止我还没有找到一个，因为否则 Azure 似乎无法支持整个开发人员群。

我正在尝试使用 python 和质子库作为订阅者（用于接收消息）连接到天蓝色事件中心。

我找到了一个示例代码，最终得到：

我正在使用 pip 安装的 python-qpid-proton (0.10) 在 macosx 上运行此代码。

但我无法收到事件中心的任何消息我知道我每分钟从一个不同的脚本发送一条消息，该脚本确实有效。我得到以下我打印的输出

订阅了 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/0 订阅了 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/ NAME/ConsumerGroups/$Default/Partitions/1 订阅 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/2 订阅 amqps://NAME:KEY@ clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/3 订阅了 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/4订阅了 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/5 订阅了 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/ NAME/ConsumerGroups/$Default/Partitions/6 订阅 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/7

你知道为什么这段代码不能工作吗？谢谢

我正忙于EventProcessorHost为 azure EventBus 客户端实现客户端。

我有一个实现IEventProcessor如下的类：

然后我将其称为如下：

我需要将参数传递给创建的MyEventProcessor实例EventProcessorHost。我该怎么做呢？

我无法发布我的事件中心 EventProcessorHost 辅助角色。实例无法启动。我得到的错误是：

这基本上是复制 Kirk Evans 博客示例：http: //blogs.msdn.com/b/kaevans/archive/2015/02/24/scaling-azure-event-hubs-processing-with-worker-roles.aspx

真正让我感动的是我以前做过。我已经使用他的相同示例发布到不同的服务总线/事件中心。因此，我使用那个“旧”项目通过重定向一些 url 来发布到这个新的服务总线/事件中心，一切正常。当我尝试使用新项目发布到新的服务总线/事件中心时......没有骰子。我已经将这个新项目剥离到只有他正在使用的相同代码......仍然没有。

我已经确定一切都是 4.5.1（不是 4.5.2），图书馆看起来是一样的......我已经看了 2 天了，这让我发疯了！

更新：好的，图书馆并不完全相同......而且似乎有问题。如果我退后，我可以让它工作-ServiceBus 到 3.0.6（不是 3.0.7）-Azure 存储客户端到 6.0.0（不是 6.1.0）-EventProcessorHost 到 2.0.3（不是 2.0.5）

因此，在某个地方，这些库的最新版本的组合存在冲突。

We are experiencing lots of these exceptions sending events to EventHubs during peak traffic:

"Failed to send event to EventHub. Exception : Microsoft.ServiceBus.Messaging.MessagingException: The server was unable to process the request; please retry the operation. If the problem persists, please contact your Service Bus administrator and provide the tracking id." or "Failed to send event to EventHub. Exception : System.TimeoutException: The operation did not complete within the allocated time "

You can see it clearly here:

As you can see, we got lots of Internal Errors, Server Busy Errors, Failed Request when Incoming messages are over 400K events/hour (or ~270 MB/hour). This is not just a transient issue. It's clearly related to throughput.

Our EH has 32 partitions, message retention of 7 days, and 5 throughput units assigned. OperationTimeout is set to 5 mins, and we are using the default RetryPolicy.

Is it anything we still need to tweak here? We are really concerned about the scalability of EH.

Thanks

有很多关于各种 Azure 数据存储风格的信息，但是我想针对我的特定场景寻求一些建议。

我正在整理一个宠物项目，以更加熟悉 Azure 技术，特别是服务总线/事件中心和数据存储平台。我想要创建的系统相当简单：接受中等负载的事件（不是 IoT 规模），将它们持久化，并提供聚合数据，例如“用户 A 在过去一天/一周/一个月内有 N 个 X 类型的事件/ ETC。' 作为报告。

鉴于数据将非常结构化（例如用户、用户组、事件等），并且我将需要聚合功能，这表明关系存储可能是最合适的，尽管成本更高。

我考虑过的另一种选择是使用流分析之类的东西以近乎实时的方式维护聚合数据，但与更多的数据仓库式解决方案相比，不确定这是否是多余的。

任何建议/帮助将不胜感激。

约翰

我是 Microsoft Azure 的新手，
我需要更新 Event Hub Microsoft Azure 中的数据，
这是我在 Event Hub 中发送数据的代码：

我可以这样做吗？
帮我。
谢谢。