Metadata-Version: 2.4
Name: jettask-python
Version: 0.1.0
Summary: 高性能分布式任务队列
License-Expression: MIT
Keywords: task-queue,distributed,redis,async
Classifier: Development Status :: 4 - Beta
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Programming Language :: Rust
Classifier: Topic :: System :: Distributed Computing
Requires-Python: >=3.10
Description-Content-Type: text/markdown
Requires-Dist: click>=8.0

# Jettask

高性能分布式任务队列。

## 安装

```bash
pip install jettask
```

## 快速开始

```python
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：

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

## 特性

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

## 文档

详见 [教程](https://github.com/user/jettask/tree/main/docs)
