🚀 FunBoost 最简单Demo

Python分布式函数调度框架 - 只需一个@boost装饰器

🎯 什么是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倍!!