Django celery任务_id为nu

2024-04-18 08:55:54 发布

您现在位置:Python中文网/ 问答频道 /正文

我试图在Django中实现一个进度条,我从我找到的代码片段中引用了http://djangosnippets.org/snippets/2898/,但我的努力都在风向标上,因为我不知道发生了什么,但是celery的task_id在执行方法任务时总是空的,这是我的代码:

def add_categoria(request):
        if request.POST:
            form_cat = CategoriaModelForm(request.POST,request.FILES)
            if form_cat.is_valid():
                file = request.FILES['imagen']
                job = upload_image_categoria(request).delay()
                request.session['task_id'] = job.id
                return HttpResponse(json.dumps({'task_id':job.id}))
            else:
                return HttpResponseBadRequest(json.dumps(form_cat.errors),
                                            mimetype="application/json")
        else:
             form = CategoriaModelForm()
             return render_to_response("ventas/form.html",{'form':form},context_instance=RequestContext(request))


@task()
def upload_image_categoria(request):
        form = CategoriaModelForm(request.POST, request.FILES)
        path = MEDIA_ROOT+'/categorias/%s' % form.cleaned_data['imagen'].name
        file = request.FILES['imagen']
        destination = open(path, 'wb+')
        porcentaje = 0
        acum = 0
        for chunk in file.chunks():
            time.sleep(0.1)
            current_task.update_state(state='PROGRESS', meta={'current': porcentaje})
            acum += len(chunk)
            porcentaje = int((acum*100)/file.size)
            destination.write(chunk)

@csrf_exempt
def upload_state(request):
       """ A view to report the progress to the user """
       data = 'Fail'
       if request.is_ajax():
           if 'task_id' in request.POST.keys() and request.POST['task_id']:
               task_id = request.POST['task_id']
               task = AsyncResult(task_id)
               data = task.result or task.state
           else:
               data = 'No task id'
       else:
           data = 'This is not an ajax request'
       json_data = json.dumps(data)
       return HttpResponse(json_data, mimetype='application/json')

所以,当我在upload_image_categoriacurrent_task.update_state(state='PROGRESS', meta={'current': porcentaje})报告进度条的状态时,我总是得到这个回溯:

^{pr2}$

那是我的设置.py芹菜选项:

    BROKER_URL = "amqp://guest@localhost:5672//"
    CELERY_IMPORTS = ("ventas.forms",)
    CELERY_TRACK_STARTED = True
    CELERY_RESULT_BACKEND = "amqp"
    CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'
    CELERY_RESULT_DBURI = "mysql://root@localhost/dgp"

所以我不知道发生了什么,worker是正确的,设置(我猜,是正确的),而且我总是得到相同的设置,我证明在其他一些项目相同的设置(这个项目特别是http://iambusychangingtheworld.blogspot.com.es/2013/07/django-celery-display-progress-bar-of.html)和它完美地工作,所以我不知道为什么这里不,我遗漏了一些东西?任何想法都将不胜感激。在

问候!在


Tags: formidjsontaskdatareturnifrequest