我们有一个要求，即我们需要收到有关 Redis 数据结构更改的通知。根据我的研究，我发现我可以使用 Redis 密钥空间通知来做同样的事情。但是，Redis 密钥空间通知将事件发送到 Redis 发布/订阅通道，该通道会触发并忘记，即一旦客户端失去连接，所有事件都会丢失，直到连接再次启动。
Redis 流解决了这个问题。我还想使用 Redis 流的消费者组功能。那么有什么方法可以将 Redis 键空间通知推送到 Redis 流而不是 Redis 发布/订阅通道？
【问题讨论】：
标签： redis stream publish-subscribe
使用当前的 Redis v5.0.3 可以做到这一点的唯一方法是使用 Modules API 开发一个模块来注册键空间通知、处理它们并将相关消息添加到 Stream 中。
【讨论】：
使用RedisGears，注册一个监听器非常简单，它会自动将每个事件写入流。
例如以下 register.py 脚本将为 person:* 键上的每个 HSET 或 HMSET 调用编写事件前缀到 mystream 流。
注册.py：
GearsBuilder() \
.foreach(lambda x: execute('XADD', "mystream", '*', *sum([[k,v] for k,v in x.items()],[]))) \
.register(prefix="person:*", eventTypes=['HSET', 'HMSET'])
要运行它，您只需调用：
$ gears-cli run register.py
【讨论】：