PF0F78Hx

1from twython import TwythonStreamer
2import argparse
3
4parser = argparse.ArgumentParser(description='Crispy Streamer')
5parser.add_argument('--app_key', help='app_key')
6parser.add_argument('--app_secret', help='app_secret')
7parser.add_argument('--oauth_token', help='oauth_token')
8parser.add_argument('--oauth_secret', help='oauth_secret')
9parser.add_argument('--term', help='term', default='crispy')
10
11args = parser.parse_args()
12
13APP_KEY = args.app_key
14APP_SECRET = args.app_secret
15OAUTH_TOKEN = args.oauth_token
16OAUTH_SECRET = args.oauth_secret
17TERM = args.term
18
19class CrispyStreamer(TwythonStreamer):
20  def __init__(self, a, b,c,d):
21    TwythonStreamer.__init__(self, a, b, c, d)
22  def on_success(self, data):
23    if 'text' in data:
24      print(data['text'].encode('utf-8'))
25
26try:
27  stream = CrispyStreamer(APP_KEY, APP_SECRET, OAUTH_TOKEN, OAUTH_SECRET)
28  stream.statuses.filter(track=TERM)
29except KeyboardInterrupt:
30  pass