deepfos-celery 1.1.25

Distributed Task Queue.

Version:

1.1.25

Web:

http://celeryproject.org/

Download:

https://pypi.org/project/deepfos-celery/

Source:

https://gitee.com/python-development-team/deepfos-celery/

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.