6

以下のエラーが表示されます。エラーは関数に追加delayする ときにのみ発生しprocess_uploadます。それ以外の場合は問題なく動作します。

誰かがこのエラーが何であるか、なぜそれが起こっているのか、解決するための推奨事項を説明できますか?

エラー：

PicklingError at /contacts/upload/configurator/47/
  Can't pickle <type 'function'>: attribute lookup __builtin__.function failed

これがビューです

 if request.method == 'POST':
        form = ConfiguratorForm(data=request.POST)
        # Send import to task.
        process_upload.delay(upload_id=upload.id, form=form)

これがタスクです

@task
def process_upload(upload_id, form):
    upload = Upload.objects.get(id=upload_id)
    upload.process(form=form)

Upload.process は私のモデル内にあります:

 def process(self, form):
        self.date_start_processing = timezone.now()
            import_this(data=self.filepath, extra_fields=[
                {'value': self.group_id, 'position': 5},
                {'value': self.uploaded_by.id, 'position': 6}], form=form)

完全なトレース:

Traceback:
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/django/core/handlers/base.py" in get_response
  115.                         response = callback(request, *callback_args, **callback_kwargs)
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/django/contrib/auth/decorators.py" in _wrapped_view
  25.                 return view_func(request, *args, **kwargs)
File "/Users/user/Documents/workspace/sms/contacts/views.py" in upload_configurator
  118.         process_upload.delay(upload_id=upload.id, form=form)
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/celery/app/task.py" in delay
  357.         return self.apply_async(args, kwargs)
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/celery/app/task.py" in apply_async
  472.                                      **options)
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/celery/app/amqp.py" in publish_task
  249.             **kwargs
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/kombu/messaging.py" in publish
  157.             compression, headers)
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/kombu/messaging.py" in _prepare
  233.              body) = encode(body, serializer=serializer)
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/kombu/serialization.py" in encode
  161.         payload = encoder(data)
File "/Users/user/Documents/workspace/sms/django-env/lib/python2.7/site-packages/kombu/serialization.py" in dumps
  340.         return dumper(obj, protocol=pickle_protocol)

Exception Type: PicklingError at /contacts/upload/configurator/47/
Exception Value: Can't pickle <type 'function'>: attribute lookup __builtin__.function failed

フォーム.py

COL_CHOICES = [
    ('N/A', 'No Import'),
    ('first_name', 'First Name'),
    ('last_name', 'Last Name'),
    ('company', 'Company'),
    ('mobile', 'Mobile Number'),
    ('email', 'Email Address'),
    ]


class ConfiguratorForm(forms.Form):
    col1 = forms.TypedChoiceField(choices=COL_CHOICES, initial='first_name')
    col2 = forms.TypedChoiceField(choices=COL_CHOICES, initial='first_name')
    col3 = forms.TypedChoiceField(choices=COL_CHOICES, initial='first_name')
    col4 = forms.TypedChoiceField(choices=COL_CHOICES, initial='first_name')
4

1 に答える 1

9

ConfiguratorForm の定義を提供しませんが、とにかく: 非同期実行では、タスクの引数が選択可能である必要があり、明らかにフォームはそうではありません。難しい方法で選択可能にすることもできますが、それは時間の無駄です。簡単な解決策は、フォームを渡さず、フォームのデータのみを渡すことです（iow：request.POST.copy（）ですが、Querydictが選択可能かどうかはわかりません）-または、最初にフォームを検証し、フォームのcleaned_dataのみを渡します無効なフォームを処理しても意味がないためです。

于 2013-04-18T20:23:43.020 に答える