3

私はDjangoにプログレスバーを実装しようとしています.http://djangosnippets.org/snippets/2898/を見つけたこのコードスニペットから参照していますが、何が起こっているのかわからないので私の努力は無駄ですメソッドタスクを実行するとき、セロリのtask_idfor は常に null です。それが私のコードです:

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_categoria次のcurrent_task.update_state(state='PROGRESS', meta={'current': porcentaje})トレースバックが表示されます。

Traceback:
    File "/Users/Tone/blog-env/lib/python2.7/site-packages/django/core/handlers/base.py" in get_response
      115.                         response = callback(request, *callback_args, **callback_kwargs)
    File "/Users/Tone/blog-env/lib/python2.7/site-packages/django/contrib/auth/decorators.py" in _wrapped_view
      25.                 return view_func(request, *args, **kwargs)
    File "/Users/Tone/Documents/Proyectos/dgp/ventas/forms.py" in add_categoria
      446.             job = upload_image_categoria(request).delay()
    File "/Users/Tone/blog-env/lib/python2.7/site-packages/celery/app/task.py" in __call__
      330.             return self.run(*args, **kwargs)
    File "/Users/Tone/Documents/Proyectos/dgp/ventas/forms.py" in upload_image_categoria
      462.         current_task.update_state(state='PROGRESS',meta={'current': i, 'total': 100})
    File "/Users/Tone/blog-env/lib/python2.7/site-packages/celery/app/task.py" in update_state
      695.         self.backend.store_result(task_id, meta, state)
    File "/Users/Tone/blog-env/lib/python2.7/site-packages/celery/backends/base.py" in store_result
      282.         self._store_result(task_id, result, status, traceback, **kwargs)
    File "/Users/Tone/blog-env/lib/python2.7/site-packages/celery/backends/amqp.py" in _store_result
      128.                             routing_key=task_id.replace('-', ''),

    Exception Type: AttributeError at /ventas/categorias/add/
    Exception Value: 'NoneType' object has no attribute 'replace'

それは、セロリ オプションの私の settings.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は正しく、設定は(おそらく正しいと思います)、常に同じ結果になります。 com.es/2013/07/django-celery-display-progress-bar-of.html )、それは完全に機能するので、なぜここにないのかわかりません。任意のアイデアをいただければ幸いです。

よろしく!

4

0 に答える 0