🎯 什么是FunBoost?
FunBoost是一个万能、强大、简单、自由的Python全功能分布式调度框架。它的作用是给用户任意项目的任意函数赋能,让你的函数具备分布式执行能力。
核心优势: 只需要一个
@boost装饰器,就能让任意函数实现分布式调度,无需修改原有代码结构。
✨ 核心特性
🎯 简单易用
只需一个@boost装饰器,无需复杂配置,学习成本低
🔄 分布式支持
支持40+种消息队列中间件,包括Redis、RabbitMQ、Kafka等
⚡ 高性能
发布性能是Celery的22倍,消费性能是46倍
🎛️ 功能丰富
QPS控制、任务过滤、重试机制、RPC调用、定时任务等
👁️ 可视化界面
内置Web管理界面,实时监控任务状态
🔧 零侵入性
不改变原有代码结构,随时添加或移除装饰器
🚀 最简示例
下面是最简单的FunBoost使用示例:
from funboost import boost, BrokerEnum, BoosterParams
import time
# 只需一个@boost装饰器,函数就具备了分布式调度能力
@boost(BoosterParams(
queue_name="simple_queue",
broker_kind=BrokerEnum.MEMORY_QUEUE, # 使用内存队列
qps=3, # 每秒执行3次
))
def add_task(x, y):
print(f"开始计算: {x} + {y}")
time.sleep(1) # 模拟耗时操作
result = x + y
print(f"计算完成: {x} + {y} = {result}")
return result
if __name__ == "__main__":
# 发布任务
for i in range(5):
add_task.push(i, i * 2)
# 启动消费者处理任务
add_task.consume()
🛠️ 安装要求
# 安装FunBoost
pip install funboost
🏷️ 支持的中间件
Redis RabbitMQ Kafka NSQ SQLite MongoDB Celery Memory Queue 40+种中间件
📊 性能对比
框架对比:
- FunBoost: 发布性能 100%, 消费性能 100%
- Celery: 发布性能 4.5%, 消费性能 2.2%
结论:FunBoost性能是Celery的20-40倍!!