我试图在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_categoria
在current_task.update_state(state='PROGRESS', meta={'current': porcentaje})
报告进度条的状态时,我总是得到这个回溯:
那是我的设置.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)和它完美地工作,所以我不知道为什么这里不,我遗漏了一些东西?任何想法都将不胜感激。在
问候!在
目前没有回答
相关问题 更多 >
编程相关推荐