redis pubsub を介してリアルタイムで金融ティック データを送信するプロセスがあります。ここで、移動平均などのインスタンス計算のために、Python アプリケーションで入力データ (json) を処理する必要があります。redis を介して他のタスクに送り返したい結果 (最初のタスクの結果に基づいてさらに計算を行う)。さらに、1 日または 1 秒ごとに定期的にいくつかのタスクをトリガーしたいと考えています。この複雑で予期せぬ構造の問題により、gevent、Celery、または単なるスレッドなどのソリューションに出くわしました。
しかし、私が疑問に思っているのは、これを正しい方法で行うためのオプションは何ですか? ワーカー/タスクを最も効率的な方法で実行して、redis pubsub を構成するにはどうすればよいですか? そのため、ライブラリの行 (上記のいずれかを使用したことがある場合は、経験を共有してください)、テクニック (Python の構造のベスト プラクティス)、redis の pubsub を使用して最善の方法で作業を行う方法など、提案を歓迎します。