如何在heroku上使用twitter/datasift流與軌道

Question

如何使用heroku上的rails來使用流式API（如Twitter流式API）？它是否涉及使用消耗流的工作器來運行腳本？如果有任何現有資源記錄此鏈接，我目前還找不到多少。

Answer 1

你的兩個選擇是使用工人dyno來運行一個消耗流的腳本並將其寫入數據存儲區（數據庫等），或者在你的rails應用程序中動態獲取部分流部分對HTTP請求的響應。

哪一個對你來說是有意義的取決於你想要對數據做什麼以及你需要多少流。

Answer 2

很抱歉的回答柔和，沒有這個代碼或想法是我自己......

消耗流API，而不使用在Heroku後臺工作的最簡單的方法是使用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