我们有一个要求，我们需要在Redis数据结构发生变化时获得通知。基于我的研究，我发现我可以使用Redis键空间通知来做同样的事情。然而，Redis键空间通知将事件发送到Redis pub/sub通道，即一旦客户端失去连接，直到连接再次建立的所有事件都会丢失。 Redis streams解决了这个问题。此外，我还想使用Redis streams的消费者组功能。那么，有没有办法将Redis密钥空间通知推送到Redis</
浏览 27提问于2019-01-10得票数 4
回答已采纳
1回答
我使用Redis作为一个简单的pubsub代理，由redis-py库管理，只使用默认的'main‘通道。在Redis本身或包装Python库中，有没有一种技术可以计算这个队列中的消息数量？我对Redis没有更深的概念知识(特别是它是如何实现代理功能的)，所以我不确定这样的问题是否有意义 不需要精确的计数、锁避免等；我只需要周期性地检查这个队列是否为空(以分钟为单位)
浏览 9提问于2019-09-04得票数 0
Redis streams是否受益于集群模式？假设您有10个流，它们是分布在群集上，还是全部分布在同一个节点上？我计划将Redis streams用于非常高的吞吐量(2m+消息/秒)，所以我担心Redis streams在这种规模下的性能。任何关于水平扩展Redis流的指导都将是很棒的，如果它不是在集群模式下扩展的话。
浏览 6提问于2021-07-06得票数 0
通过发送到ffmpeg、redis pub->sub，然后将套接字发送到客户端，对每个项目进行“处理”。// Streams controller const streams = await);}
c
浏览 31提问于2021-09-14得票数 0
我在我的api服务器中使用redis订阅。收到消息时，所有副本都在处理已发布的消息。如何让其中三个副本停止处理消息，而只让其中一个副本处理消息。 提前感谢
浏览 62提问于2020-10-25得票数 0
回答已采纳
Redis团队为Redis5.0引入了新的数据类型。由于流看起来像卡夫卡主题，从第一视图，似乎很难找到现实世界的例子使用它。
使用AOF复制将所有数据存储在内存中。Sentinel或Redis群集操作的Redis故障转移过程只执行最佳的故障转移到更新最多的追随者的检查，而且在某些特定故障下，可能会促
浏览 1提问于2018-10-25得票数 21
1回答
我正在尝试理解redis streams如何进行分区，如果可以将特定的消息发送到特定的分区(类似于使用Kafka的方式)。我已经检查了redis-cli api，没有类似于分区的东西，在使用StackExchangeRedis redis库时也没有这方面的东西。
浏览 41提问于2021-10-07得票数 1
回答已采纳
1回答
我对Redis streams非常感兴趣。(看起来有可能构建由append-log驱动的小型系统，如Kafka，但没有Kafka的所有开销。)Kafka Streams、Flink、Spark等提供了这样做的方法。在Redis宇宙中有没有等价物？如果其他人有使用Redis Streams进行此操作的经验，请分享您的提示或警告。
浏览 12提问于2019-03-23得票数 6
下面的代码显示了如何测试Redis流函数。import aioredis
async def consume_astreams={"test_stream": ">", "test_
浏览 12提问于2021-10-09得票数 0
每种方法的优缺点是什么？请建议何时使用其中一个，而不是另一个。
浏览 2提问于2019-12-31得票数 27
回答已采纳
1回答
如何在redis-node中使用Redis流。XADD的Redis文档是： XADD mystream * key1 "Value1" key2 "Value2" 这将添加具有给定键值对的单个条目。*指定自动生成id。
浏览 57提问于2019-05-14得票数 1
我的代码是这样的const client = redis.createClient();
client.on("connect", functionTCPConnectWrap.afterConnect 在以下位置的RedisClient实例上发出'error‘事件: at RedisClient.on_error (E:\TEKNIK INFORMATIKA\Latihan redis\node_modu
浏览 7提问于2020-12-02得票数 1
1回答
我正在将一个redis发布/订阅系统转换为redis流，这样我就可以为我的服务器发送的事件添加一些容错功能。}/0`const redis = createClient(redisOptions);
redis.publ
浏览 11提问于2020-06-04得票数 8
您能给出一个在Python中使用Redis‘xread和xadd的简单示例(显示返回值的类型和格式、xread和xadd的输入)吗？我已经读过许多文档，但没有一个是Python的。Redis 给出了一个例子：1518951480106-0sample ={b"hello":b"12"}我知道这个错误：
<
浏览 0提问于2019-03-06得票数 7
回答已采纳
redis没有kafka client_id这样的功能吗？pub.py r = redis.StrictRedis(host=host, port=port, db=0)
print('end') sub1.py r = redis.StrictRedis(host=host, port=port, db=0)# print("Subsc
浏览 15提问于2019-08-29得票数 0
我使用Google Cloud Run和Google Memorystore Redis。我的应用程序是在Node.js (速成版)上编写的，并通过以下方式连接到Redis实例： const asyncRedis = require("async-redis");
const redisClient: Redis connection lost and command aborted.(/usr/src/app/node_modules/redi
浏览 38提问于2020-09-04得票数 1
2回答
我目前使用的是redis的pub/sub，但这些消息都是短暂的。我对rabbitMQ做了一些深入的研究，看起来也是这样。Kafka似乎有一些重放功能？不过，我不知道它是否像我希望的那样细粒度。
浏览 21提问于2020-05-09得票数 0
回答已采纳
考虑一下守则：const redis = require("redis");const client = redis.createClient(redisUrl);
浏览 1提问于2020-04-08得票数 1
3回答
var client = redis.createClient();
console.log('Redis client connected');
浏览 4提问于2019-11-14得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
