- Version:
1.1.32
- 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.32
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.32.tar.gz | 1.5 MB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| deepfos_celery-1.1.32-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 2.0 MB
Release files / deepfos_celery-1.1.32.tar.gz
| Download URL | deepfos_celery-1.1.32.tar.gz |
|---|---|
| Size | 1.5 MB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
89a0d08adf91968ee1d7b906747139d9268fd8ad9d04e01d2011139e36e54f5d
|
|
BLAKE2b-256 checksum How to use checksums |
9a9fb31b04be88078bb86ce2216c5b0f2c3f8e79263571361b8a05581472c344
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/6.2.0 CPython/3.9.25
|
Release files / deepfos_celery-1.1.32-py3-none-any.whl
| Download URL | deepfos_celery-1.1.32-py3-none-any.whl |
|---|---|
| Size | 457.4 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
06d0e4a3020a8b9686194d8ee92bedb9d9589b013713de81d1ed5161f012747f
|
|
BLAKE2b-256 checksum How to use checksums |
92164d1ae112ea4b3bdf117b8360176d30ae80abaeb061c03e74939abaf3c1a5
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/6.2.0 CPython/3.9.25
|
