Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #Import the necessary methods from tweepy library
- import tweepy, codecs
- import pymysql
- import time
- #Variables that contains the user credentials to access Twitter API
- access_token = "1224754879-W3GemB5jCRm4VTrPPS13rgLhPGLpzoiEt1iARa8"
- access_token_secret = "aJEUW4k9fBIQ5rcYYRGpH0UzzXByV6rMoYUSIJHYqxYwe"
- consumer_key = "yxAbP3ypx6AbO8YfcKzsIVkdW"
- consumer_secret = "hFOb7Ss4qY9mlQLwdm1A32jcO0y4ivuzG6brY2VxFORosVEw0s"
- #Authentication
- auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
- auth.set_access_token(access_token, access_token_secret)
- api = tweepy.API(auth)
- #Declare Connection
- conn = pymysql.connect(host='localhost', port='', user='root', passwd='', db='test', use_unicode=True, charset="utf8mb4")
- cur = conn.cursor()
- #Get Current Date Time
- curdatetime = time.strftime("%Y-%m-%d %H:%M:%S")
- cur.execute("DELETE FROM tweet order by id desc LIMIT 500")
- #Get last id from table tweet
- last_id = 0
- cur.execute("SELECT MAX(id) FROM tweet")
- result = cur.fetchall()
- for row in result:
- last_id = row[0]
- print ("Last ID : " + str(last_id))
- #Get Number of Tweet
- user = api.get_user(108543358)
- print ("Name:", user.name)
- print ("Name:", user.screen_name)
- print ("Number of tweets: " + str(user.statuses_count))
- print ("followers_count: " + str(user.followers_count))
- print ("Account location: ", user.location)
- print ("Account created at: ", user.created_at)
- n = 0
- for Tweet in tweepy.Cursor(api.user_timeline, id=108543358, q = "#Gempa", lang = id, result_type = "recent", since_id = last_id).items(3):
- print ("*****" + str(i) +"*****")
- print ("ID: " + Tweet.id_str)
- print ("Text: " + str(Tweet.text.encode("utf-8")))
- print ("Retweet Count: " + str(Tweet.retweet_count))
- print ("Favorite Count: " + str(Tweet.favorite_count))
- print ("Date Time: " + str(Tweet.created_at))
- #print (str(Tweet.location)) #how to get geolocation data for mapping ?
- print ("************")
- n = n + 1
- cur.execute("INSERT INTO tweet (no, id, text, retweet_count, favourite_count, date_time) VALUES (%s, %s,%s,%s,%s,%s)",
- (str(n), Tweet.id_str, Tweet.text.encode("utf-8"), str(Tweet.retweet_count), str(Tweet.favorite_count), str(Tweet.created_at)))
- conn.commit()
- cur.close()
- conn.close()
Add Comment
Please, Sign In to add comment