Использование службы очередей Google App Engine с Django - PullRequest
3 голосов
/ 26 января 2011

Я пытаюсь использовать API очередей Google App Engine, у меня возникают проблемы при тестировании.Кажется, что в какой-то части процесса CSRF не работает.

, как я понимаю, API выполняет задачу, вызывающую URL-адрес и выполняющий запрос http в фоновом режиме.

Полный URL-адресAPI вызывает → http://localhost.localdomain:8000/admin/cooking/recipe/36/chefworker/

Когда возникает это исключение:

Traceback (most recent call last):
  File "/home/mariocesar/Proyectos/Cooking/cooking/django/core/handlers/base.py", line 100, in get_response
    response = callback(request, *callback_args, **callback_kwargs)
  File "/home/mariocesar/Proyectos/Cooking/cooking/django/views/decorators/csrf.py", line 24, in wrapped_view
    resp.csrf_exempt = True
AttributeError: 'NoneType' object has no attribute 'csrf_exempt'

Итак, промежуточное программное обеспечение csrf, cookie, некоторые данные или сам ответ отсутствуют в запросечто GAE API делает для выполнения задачи в фоновом режиме.

Как решить эту проблему, не отключая CSRF на Django?однако, это возможно с djangoappengine вообще?

Внизу находятся файлы models.py и admin.py, которые я использую.

models.py

from django.db import models

class Recipe(models.Model):
    name = models.CharField(max_length=140)
    description = models.TextField()
    cooking_time = models.PositiveIntegerField()
    status = models.CharField(max_length=40)

    def __unicode__(self):
        return self.name

    def cookthis(self):
        import time
        self.status = 'The chef is cooking this recipe'
        self.save()
        time.sleep(obj.cooking_time)
        self.status = 'It\'s done ! the recipe is ready to serve'
        self.save()

admin.py

import logging

from django.contrib import admin, messages
from django.http import HttpResponse
from django.utils.functional import update_wrapper
from django.contrib.admin.util import unquote
from django.shortcuts import get_object_or_404, render_to_response
from django import template
from django.core.urlresolvers import reverse
from google.appengine.api import taskqueue
from google.appengine.api.taskqueue import TaskAlreadyExistsError

from cooking.models import Recipe
from django.views.decorators.csrf import csrf_exempt

class AdminRecipe(admin.ModelAdmin):
    def get_urls(self):
        from django.conf.urls.defaults import patterns, url

        def wrap(view):
            def wrapper(*args, **kwargs):
                return self.admin_site.admin_view(view)(*args, **kwargs)
            return update_wrapper(wrapper, view)

        info = self.model._meta.app_label, self.model._meta.module_name

        urlpatterns = super(AdminRecipe, self).get_urls()
        myurls = patterns('',
            url(r'^(.+)/cook/$',
                wrap(self.cook_view),
                name='%s_%s_chefworker' % info),
            url(r'^(.+)/chefworker/$',
                wrap(self.chefworker_worker),
                name='%s_%s_chefworker' % info),
        )
        return myurls + urlpatterns

    def cook_view(self, request, object_id, extra_context=None):
        obj = get_object_or_404(Recipe, pk=unquote(object_id))
        if request.POST:
            try:
                taskqueue.add(
                    name="recipie-%s" % obj.id,
                    url=reverse('admin:cooking_recipe_chefworker', args=(obj.id,))
                )
                messages.add_message(request, messages.INFO, 'Chef is cooking the recipe.')
            except TaskAlreadyExistsError:
                messages.add_message(request, messages.ERROR, 'chef is already cooking that recipe.')

        context_instance = template.RequestContext(request, current_app=self.admin_site.name)
        return render_to_response("admin/cooking/recipe/cook_view.html", {'object': obj}, context_instance=context_instance)

    #TODO: Add csrf token on form
    @csrf_exempt
    def chefworker_worker(self, request, object_id, extra_context=None):
        import time

        if request.POST:
            obj = get_object_or_404(Recipe, pk=unquote(object_id))
            obj.cookthis()

        return HttpResponse('done')

admin.site.register(Recipe, AdminRecipe)

ВАЖНОЕ ПРИМЕЧАНИЕ: Сложно было отладить эту ошибку, потому что регистратор dev_appserver просто выдавал 403 ошибки, никакой другой информации;поэтому я должен пропатчить файл google / appengine / api / taskqueue / taskqueue_stub.py строка 574 и добавить «logging.info ('response --- \ n% s'% result)", чтобы получить вывод.

Ответы [ 3 ]

4 голосов
/ 18 марта 2011

Если у вас включен CsrfViewMiddleware, Django потребует csrf_token во всех POST для ваших представлений.

Django предоставляет декоратор, @csrf_exempt, который вы должны поместить в представления вашей очереди задач.,Это отключает промежуточное ПО только для этих представлений.

В качестве альтернативы, вы можете вообще не использовать CsrfViewMiddleware и вместо этого использовать декоратор @csrf_protect там, где вам это нужно.Я не рекомендую делать это - возможно, безопаснее защищать везде и выделять небольшое количество исключений для представлений в очереди задач.

(Последнее замечание: оба ответа выше - что-то не так сваше мнение, или что вы должны просто использовать GET для очереди задач - не поймите меня неправильно. В вашем представлении нет ничего плохого, и POST - правильный глагол для задач очереди задач.)

3 голосов
/ 27 января 2011

Глядя на источник файла csrf.py, похоже, что это произойдет, только если ваша функция представления возвращает None (или не возвращает явно, в этом случае Python неявно возвращает None).Глядя на ваш код, я не понимаю, как это могло произойти, - вы уверены, что это именно ваш развернутый код?

Кроме того, вы, вероятно, не хотите использовать get_object_or_404 в очереди задачзадача - если он не может найти объект, он выдаст 404, что приведет к ошибке и повторной попытке задания на неопределенное время.

Вам также не нужна защита от CSRF (согласно вашему TODO);Вместо этого убедитесь, что URL-адрес очереди задач помечен только для администратора и будет вызываться только службой очереди задач.

1 голос
/ 26 января 2011

Я не эксперт, но вы можете попробовать использовать GET вместо POST.См. http://groups.google.com/group/django-non-relational/browse_thread/thread/e6baed5291aed957/d6c42150c8e246e1?lnk=gst&q=queue#d6c42150c8e246e1 (последняя запись)

...