网络编程
位置：首页>> 网络编程>> Python编程>> Django使用Celery加redis执行异步任务的实例内容

Django使用Celery加redis执行异步任务的实例内容

作者：不识少年愁　　发布时间：2022-08-25 18:09:53　

标签：Django,Celery,redis

简单使用

安装celery及redis

定义celery任务

项目下新建tasks.py


from celery import Celery

# 创建一个Celery类的实例对象
app = Celery('celery_task.tasks', broker='redis://127.0.0.1:6379/8')

# 定义任务函数
@app.task
def send_register_active_email(message):
 with open("D:\\celery\\text.txt", 'a') as f:
   f.write("To perform a task..." + message)

调用触发任务

run.py


from celery_tasks.tasks import send_register_active_email

def register():
 send_register_active_email.delay("test1\n")

if __name__ == "__main__":
 register()

在项目目录下启动celery

celery -A tasks worker -l info

再运行run.py

如图，接收到任务并成功执行。

Django使用Celery加redis执行异步任务的实例内容

来源：https://www.cnblogs.com/viete/p/12332742.html

0
投稿

猜你喜欢

手机版 网络编程 asp之家 www.aspxhome.com