Celery任务列表执行

Posted wen-kang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Celery任务列表执行相关的知识,希望对你有一定的参考价值。

创建计划任务:

from celery import Celery
import time

my_task=Celery("task",broker="redis://:[email protected]:6379",backend="redis://:[email protected]:6379")

@my_task.task
def my_func1():
    time.sleep(10)
    return "任务1"

@my_task.task
def my_func2():
    return "任务2"


@my_task.task
def my_func3():
    return "任务"

调用方法执行指定的任务:

from s1 import my_func1

res=my_func1.delay()
print(res)

获取返回值中运行计划的ID

判断计划是否执行完成:

from celery.result import AsyncResult
from s1 import my_task

async_task=AsyncResult(id="48029f4f-769e-438b-ac97-e89cc0bb1157",app=my_task)
# result=async_task.get()

if async_task.successful():
    result=async_task.get()
    print(result+"OK!")
else:
    print("任务还未执行完成!")

 启动celery在命令行执行: Celery worker -A s1 -l INFO -P eventlet -c 6

-A:指定要执行的目录

-l: 指定要使用的打印日志级别

-p:指定使用eventlet插件 让高版本celery支持window平台

-c:指定可执行的计划数量

以上是关于Celery任务列表执行的主要内容,如果未能解决你的问题,请参考以下文章

Celery+python+redis异步执行定时任务

【celery】任务重复执行

Celery架构

如何确保 Celery 任务是防止重叠的 Celery 任务执行

celery:celery介绍架构基本使用,celery执行异步任务延迟任务定时任务,django中使用celery。

使用 celery 为 Django 应用程序异步执行任务