2016-02-19 145 views
4

我想用芹菜运行任务。我按照这个教程linkDjango芹菜与RabbitMQ

一切都已成功安装。现在的事情是我不知道如何执行任务。我运行芹菜,它找不到任务。 我想知道我需要调用什么来执行任务,以及我需要如何配置RabbitMQ服务器上的任务,django-admin .. 我找不到任何完整的教程。

回答

2

任务定义 应用程序/ tasks.py:

from celery import shared_task 

@shared_task 
def add(param1,param2) 
    print("task") 

任务执行:

from celery import current_app 
current_app.send_task("app.tasks.add", ["param1", "param2"])