Capture d'arguments d'événements de céleri

Question

Je veux capturer des arguments de tâche en utilisant les événements de tâche fournis par céleri. J'utilise redis comme backend et broker (Pickle comme serializer). Selon la documentation, il est possible d'obtenir cette information en écoutant le gestionnaire task-received, où les arguments seront remplis.

Le problème que je suis confronté est, pour la petite entrée de données cela fonctionne comme prévu. Lorsque j'utilise une grande entrée (fichier binaire - ~ 16 Mo), les args reçus par les événements sont beaucoup plus petits et tronqués.

Est-ce que quelqu'un sait la raison pour cela? Merci pour l'aide!

Answer 1

Céleri a une limite sur la taille des données transmises à un événement. Il est configurable avec repr_maxsize.

Je suppose, mais cela a probablement des pénalités de performance significatives et devrait être évitée.