查询rethinkdb中的订阅者



我对RethinkDB(2天)很陌生,我正在考虑它用于特定的用例,在这个阶段,我试图理解它是否将是一个可行的解决方案。我已经浏览了文档,但我还没能找到一个快速的答案。

拥有实时/连续查询是很棒的,这解决了我的特定用例的前半部分。我的问题是,我是否可以查询在特定数据库(或表/查询)上运行的实时查询的订阅者。更好的是,订阅那个元查询。

我的用例是:订阅者随机订阅一个实时主题,他们使用一个键来指示他们对实时更新感兴趣的数据片。从发布者的角度来看,发布者不想处理订阅者不感兴趣的任何内容。

发布者需要有效地(不需要轮询)知道

  • 如果有新的订户出现
  • 如果现有用户丢失或断开连接

因此,我梦想着一个"系统"查询,我的发布者可以订阅它,如果有新的订阅者出现或现有的订阅者消失,它会通知。最重要的是,对于每个订阅,我甚至可以深入了解他们订阅时使用的密钥。

希望吗?

我认为下面的内容很好地实现了我想要达到的目标:

r.db("rethinkdb").table("jobs").filter({type: 'query'})

最新更新