代码之家  ›  专栏  ›  技术社区  ›  Charlie S

事件中心侦听器-一次性获取所有消息

  •  0
  • Charlie S  · 技术社区  · 7 年前

    我正在测试一个事件中心。开发人员正在将消息推送到事件中心。我已经构建了一个事件集线器监听器来检查所有消息是否正确发送/接收。这是我使用的设计:

    https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-dotnet-framework-getstarted-receive-eph

    我遇到的问题是,事件中心上大约有400万个事件,processEventsAsync方法似乎被调用了4到5次,然后停止被调用。

    有没有一种方法可以让我请求只获取在过去x分钟内添加的消息?

    1 回复  |  直到 7 年前
        1
  •  1
  •   Mikhail Shilkov    7 年前

    而不是使用 EventProcessorHost ,您可以直接阅读所有事件。也就是说你会打电话 Receive 方法直接读取一批事件。

    Direct consumer Service Bus Event Hubs Direct Receivers 代码示例。

    无法按时间(最后x秒)筛选事件,偏移量是唯一可寻址的空间。