jettask-python 0.1.0

高性能分布式任务队列

Jettask

高性能分布式任务队列。

安装

pip install jettask

快速开始

from jettask import Jettask, TaskMessage

app = Jettask()


@app.task(queue="math")
def add(x, y):
    print(f"{x} + {y} = {x + y}")


# 发送
app.send_sync([
    TaskMessage(queue="math", kwargs={"x": 1, "y": 2}),
])

启动 Worker：

jettask worker start -a main:app -t add -c 4

特性

• 延迟任务、优先级、自动重试
• 定时调度（Cron / 固定间隔 / 一次性）
• QPS 和并发限流，运行期间动态调整
• 手动确认（Manual ACK）
• 通配符队列、多 Handler Fan-out
• TaskRouter 模块化组织
• 多应用命名空间隔离
• 崩溃恢复，消息零丢失
• PostgreSQL 持久化

文档

详见 教程