一般的に、コードはつぶやきを収集して処理し、データベースにいくつかの統計を保存する必要があります。Twitter Stream API には phirehose lib を使用しているため、常にツイートをストリーミングしています。私が理解している限り、同じプロセスでツイートを解析することはできないため、他のプロセスでツイートを解析する必要があります。そのため、phirehose lib はツイートを取得してどこかに保存するか、他のプロセス (またはプロセス) のためにメモリにキューイングする必要があります。それらを解析してdbに保存します。だから私は車輪を再発明したくないので、そのようなデータ処理を可能にするコードのスニペットやライブラリがあるかもしれませんか?