2016-02-19 192 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"])