流分析工作并将事件路由到服务总线后，事件中心中的事件会如何处理？

如何解决流分析工作并将事件路由到服务总线后，事件中心中的事件会如何处理？

我有以下情况：

1. 事件中心（EH1）配置有7天的保留策略。
2. 生产者将事件发布到EH1。
3. EH1中的事件从流分析（SA）（在1小时的时间窗口内执行某些计算后）路由到服务总线，该服务总线既获取原始事件（作为消息）又进行汇总计算。
4. 让我们说在第一天的24小时内，生产者向EH1发布了100万个事件。
5. SA启动并将原始事件以及汇总的计算（在1小时内）路由到服务总线。
6. 假设在第1天之后的15天之内没有任何事件推送到EH1。

问题：

1. 从第一天开始的100万个原始事件将在EH1中停留多长时间？
2. 在第2天（第1小时之后）到第7天（因为保留策略为7），那100万个原始事件（从第1天开始）是否还会存在？还是在SA处理完所有这些事件后的第一天之后就消失了？如果没有，还会发生什么？
3. 我应该在EH1中查看哪些指标来证明（1）和（2）的答案是什么？

解决方法

首先，您应该先看看consumer group。

简而言之，当使用者（如用于从eventhub接收事件的任何应用程序或代码）读取事件时，它必须通过使用者组（在这里将其命名为cg_1）读取事件->然后下次，您再次从cg_1中读取事件时，将不再读取已读取的事件。

但是，如果您切换到另一个使用者组（例如，您新创建了一个名为cg_2的使用者组），则可以再次读取所有数据（即使已从cg_1中读取了数据）。

对于您的问题：

＃1： 由于您已将保留策略配置为7天，因此事件（原始数据）将在eventhub中保留7天。如果事件是通过使用者组收到的，则无法通过该使用者组再次收到事件。但是您可以使用另一个使用者组再次接收数据。

＃2： 与问题1相似，原始事件将根据您配置的保留天数存储在eventhub中。

＃没有此类指标，但您可以轻松编写客户端代码，创建新的使用者组，然后读取数据以检查其是否存在。