azure-eventhub - 如何在 Eventhub 中实现过滤器？

在我的应用程序中，发布到 Eventhub 的各种事件。但是我的消费者群体只需要特定的一组事件。如何在 Eventhub 中过滤这个？

最佳答案

按照这个 post :



正如@Sapnandu 提到的，您可以为此使用 Azure 服务总线，也可以使用 Event Processor Host 自己实现过滤器

例如 - 当将 node module 用于 EPH 时:

const onMessage = async (context, data) => {
  // use data to get message payload (data.body) and implement a filter here
  // suggestion: create an event name field for each message and query it here
};

const onError = (error) => {
  // do something with it
};

await eph.start(onMessage, onError);

关于azure-eventhub - 如何在 Eventhub 中实现过滤器？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/49656956/