funboost-wise 18.3.2

基于 RabbitMQ/AmqpStorm 的 Python 函数调度框架，支持发布、消费、并发控制、任务过滤、RPC 结果回传与状态持久化。

RabbitMQ-only 清理说明

当前版本仅保留 RabbitMQ 作为消息中间件。

核心能力

• RabbitMQ 发布 / 消费
• 并发池、多进程、定时调度
• 任务过滤、重试、重新入队、消息确认
• RPC 结果回传、任务状态持久化
• 远程部署与辅助调试能力

安装方式

基础安装会自动带上核心必需依赖：

pip install funboost-wise

如果需要可选能力，可以按需安装：

pip install "funboost-wise[web]"
pip install "funboost-wise[remote]"
pip install "funboost-wise[all]"

Python 版本支持

• Python 3.10
• Python 3.11
• Python 3.12
• Python 3.13

默认安装内容

默认安装会自动带上：

• RabbitMQ 核心运行所需依赖
• 日志与工具依赖
• Redis / Mongo 相关基础能力依赖
• 调度、并发与基础辅助依赖

可选安装内容

• web：Web 相关能力
• remote：远程部署能力
• all：Web + 远程部署等扩展能力

核心定位

• 基于 RabbitMQ / AmqpStorm 的 Python 函数调度框架
• 统一生产、发布、消费流程
• 保留 qps 控制、重试、过滤、结果回传、状态持久化等增强能力

当前不再支持

• Kafka
• NSQ
• Pulsar
• MQTT
• Kombu 作为 broker
• Celery / Dramatiq / Huey / RQ / Nameko 作为 broker
• 本地 queue / sqlite / mysql 模拟消息队列等多 broker 模式

依赖说明

• RabbitMQ：消息投递与消费
• Redis：仅在使用 AsyncResult、任务过滤、分布式频控等能力时需要
• Mongo：仅在使用任务状态与结果持久化时需要
• Flask：仅在使用 Web 相关功能时需要
• Fabric2：仅在使用远程部署功能时需要