基于redis的分布式漏斗系统,包括管理系统。
redis-funnel的Python项目详细描述
redis漏斗
一个基于redis的分布式漏斗中间件,包含管理ui。
安装
只需使用pip
:
redis-funnel
pip install redis-funnel
开始
假设有一个名为dummy
的函数运行在许多进程中,并且执行得非常快:
importtimedefdummy():returntime.time()whileTrue:printdummy()
您希望使用有限的qps限制其执行速度,例如100:
importtimefromredis_funnel.distributedimportqps_factoryqps=qps_factory(host="localhost",port=6379,db=0)@qps("1000001","test",100)defdummy():returntime.time()whileTrue:printdummy()
Warning: a redis server should be started first and listening on localhost:6379.
另外,如果函数dummy
只在一个进程中运行,那么您可以只使用基于本地内存的qps
decorator,在这种情况下,您不需要先运行redis服务器:
importtimefromredis_funnel.localimportqps@qps(100)defdummy():returntime.time()whileTrue:printdummy()
管理用户界面
待定
作者
redis漏斗由fanwei.zeng(stayblank@gmail.com)开发和维护。可在此处找到:
https://github.com/PurpleSun/redis_funnel