关闭
您正在使用的浏览器版本较低，无法支持聚宽的某些特性。
为了获得更好的体验，推荐使用：
Google Chrome
或者
Mozilla Firefox
或者
IE9以上
。
返回主题列表
基于redis stream的消费者处理
39
listen
分享到：
微信
微博
雪球
评论
量化致富
@idolszy +1
2023-11-29
妙手
@量化致富 老师，我按你这样改，然后同时二个策略发来消息，发现接收到的处理速度跟不上，我是设置了一次读5条，数据条数多了，处理不过来，会延时的情况 ，我尝试用ThreadPoolExecutor加线程池的数量来处理业务，速度有提升 ，但也慢。这个怎样处理好？谢谢
2023-11-30
量化致富
@妙手 可以启动多个消费端同时消费，注意 consumer_name = 'single' 每个启动实例都改成不一样的，你可以用当前进程号，随机数等等试试看，这里是配置死的'single'，你可以去掉这个配置，在init中加上self.consumer_name = "consumer_" + str(os.getpid())
2023-11-30
量化致富
@妙手 数量多可以一次性读多点 比如100，当然消费端的业务处理速度也得跟上
2023-11-30
妙手
@量化致富 是不是一个消费数据对应一个消费者和相应的消费者组里，进行消费 stream1 = RedisService(stream_name="stream1", consumer_group="group1") stream2 = RedisService(stream_name="stream2", consumer_group="group2")
2023-12-01
x x l p
@量化mm 1
2023-12-02
x x l p
@小手机 1
2023-12-02
x x l p
@bbzh 1
2023-12-02
投资投机
@x x l p 1
2023-12-02
投资投机
@量化mm 1
2023-12-02
投资投机
@小手机 1
2023-12-02
投资投机
@bbzh 1
2023-12-02
bbzh
@投资投机 1
2023-12-02
bbzh
@bbzh 1
2023-12-02
bbzh
@投资投机 1
2023-12-02
bbzh
@量化mm 1
2023-12-02
bbzh
@x x l p 1
2023-12-02
小手机
@x x l p 1
2023-12-02
小手机
@量化mm 1
2023-12-02
小手机
@bbzh 1
2023-12-02
首页
上一页
1
2
3
4
5
下一页
尾页
您尚未登录，请
登录
或者
注册
聚宽发表回复。
取 消
提 交
雪球
