Ich möchte Aufgabenargumente mit den Aufgabenereignissen von Sellerie erfassen erfassen. Ich verwende redis als Backend und Broker (Pickle als Serializer). Laut der Dokumentation ist es möglich, diese Informationen zu erhalten, indem Sie den Handler task-received
abhören, in dem die Argumente eingetragen werden.Sellerie Ereignis args Erfassung
Das Problem, das ich gegenüberstelle, ist, für kleine Dateneingabe funktioniert dies wie erwartet. Wenn ich eine große Eingabe (Binärdatei - ~ 16MB) verwende, sind die von Ereignissen empfangenen Argumente viel kleiner und abgeschnitten.
Kennt jemand den Grund dafür? Danke für die Hilfe!
Danke! Wird es möglich sein, es von redis zu bekommen? Ich habe 'AsyncResult' überprüft, aber Argumente sind nicht da. – tha4