Celery的基本使用

Posted 2021-06-18 隔江千万里

Celery

# celery.py
from celery import Celery

backend = "redis://127.0.0.1:6379/1"
broker = "redis://127.0.0.1:6379/2"

app = Celery(__name__, broker, backend)

# 添加任务到 backend
@app.task
def add(x, y)
	print(x, y)
    return x + y

# run.py

# 执行任务
from .test import add
from datetime import datetime, timedelta

# 立刻执行----异步执行 add() 函数
t1 = add.delay(3, 4)
print(t1.id)

# 延时任务
# utcnow()：国际时间：2021-04-22 01:12:15.579929
# timedelta：0:00:10
eta=datetime.utcnow() + timedelta(seconds=10)
add.apply_async(args=(1,2), eta=eta)

# result.py
from .test import app
from celery.result import AsyncResult

# id 在执行任务时获取
id = \'21325a40-9d32-44b5-a701-9a31cc3c74b5\'
if __name__ == \'__main__\':
    async = AsyncResult(id=id, app=app)
    if async.successful():
        result = async.get()
        print(result)
    elif async.failed():
        print(\'任务失败\')
    elif async.status == \'PENDING\':
        print(\'任务等待中被执行\')
    elif async.status == \'RETRY\':
        print(\'任务异常后正在重试\')
    elif async.status == \'STARTED\':
        print(\'任务已经开始被执行\')