Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/usr/bin/env python
- try:
- import json as simplejson
- except ImportError:
- import simplejson
- import twitstream
- import MySQLdb
- USER = ''
- PASS = ''
- USAGE = """%prog"""
- conn = MySQLdb.connect(host = "",
- user = "",
- passwd = "",
- db = "")
- # Define a function/callable to be called on every status:
- def callback(status):
- twitdb = conn.cursor ()
- twitdb.execute ("INSERT INTO tweets_unprocessed (text, created_at, twitter_id, user_id, user_screen_name, json) VALUES (%s,%s,%s,%s,%s,%s)",(status.get('text'), status.get('created_at'), status.get('id'), status.get('user', {}).get('id'), status.get('user', {}).get('screen_name'), status))
- # print status
- #print "%s:\t%s\n" % (status.get('user', {}).get('screen_name'), status.get('text'))
- if __name__ == '__main__':
- # Call a specific API method from the twitstream module:
- # stream = twitstream.spritzer(USER, PASS, callback)
- twitstream.parser.usage = USAGE
- (options, args) = twitstream.parser.parse_args()
- if len(args) < 1:
- args = ['Blackberry']
- stream = twitstream.track(USER, PASS, callback, args, options.debug, engine=options.engine)
- # Loop forever on the streaming call:
- stream.run()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement