इवेंटमैचिन और ट्विटर स्ट्रीमिंग एपीआई

Question

मैं ट्विटर स्ट्रीमिंग एपीआई का उपयोग कर इवेंटमैचिन प्रक्रिया चला रहा हूं। यदि स्ट्रीम की सामग्री अक्सर नहीं होती है तो मुझे हमेशा एक समस्या है।

यहाँ स्क्रिप्ट के न्यूनतम संस्करण है:

require 'rubygems' 
require 'eventmachine' 
require 'em-http' 
require 'json' 

usage = "#{$0} <user> <password> <track>" 
abort usage unless user = ARGV.shift 
abort usage unless password = ARGV.shift 
abort usage unless keywords= ARGV.shift 

def startIt(user,password,keywords) 
EventMachine.run do 
    http = EventMachine::HttpRequest.new("https://stream.twitter.com/1/statuses/filter.json",{:port=>443}).post(
        :head =>{ 'Authorization' => [ user, password ] } , 
        :body =>{"track"=>keywords}, 
        :keepalive=>true, 
        :timeout=>-1) 

    buffer = "" 
    http.stream do |chunk| 
    buffer += chunk 
    while line = buffer.slice!(/.+\r?\n/) 
     if line.length>5 
      tweet=JSON.parse(line) 
      puts Time.new.to_s+"#{tweet['user']['screen_name']}: #{tweet['text']}" 
     end 
    end 

    end 
    http.errback { 
     puts Time.new.to_s+"Error: " 
     puts http.error 
    } 
end 
    rescue => error 
     puts "error rescue "+error.to_s 
end 

while true 
    startIt user,password,keywords 
end 

अगर मैं "iPhone" की तरह एक कीवर्ड के लिए खोज, सब कुछ अच्छी तरह से काम करता है अगर मैं एक कम बार इस्तेमाल किया कीवर्ड के लिए खोज, मेरे धारा होने के लिए रहता है अंतिम संदेश के लगभग 20 सेकंड बाद, बहुत तेज़ी से बंद हो गया। नोट: कि http.error हमेशा खाली रहता है, इसलिए स्ट्रीम बंद होने पर समझना बहुत मुश्किल है ... दूसरी तरफ, बेवकूफ समान PHP संस्करण बंद नहीं है, इसलिए संभवतः इवेंटमाचिन/http- एम लेकिन मैं नहीं समझता कि कौन सा ...

Answer 1

आपको टाइमआउट से अपने कनेक्शन को रोकने के लिए सेटिंग्स जोड़नी चाहिए।

http = EventMachine::HttpRequest.new(
    "https://stream.twitter.com/1/statuses/filter.json", 
    :connection_timeout => 0, 
    :inactivity_timeout => 0 
).post(
    :head => {'Authorization' => [ user, password ] } , 
    :body => {'track' => keywords} 
) 

गुड लक, ईसाई