时间戳最小为0，序列部分从0开始。为什么Redis Streams的最小消息ID是'0-1‘，而不是'0-0'？
“0-0”是否在内部使用？这就是为什么你可以有“空”流？
浏览 11提问于2019-11-18得票数 0
每种方法的优缺点是什么？请建议何时使用其中一个，而不是另一个。
浏览 2提问于2019-12-31得票数 27
回答已采纳
您能给出一个在Python中使用Redis‘xread和xadd的简单示例(显示返回值的类型和格式、xread和xadd的输入)吗？我已经读过许多文档，但没有一个是Python的。Redis 给出了一个例子：1518951480106-0sample ={b"hello":b"12"
浏览 0提问于2019-03-06得票数 7
回答已采纳
Redis streams是否受益于集群模式？假设您有10个流，它们是分布在群集上，还是全部分布在同一个节点上？我计划将Redis streams用于非常高的吞吐量(2m+消息/秒)，所以我担心Redis streams在这种规模下的性能。任何关于水平扩展Redis流的指导都将是很棒的，如果它不是在集群模式下扩展的话。
浏览 6提问于2021-07-06得票数 0
2回答
我正在构建一个扑克牌系统，并且我已经决定使用SSE的pub/sub系统来保持客户端的更新。我面临的一个问题是保留消息以供以后查询。一种用例是玩家在游戏中加入一张桌子。我目前使用的是redis的pub/sub，但这些消息都是短暂的。我对rabbitMQ做了一些深入的研究，看起来也是这样。Kafka似乎有一些重放功能？不过，我不知道它是否像我希望<
浏览 21提问于2020-05-09得票数 0
回答已采纳
在我的流中，我有一个挂起的消息：1) 1) "messages2) "1592850947048-0"4) 1) 1) "consumer"它不可能是(零)，但仍然..我读到了一条
浏览 12提问于2020-06-26得票数 0
1回答
我正在将一个redis发布/订阅系统转换为redis流，这样我就可以为我的服务器发送的事件添加一些容错功能。订阅传统的方式是微不足道的： url: `${process.env.REDIS_URL我正在努力解决的部分是阻塞。redis<
浏览 11提问于2020-06-04得票数 8
如何使用redis cli不断地从流中消费和输出消息？我尝试了下面的命令，但是它只使用了最后一条消息，但是我想从redis cli中得到的是在发布者不断发布消息的同时，在屏幕上不断地使用和输出消息。XREAD BLOCK 0 STREAMS mystream $
浏览 16提问于2021-07-17得票数 0
3回答
我有一个使用Redis stream (‘ioredis’库)传递信息的NodeJS应用程序。问题是，当我将消息添加到流中并试图检索它时，我必须向下进行很多数组级别的操作：
const message = await redis.xreadgroup('GROUP', orderGroup, orderConsumer, 'COUNT', 1, 'STREAMS', orderStream, '>&#
浏览 0提问于2020-12-18得票数 0
我有几个问题，我在Redis教程中找不到答案 1)如何查看/查看Redis PubSub通道的值? Redis命令是用来调试Redis的，但我想看看之前推到通道的是什么。3)如何在免费的web应用中监控Redis集群？
浏览 26提问于2019-03-02得票数 0
回答已采纳
下面的代码显示了如何测试Redis流函数。import aioredis
async def consume_a()
名为&q
浏览 12提问于2021-10-09得票数 0
1回答
我有一条红河“我的溪流”，我试着用：读取附加到mystream的五个新条目，并阻塞50。当我执行命令将数据添加到mystream时，可以使用：阻塞的命令退出，并将单个条目作为输出。有没有任何方式的XREAD命令，我可以使用从现在到50多个附加的条目，或者我必须多次调用XREAD实现相同的？
浏览 2提问于2020-03-29得票数 0
1回答
我正在尝试理解redis streams如何进行分区，如果可以将特定的消息发送到特定的分区(类似于使用Kafka的方式)。我已经检查了redis-cli api，没有类似于分区的东西，在使用StackExchangeRedis redis库时也没有这方面的东西。唯一的方法是：IDatabase.StreamAdd(key,streamKey,streamValue,messageId) 我错过了什么
浏览 41提问于2021-10-07得票数 1
回答已采纳
我使用redis流和XReadGroup从流中读取消息。我已经将block参数设置为0。目前我的代码如下所示 Group: w.opts.group, Streams: []string{w.opts.streamName, ">&qu
浏览 11提问于2022-09-20得票数 0
1回答
我有一个Java服务器执行一些工作，并将其结果发布到Redis上。我想将结果实时发送给一些用户，所以我实现了一个基于SignalR的解决方案。结果必须对许多客户机可用，而SignalR只是其中之一；因此不能修改服务器以完全满足我的需要。基本上，这就是我所拥有的：我认为这是一个丑陋的解决方案，因为它使用Lazy类型来侦听订阅的通道，并调用委托来告诉SignalR推送数据。最好的解决方案是
浏览 0提问于2015-11-27得票数 3
我正在尝试使用Reddison lib在redis中使用streams。我接收消息时使用的是code StreamReadGroupArgs.neverDelivered()。但是如果我不确认它，那么下一次调用readGroup时，它就不会收到这些消息。问题是，如果节点崩溃或网络出现故障，而我无法处理这些消息，该怎么办？那么，即使我没有确认它，我也不会再次收到这些消息。有没有解决这个问题的办法，或者我可以做的
浏览 229提问于2021-09-23得票数 0
回答已采纳
我有这样的测试。这个问题在评论中。':'test_stream','redis_chan':'test_chan'}" yield self.pool.q.put(cmd) self.assertIsInstance(self.pool.streams['test_stream'], Streams
浏览 0提问于2015-08-19得票数 0
我需要从REDIS流中读取数据，而服务器仍将写入STream。现在有两种方法。一种方法是获取已经存在的消息列表。我正在做如下所示的事情。然而，我想做一个阻塞读取，这样我的客户端控制台应用程序将等待流中的消息。我知道在REDIS-CLI中使用以下命令也可以做到这一点。我希望在C# XREAD BLOCK 1000 STREAMS #channel1 1526999626221-0中实现相同的结果
ID
浏览 29提问于2019-11-08得票数 3
2回答
在前端，我有一个用户文本输入，和一个叫“搜索”的按钮。理想情况下，当用户在输入中输入搜索词并单击“搜索”按钮时，Tweepy应该监听新的搜索词并停止前一个搜索词流。True) return render_template('index.html')
在上述代码的倒数第二行中执行的，只要单击" search“按钮，它就会启动一个新<e
浏览 46提问于2014-12-12得票数 18
回答已采纳
云服务器
ICP备案
对象存储
云直播
腾讯会议
腾讯云开发者
