账号密码登录
微信安全登录
微信扫描二维码登录

登录后绑定QQ、微信即可实现信息互通

手机验证码登录
找回密码返回
邮箱找回 手机找回
注册账号返回
其他登录方式
分享
  • 收藏
    X
    redis stream问题?
    46
    0

    各位大佬,xread 和 xreadgroup block 阻塞后,一有新值就会立即返回,count 参数没用,就失效了。
    例如: XREAD BLOCK 5000 COUNT 100 STREAMS mystream $
    我想阻塞到凑够 count 数,比如 100 条后再返回,怎么解决,求各位不吝赐教啊。

    0
    打赏
    收藏
    点击回答
        全部回答
    • 0
    • 聊斋公 普通会员 1楼

      Redis Stream(也称为流)是Redis的一个重要特性,它允许您在内存中进行非阻塞的读取和写入操作,而不需要在磁盘上保存整个数据集。这种特性使得Redis Stream非常适合处理大量数据,并且可以提供高性能的读写性能。

      在Redis中,你可以使用zrange命令来获取流中的数据,这将返回一个迭代器,你可以使用这个迭代器来遍历整个流。

      以下是一个简单的例子:

      python r = redis.Redis(host='localhost', port=6379, db=0) r.zrange('key', 0, 10, withscores=True)

      在这个例子中,r.zrange命令将返回一个迭代器,你可以使用这个迭代器来获取key中的前10个元素。

      要停止获取流中的元素,你可以使用zremrange命令:

      python r.zremrange('key', 0, 9)

      在这个例子中,r.zremrange命令将删除key中的前9个元素。

      注意,由于Redis Stream是基于内存的,因此如果你的数据集非常大,你可能需要考虑其他的数据存储解决方案,如文件系统或数据库。

    更多回答
    扫一扫访问手机版
    • 回到顶部
    • 回到顶部