Django-Celery进度条

Question

Django-Celery进度条

der*_*evo 18 django django-celery

我用:

芹菜
Django的芹菜
的RabbitMQ

我可以在Django管理页面中看到我的所有任务,但目前它只有几个状态,例如:

RECEIVED
重试
撤销的
成功
已启动
失败
PENDING

这对我来说还不够.是否可以向管理页面添加有关正在运行的进程的更多详细信息？像进度条或完成的工作柜台等

我知道如何使用Celery日志记录功能,但出于某些原因,GUI在我的情况下更好.

那么,是否可以将一些跟踪信息发送到Django-Celery管理页面？

Answer 1

Flo*_*ser 30

这是我的最小进度报告Django后端使用您的设置.我还是一个Django n00b,这是我第一次搞乱Celery,所以这可能会被优化.

from time import sleep

from celery import task, current_task
from celery.result import AsyncResult

from django.http import HttpResponse, HttpResponseRedirect
from django.core.urlresolvers import reverse
from django.utils import simplejson as json
from django.conf.urls import patterns, url


@task()
def do_work():
    """ Get some rest, asynchronously, and update the state all the time """
    for i in range(100):
        sleep(0.1)
        current_task.update_state(state='PROGRESS',
            meta={'current': i, 'total': 100})


def poll_state(request):
    """ A view to report the progress to the user """
    if 'job' in request.GET:
        job_id = request.GET['job']
    else:
        return HttpResponse('No job id given.')

    job = AsyncResult(job_id)
    data = job.result or job.state
    return HttpResponse(json.dumps(data), mimetype='application/json')


def init_work(request):
    """ A view to start a background job and redirect to the status page """
    job = do_work.delay()
    return HttpResponseRedirect(reverse('poll_state') + '?job=' + job.id)


urlpatterns = patterns('webapp.modules.asynctasks.progress_bar_demo',
    url(r'^init_work$', init_work),
    url(r'^poll_state$', poll_state, name="poll_state"),
)

Run Code Online (Sandbox Code Playgroud)