TwitterAPI/StreamingAPI の履歴(No.1)

• 履歴一覧
• 差分 を表示
• 現在との差分 を表示
• ソース を表示
• TwitterAPI/StreamingAPI へ行く。
  • 1 (2010-07-24 (土) 13:29:43)
  • 2 (2010-07-24 (土) 13:35:39)
  • 3 (2010-07-26 (月) 02:27:33)
  • 4 (2010-08-24 (火) 08:25:06)

目次†

参考情報†

• Streaming API Documentation | dev.twitter.com。公式ドキュメント。
• Twitter Streaming APIをRubyで試してみる - しばそんノート
• RubyからTwitterStreamingAPIを使うgem作ったよ！ - yayuguのにっき

基本†

• BASIC認証で使える。一つのアカウントで一つのみ。

Rubyのサンプルコード†

#!/usr/bin/env ruby
# coding: utf-8

require 'net/http'
require 'uri'
require 'rubygems'
require 'json'

USERNAME = '_USERNAME_' # ここを書き換える
PASSWORD = '_PASSWORD_' # ここを書き換える

# URLが変更になってるみたい(2010/07/22)
#uri = URI.parse('http://stream.twitter.com/spritzer.json')
uri = URI.parse('http://stream.twitter.com/1/statuses/sample.json')

Net::HTTP.start(uri.host, uri.port) do |http|
  request = Net::HTTP::Get.new(uri.request_uri)
  # Streaming APIはBasic認証のみ
  request.basic_auth(USERNAME, PASSWORD)
  http.request(request) do |response|
    raise 'Response is not chuncked' unless response.chunked?
    response.read_body do |chunk|
      # 空行は無視する = JSON形式でのパースに失敗したら次へ
      status = JSON.parse(chunk) rescue next
      # 削除通知など、'text'パラメータを含まないものは無視して次へ
      next unless status['text']
      user = status['user']
      puts "#{user['screen_name']}: #{status['text']}"
    end
  end
end

Tweepy(Python)のサンプルコード†

#!/usr/bin/python
# -*- coding: utf-8 -*-
 
import sys
import tweepy
import simplejson

#from pit import Pit
 
class StreamListener(tweepy.StreamListener):
  def on_data(self, data):
    data = simplejson.loads(data)
    if data.has_key('text'):
      print data['text']
 
def main():
  user   = 'xxxxx'
  passwd = 'yyyyy'
  stream = tweepy.Stream(user, passwd, StreamListener())
  stream.filter(track=('#nhk',))
if __name__ == "__main__":
  main()

streaming.pyで処理が行われている。

    def filter(self, follow=None, track=None, async=False):
        params = {}
        self.headers['Content-type'] = "application/x-www-form-urlencoded"
        if self.running:
            raise TweepError('Stream object already connected!')
        self.url = '/%i/statuses/filter.json?delimited=length' % STREAM_VERSION
        if follow:
            params['follow'] = ','.join(map(str, follow))
        if track:
            params['track'] = ','.join(map(str, track))
        self.body = urllib.urlencode(params)
        self._start(async)