Django Celery任务排队(Django Celery tasks queue)

 我有一个应用程序用django使用redis和celery进行一些异步任务。 我正在使用celery任务来执行一些存储过程。 该SP从5分钟到30分钟完全执行（取决于记录的数量）。 一切都很好。 但我需要能够多次执行任务。 但是现在当我运行任务而另一个用户也运行任务时，这两个任务同时执行。 我需要在队列中输入任务，并且仅在第一个任务完成时执行。 我的settings.py： 
 
BROKER_URL = 'redis://localhost:6379/0'
CELERY_IMPORTS = ("pc.tasks", )
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_RESULT_BACKEND='djcelery.backends.cache:CacheBackend'
 
 tasks.py 
 
from __future__ import absolute_import
from celery.decorators import task
from celery import task, shared_task
from .models import Servicio, Proveedor, Lectura_FTP, Actualizar_Descarga
from .models import Lista_Archivos, Lista_Final, Buscar_Conci

@task
def carga_ftp():
    tabla = Proc_Carga()
    sp = tabla.carga()
    return None

@task
def conci(idprov,pfecha):
    conci = Buscar_Conci()
    spconc = conci.buscarcon(idprov,pfecha)
 
 我以这种方式在视图中调用任务： 
 
conci.delay(prov,DateV);
 
 如何创建或设置一个队列列表，并且只有在之前的抽签结束时才会执行任务 
 
 提前致谢 

I have an application made it with django using redis and celery for some asynchronous tasks. I am using the celery tasks to execute some stored procedures. This SP take from 5 mins to 30 mins to execute completely(depending in amount of records). Everything works great. But I need the be able to execute the tasks several times. but right now when I run task and another user run the task too, the two tasks are executed at the same time. I need the task enter in queue and only executed when the first task finish. My settings.py:
 
BROKER_URL = 'redis://localhost:6379/0'
CELERY_IMPORTS = ("pc.tasks", )
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_RESULT_BACKEND='djcelery.backends.cache:CacheBackend'
 
tasks.py
 
from __future__ import absolute_import
from celery.decorators import task
from celery import task, shared_task
from .models import Servicio, Proveedor, Lectura_FTP, Actualizar_Descarga
from .models import Lista_Archivos, Lista_Final, Buscar_Conci

@task
def carga_ftp():
    tabla = Proc_Carga()
    sp = tabla.carga()
    return None

@task
def conci(idprov,pfecha):
    conci = Buscar_Conci()
    spconc = conci.buscarcon(idprov,pfecha)
 
I call the tasks in my view in this way:
 
conci.delay(prov,DateV);
 
How can I create or setup a queue list of taks and everry tasks is executed only when the previous taks is finished
 
Thanks in advance

原文：https://stackoverflow.com/questions/29567488