使用pythonqpid/Proton/Messenger（），如何过滤来自Azure事件中心的消息？

Question

这个要点展示了如何使用Messenger（）从Azure事件中心接收消息。效果很好。在

https://gist.github.com/tomconte/e2a4667185a9bf674f59

但是，使用此技术将生成事件中心中的所有消息。我想从偏移量或时间戳（不在乎哪个）开始读取消息。我可以在Qpid文档中看到如何设置这些要求，但在使用Messenger（）时却看不到。在

以下是Qpid文档中的相关部分： https://qpid.apache.org/releases/qpid-proton-0.16.0/proton/python/api/index.html

以及一个演示如何使用它的示例： qpid.apache.org/releases/qpid-质子-0.16.0/proton/python/examples/selected_接收.py.html在

问题：有可能吗？如果有，怎么可能？在

Answer 1

根据我的理解，我想您应该读取以EventHub上的偏移量或时间戳开头的事件数据。我回顾了EventHub SDK for C#/Java的所有类和方法，但是没有任何方法支持这种使用来从EventHub上的部分使用事件数据。apacheqpid是一个支持Java/C/Python的AMQP协议的库，EventHub支持AMQP，但并不意味着EventHub支持Qpid的所有方法。在

有两种解决方法可供您选择。在

1. 接收EventHub上的所有消息，并过滤这些不需要的消息。在
2. Using Azure Stream Analytics to create an output pipeline要将消息输出到其他存储，如表存储、DocumentDB，则可以使用所需的偏移量/时间戳从其他存储中检索这些数据。在