herokuのレールでTwitter/Datasiftストリームを消費する方法

Question

herokuのレールを使用してストリーミングAPI（TwitterのストリーミングAPIなど）を消費するにはどうすればよいですか？それは、ストリームを消耗する労働者と一緒にスクリプトを実行することを含むでしょうか？これがリンクしていることを伝える文書がある既存のリソースがある場合、これまでのところほとんど見つけられていません。

Answer 1

あなたの2つのオプションは、ストリームを消費し、データストア（データベースなど）に書き込むスクリプトを実行するためのワーカーdynoを使用することです。または、レールアプリケーションのストリームの一部をHTTPリクエストに対するあなたの応答の一部。

これらのうちどれがあなたにとって理にかなっているかは、データで何をしようとしているか、必要なストリームの量によって決まります。

Answer 2

申し訳ありませんが、ソフトの答えのために、このコードのいずれかのアイデアがありません私自身の...

Herokuの上のバックグラウンドワーカーを使用せずにストリーミングAPIを消費する最も簡単な方法は、にEventMachine

を使用することですこのモデルは、あなたがこのような何かをしたい：詳細については

EM.schedule do 
    http = EM::HttpRequest.new(STREAMING_URL).get :head => { 'Authorization' => [ 'USERNAME', 'PASSWORD' ] } 
    buffer = "" 
    http.stream do |chunk| 
    buffer += chunk 
    while line = buffer.slice!(/.+\r?\n/) 
     handle_tweet JSON.parse(line) 
    end 
    end 
end 

はAdam Wiggins、Joslyn EsserとKenne Jima

を見て