在 Django 中使用 Google App Engine Queues 服务

Mar*_*sar 3 python django google-app-engine task-queue

我正在尝试使用 Google App Engine 队列 API,但在测试时遇到问题。似乎在流程的某些部分,CSRF 不起作用。

据我了解,api 在后台执行调用 url 和发出 http 请求的任务。

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'
Run Code Online (Sandbox Code Playgroud)

因此,GAE api 为在后台执行任务而发出的请求中缺少 csrf 中间件、cookie、某些数据或响应本身。

如何在不禁用 Django 上的 CSRF 的情况下解决这个问题?但是,它完全可以与 djangoappengine 一起使用吗?

下面是我正在使用的 models.py 和 admin.py 文件。

模型.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()
Run Code Online (Sandbox Code Playgroud)

管理文件

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)
Run Code Online (Sandbox Code Playgroud)

重要说明: 很难调试这个错误,因为 dev_appserver 记录器只是引发 403 错误,没有其他信息;因此,我必须修补文件 google/appengine/api/taskqueue/taskqueue_stub.py 第 574 行并添加“logging.info('response --- \n%s' % result)”以获取输出。

Dav*_*eck 5

如果您CsrfViewMiddleware启用了该选项,Django 将要求csrf_token在您的视图中的所有 POST 中添加一个。

Django 提供了一个装饰器 ,@csrf_exempt你应该把它放在你的任务队列视图中。这将仅针对这些视图关闭中间件。

或者,您可以CsrfViewMiddleware完全避免使用,而是@csrf_protect在需要的地方使用装饰器。我不建议这样做——保护无处不在并为您的任务队列视图制定少量豁免可能更安全。

(最后一个注意事项:上面的两个答案——你的视图有问题,或者你应该只对任务队列使用 GET——我错了。你的视图没有任何问题,POST 是正确的动词使用用于任务队列任务。)