Django使用Celery加redis执行异步任务

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)
    

from celery_tasks.tasks import send_register_active_email


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


if __name__ == "__main__":
    register()