- Version:
1.1.31
- Web:
- Download:
- Source:
- Keywords:
task, queue, job, async, rabbitmq, amqp, redis, python, distributed, actors
What is this?
本项目基于 celery-5.0.5 开发，主要功能：
添加 asyncio 支持，更容易集成到异步web框架
支持 redis 集群
注：项目是 ``celery`` 的超集，但并非所有功能都支持 ``asyncio`` ，并且目前仅完成了 ``redis`` 作为 ``broker`` 和 ``backend`` 的支持。
Get Started
创建任务和官方 celery 一样:
from celery import Celery
app = Celery('hello', broker='redis://:@localhost/')
@app.task(aio_variant=True)
def hello():
return 'hello world'但增加了 aio_variant 这一参数，相较于普通的任务发送和获取结果的方式：
task = hello.apply_async()
result = task.get()可以使用:
task = await hello.aio.apply_async()
result = await task.get()注意
这不只是一个简单的语法糖，而是确实使用 aioredis 替换了原有 redis-py 的同步网络请求。
License
This software is licensed under the New BSD License. See the LICENSE file in the top distribution directory for the full license text.
2 maintainers
Release files for deepfos-celery 1.1.31
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| deepfos_celery-1.1.31.tar.gz | 1.5 MB | Details |
Release files / deepfos_celery-1.1.31.tar.gz
| Download URL | deepfos_celery-1.1.31.tar.gz |
|---|---|
| Size | 1.5 MB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
5c3ec5156f1b345d7bb8254a9af1011edbd7d3d8feb5e70b5bbbea93d7e33589
|
|
BLAKE2b-256 checksum How to use checksums |
beddb411a791121b93772be96530d8d4a1dee470e27b843f80bbfeaba0f11084
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/7.0.0 CPython/3.12.3
|
