如何在redis-py中指定">“

Question

我在红潮文献上看到这个，上面写着：

是时候尝试使用使用者组来阅读一些东西了：。XREADGROUP组Alice计数1数据流> 1) 1) " mystream“2) 1) 1) 1526569495631-0 2) 1)”消息“2) "apple” XREADGROUP答复与XREAD答复一样。注意，不管上面提供的组是什么，它都说我想使用使用者组mygroup从流中读取，我是使用者Alice。每次使用者对使用者组执行操作时，它必须指定其名称，唯一地标识该组内的该使用者。 在上面的命令行中还有另一个非常重要的细节，在强制流选项之后，为mystream键请求的ID是特殊ID >。这个特殊的ID仅在使用者组的上下文中有效，它意味着:到目前为止从未传递给其他使用者的消息。

我试图在redis-py中指定">“参数。

当我查看文档这里时，我在流中没有看到任何似乎允许我这样做的参数。具体来说，我在努力：

>>> r.xreadgroup(mygroupname,myconsumer,{mystream : ">"},1)
[] # oh no, empty. WHY?!
# 
# even though
>>> r.xread({mystream: '1561950326849-0'}, count=1)
[[b'stuff-returned-successfully.]]

我遗漏了什么？为什么我不能指定一个">“来表示看不见的消息呢？

Answer 1

你在这个问题上有一个错误的假设，认为你有/看不到/看到了信息。该命令应该可以工作，但如果您已经看过所有消息一次，则不会起作用。

试一试

# make sure you have not seen anything in your stream by resetting last seen to 0
>>> r.xgroup_setid(mystream,mygroupname,0) # RESET ALL

现在

r.xreadgroup(mygroupname,myconsumer,{mystream : ">"},1)

效果很好。