2017-07-08 11 views
0

セロリによって提供されるタスクイベントを使用してタスク引数を取得したい。 私はバックエンドとブローカー(シリアライザとしてのピクル)としてredisを使用しています。ドキュメントによると、task-receivedハンドラを聞いてこの情報を得ることができます。ここではargsが読み込まれます。セロリイベントのキャプチャ

私が直面している問題は、小さなデータ入力の場合、これは期待どおりに機能します。大きな入力(バイナリファイル〜16MB)を使用すると、イベントによって受け取られたargsははるかに小さくなり、切り詰められます。

誰もがこの理由を知っていますか?助けてくれてありがとう!

答えて

1

セロリには、イベントにプッシュされるデータのサイズに制限があります。

repr_maxsizeを使用して設定できます。

私は推測していますが、これはおそらく重要なパフォーマンスの低下を招き、避けるべきです。

+0

ありがとうございます!赤目からそれを得ることは可能でしょうか? 私は 'AsyncResult'をチェックしましたが、argsはそこにありません。 – tha4