Django et Céleri: incapable de tâche de conserves au vinaigre

Question

merci à l'avance :)

J'ai ce async appel tâche Céleri:

update_solr.delay(id, context) 

où id est un entier et le contexte est un dict Python.

Ma définition de tâche ressemble à:

@task 
def update_solr(id, context): 
    clip = Clip.objects.get(pk=id) 
    clip_serializer = SOLRClipSerializer(clip, context=context) 
    response = requests.post(url, data=clip_serializer.data) 

où clip_serializer.data est un dict et url est une chaîne représentant une URL.

Quand je tente d'appeler update_solr.delay(), je reçois cette erreur:

PicklingError: Can't pickle <type 'instancemethod'>: attribute lookup __builtin__.instancemethod failed 

Aucune des args à la tâche sont des méthodes d'instance, donc je suis confus.

Lorsque le code de tâche est exécuté de manière synchrone, aucune erreur.

Mise à jour: Correction de commentaires sur le passage de pk au lieu de l'objet.

Answer 1

Le context dict avait un objet en elle, à mon insu ...

Pour fixer, j'exécuté le code dépendant de la context avant l'appel async et vient de passer un dict avec seulement les types natifs:

def post_save(self, obj, created=False): 
    context = self.get_serializer_context() 
    clip_serializer = SolrClipSerializer(obj, context=context) 
    update_solr.delay(clip_serializer.data) 

la tâche a fini comme ceci:

@task 
def update_solr(data): 
    response = requests.post(url, data=data) 

cela fonctionne parfaitement bien parce que le seul but d'en faire une tâche async est pour rendre le POST non bloquant.

Merci pour l'aide!

Answer 2

import pickle 
class X: 
    def y(self): 
     pass 

pickle.dumps(X.y) 

Pickle fonctionne récursive de sorte qu'il pourrait être n'importe où dans votre objet graphique. Vous avez reçu la solution - ne transférer que les objets minimaux, c'est-à-dire les clés primaires et autres, à la place des objets du modèle Django.

Answer 3

Essayez de passer la clé primaire de l'instance de modèle (pk). Ceci est beaucoup plus simple à décaper, réduit la charge utile et évite les conditions de course.