流分析工作并将它们路由到服务总线后,事件中心中的事件会发生什么情况?
What happens to events in event hub after stream analytics does it works and routes them to service bus?
我有以下场景:
- 事件中心 (EH1) 配置了 7 天的保留策略。
- 生产者将事件发布到 EH1。
- 来自 EH1 的事件从流分析 (SA)(在 1 小时内执行某些计算后 windows)路由到服务总线,后者获取原始事件(作为消息)以及汇总计算.
- 假设在第 1 天的 24 小时内,生产者向 EH1 发布了 100 万个事件。
- SA 启动并将原始事件和汇总计算(超过 1 小时)路由到服务总线。
- 假设在第 1 天之后,接下来的 15 天内没有事件推送到 EH1。
问题:
- 100 万个原始事件(从第 1 天开始)将在 EH1 中保留多长时间?
- 那 100 万个原始事件(从第 1 天开始)在第 2 天(第 1 小时后)到第 7 天(因为保留策略是 7)是否仍然存在?或者他们会在第 1 天当 SA 处理完所有这些事件后消失吗?如果两者都不是,还会发生什么?
- 我应该在 EH1 中查看哪些指标来证明 (1) 和 (2) 的答案是什么?
首先,你应该先看看consumer group
简而言之,当消费者(像任何用于从 eventhub 接收事件的应用程序或代码)读取事件时,它必须通过消费者组(我们在这里命名为 cg_1
)读取事件 ->那么下次你再读一次cg_1
的事件,你已经读过的事件就不会再读了。
但是如果你切换到另一个消费组(比如你新创建一个名为cg_2
的消费组),你可以读取所有数据(即使数据已经从cg_1
读取)再次.
所以对于你的问题:
#1:
由于您配置了 7 天的保留策略,因此事件(原始数据)将在 eventhub 中保留 7 天。如果已通过消费者组接收到事件,则无法通过该消费者组再次接收。但是你可以使用另一个消费者组再次接收数据。
#2:
与问题1类似,原始事件将根据您配置的保留天数存储在eventhub中。
#没有这样的指标,但是你可以很容易地编写客户端代码,并创建一个新的消费者组,然后读取数据来检查它是否存在。
我有以下场景:
- 事件中心 (EH1) 配置了 7 天的保留策略。
- 生产者将事件发布到 EH1。
- 来自 EH1 的事件从流分析 (SA)(在 1 小时内执行某些计算后 windows)路由到服务总线,后者获取原始事件(作为消息)以及汇总计算.
- 假设在第 1 天的 24 小时内,生产者向 EH1 发布了 100 万个事件。
- SA 启动并将原始事件和汇总计算(超过 1 小时)路由到服务总线。
- 假设在第 1 天之后,接下来的 15 天内没有事件推送到 EH1。
问题:
- 100 万个原始事件(从第 1 天开始)将在 EH1 中保留多长时间?
- 那 100 万个原始事件(从第 1 天开始)在第 2 天(第 1 小时后)到第 7 天(因为保留策略是 7)是否仍然存在?或者他们会在第 1 天当 SA 处理完所有这些事件后消失吗?如果两者都不是,还会发生什么?
- 我应该在 EH1 中查看哪些指标来证明 (1) 和 (2) 的答案是什么?
首先,你应该先看看consumer group
简而言之,当消费者(像任何用于从 eventhub 接收事件的应用程序或代码)读取事件时,它必须通过消费者组(我们在这里命名为 cg_1
)读取事件 ->那么下次你再读一次cg_1
的事件,你已经读过的事件就不会再读了。
但是如果你切换到另一个消费组(比如你新创建一个名为cg_2
的消费组),你可以读取所有数据(即使数据已经从cg_1
读取)再次.
所以对于你的问题:
#1: 由于您配置了 7 天的保留策略,因此事件(原始数据)将在 eventhub 中保留 7 天。如果已通过消费者组接收到事件,则无法通过该消费者组再次接收。但是你可以使用另一个消费者组再次接收数据。
#2: 与问题1类似,原始事件将根据您配置的保留天数存储在eventhub中。
#没有这样的指标,但是你可以很容易地编写客户端代码,并创建一个新的消费者组,然后读取数据来检查它是否存在。