POST イベントをリッスンしてさまざまなフィーダーからリアルタイム イベントを収集する Python asyncio と aiohttp を使用して、 RESTful マイクロサービスを正常に構築しました。
次に、メモリ内構造を構築して、最後の 24 時間のイベントをネストされた defaultdict/deque 構造にキャッシュします。
ここで、できればピクルを使用して、その構造をディスクに定期的にチェックポイントしたいと思います。
メモリ構造は 100MB を超える可能性があるため、構造のチェックポイントにかかる時間、着信イベントの処理を遅らせたくありません。
構造のスナップショット コピー (deepcopy など) を作成してから、時間をかけてディスクに書き込み、事前に設定した時間間隔で繰り返します。
スレッドを組み合わせる方法の例を探していました (そして、スレッドはこれに対する最良の解決策でもありますか?) とその目的のための asyncio ですが、私を助けるものを見つけることができませんでした.
始めるための指針は大歓迎です！