我正在测试事件中心。 开发人员正在将消息推送到事件中心。 我构建了一个事件中心侦听器来检查是否正确发送/接收所有消息。 这是我使用的设计:
https://learn.microsoft.com/en-us/azure/event-hubs/event-hubs-dotnet-framework-getstarted-receive-eph
我遇到的问题是事件中心大约有 400 万个事件,ProcessEventsAsync 方法似乎被调用了 4 或 5 次,然后停止调用。
有没有办法我可以请求仅获取过去 X 分钟内添加的消息?
而不是使用EventProcessorHost
,你可以直接阅读所有事件。这意味着您将直接调用Receive
方法来读取一批事件。
有关代码示例,请参阅直接使用者和服务总线事件中心直接接收器。
无法按时间(最后 X 秒(过滤事件,偏移量是唯一可寻址的空间。