funboost icon indicating copy to clipboard operation
funboost copied to clipboard

pip install funboost,python全功能分布式函数调度框架,。支持python所有类型的并发模式和一切知名消息队列中间件,支持如 celery dramatiq等框架整体作为funboost中间件,python函数加速器,框架包罗万象,用户能...

Results 12 funboost issues
Sort by recently updated
recently updated
newest added

我不打算用 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包的补丁