funboost
funboost copied to clipboard
pip install funboost,python全功能分布式函数调度框架,。支持python所有类型的并发模式和一切知名消息队列中间件,支持如 celery dramatiq等框架整体作为funboost中间件,python函数加速器,框架包罗万象,用户能...
我不打算用 celery,因为他没办法和mysql完美的结合,我打算测试一下你这个 产品
hi 想请问一下funboost如何结合tornado实现异步非阻塞啊? 我想使用tornado通过funboost向队列中发消息 然后异步的获取执行结果 然后结束响应。 thks
其实就是一个需求, 我们调用某saas服务, 最高100qps 超过就会封禁一直断时间, 而且此saas的接口的qps限制是共用的 也就是我们写的 一部分task 加起来的qps 不得超过100 但是我们又得让他尽量靠近100 这样可以最大化利用资源 文档我看了两遍 但是好像没有 `按组` 限制qps的 恳请解答 感谢作者开源,优秀项目
能否支持降级
支持多种中间件 能否通过配置支持降级 [ kafka -> MQ - > redis -> 本地文件 ] 这种
依赖太多了
有些模块压根用不着,默认也安装了。
非常好用的框架,之前一直在用celery,发现这个框架之后,我觉得无论从项目设计规划和上手难易度来说,这个框架都非常棒。 目前问题是,这个框架在使用python 3.10+的时候,存在一些不兼容,请问作者是否有计划加入pyhton 3.10的支持。
版本41.2 脚本:basic_consumer.py line: 512 我改成下面这样 就能运行 # noinspection PyProtectedMember def _run(self, kw: dict, ): try: t_start_run_fun = time.time() max_retry_times = self._get_priority_conf(kw, 'max_retry_times') current_function_result_status = FunctionResultStatus(self.queue_name, self.consuming_function.__name__, kw['body'], ) current_retry_times =...
建议:项目工程可以搞的正式一点,readme和文档默认成英语,这样能更好的推广到全球
1.建议增加可以选择通过在远程服务器上的客户端进行调度,而不是只能通过配置IP用户名密码,这样有点不安全; 2.远程服务器上通常会有其他任务,手工设置进程数量意味着还是得登录到远程服务器查看当前负荷,能否设置成自动? 3.远程服务器上的资源使用情况也是动态的,当服务器资源达到临界值时,能否自动减少进程数,反之则增加?也即是真正的动态?
File "/usr/local/lib/python3.8/site-packages/funboost/concurrent_pool/custom_threadpool_executor.py", line 41, in check_not_monkey 2023-08-16T14:21:28.552296900Z raise Exception('指定使用多线程模式时候,请不要打gevent包的补丁') 问题是我也没打gevent包的补丁