twitter_test.py

# -*- coding: utf-8 -*-

import json
import urllib2
import oauth2 as oauth


def streaming():
	consumer_key = ''
	consumer_secret = ''

	token_key = ''
	token_secret = ''

	consumer = oauth.Consumer(key = consumer_key, secret = consumer_secret)
	token = oauth.Token(key = token_key, secret = token_secret)

	url = 'https://stream.twitter.com/1.1/statuses/filter.json'
	params = {'track':'#nowplaying'}

	request = oauth.Request.from_consumer_and_token(consumer, token, http_url = url, parameters=params)
	request.sign_request(oauth.SignatureMethod_HMAC_SHA1(), consumer, token)
	res = urllib2.urlopen(request.to_url())

	for r in res:
		
		data = json.loads(r)
		
		try:
			if data['user']['lang'] == 'ja':
				
				print data['user']['screen_name']
				print data['text']
				print
				
		except:
			pass
			

if __name__ == '__main__':
	streaming()