使用Google App Engine隊列服務與Django

我想使用Google App Engine隊列API，我在測試這個時遇到問題。看起來在CSRF的某些部分，它不起作用。使用Google App Engine隊列服務與Django

據我所知，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中間件，餅乾，一些數據或響應本身是從失蹤GAE api在後臺執行任務所做的請求。

如何解決這個問題，而不禁用Django的CSRF？然而，它可以與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）」以獲取輸出。

來源

2011-01-26 Mario César