Python_Twitter/tweeterstream_Database.py at master · bejoyalduse/Python_Twitter · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
# -*- coding: utf-8 -*-
"""
Created on Tue Dec 3 11:06:08 2019

@author: bejoyalduse
"""

from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener
import json
import io
import sys

# Refer twitter for api
# https://developer.twitter.com/en/docs/basics/authentication/guides/access-tokens


api_key = "**************"
api_secret = "**************"
access_token_key = "**************"
access_token_secret = "**************"

data1={}
tweets = {}
index = 0
class listener(StreamListener):
    index +=1
    if index == 20:
        sys.exit()

    def on_data(self, data):
        try:
            #index+=1
            print data
            tweet = data.split(',"text":"')[1].split(',"source":"')[0]
            #print tweet
            saveThis = tweet

            saveFile = open('twitDB00.csv', 'a')
            saveFile.write(saveThis)
            saveFile.write('\n')
            saveFile.close()

            #t1 = json.load(data)
            tweets= data
            saveFiletext1 = open("twitDB01.txt","a")
            json.dump(tweets,saveFiletext1)
            saveFiletext1.close()

            saveFiletext = open('twitDB02.json', 'a')
            saveFiletext.write(data)
            #saveFiletext.write('\n')
            saveFiletext.close()
            #data1.append(data)


            return True
        except BaseException, e:
            print 'failed ondata,', str(e)
            #time.sleep(5)

    def on_error(self, status):
        print status

auth = OAuthHandler(api_key, api_secret)
auth.set_access_token(access_token_key, access_token_secret)

twitterStream = Stream(auth, listener())
twitterStream.filter(track=["NFL"])