· 5 years ago · Mar 06, 2021, 07:54 AM
1from __future__ import print_function
2import tweepy
3import json
4import datetime
5keywords = ["Jihad", "jihad", "JIHAD"]
6f = open("Hasil.txt", "w")
7CONSUMER_KEY = "IaXvUIIAPgMawQLU4gBgSMikN"
8CONSUMER_SECRET = "NSefcCBNerSvTcDrqqa0IDKlfew0yfkNQUD9shamu7lCBd55nl"
9ACCESS_TOKEN = "1270862959527378944-gQN7VSrvGZNy0bjOPeYhpbumLvffhi"
10ACCESS_TOKEN_SECRET = "wHlVyr4IByMlSO89tmZGf1I4D5hN0UsRyRLSYIzsMmdcp"
11class StreamListener(tweepy.StreamListener):
12 def on_connect(self):
13 print("You are now connected to the streaming API.")
14 def on_error(self, status_code):
15 print("An Error has occured: " + repr(status_code))
16 return False
17 def on_data(self, data):
18 try:
19 datajson = json.loads(data)
20 username = datajson["user"]["screen_name"]
21 cuitan = datajson["text"].lower()
22 tweet = [{"User Name":username, "Tweet":cuitan}]
23 tulis = str(tweet)+"\n"
24 f.write(tulis)
25 except Exception as e:
26 print(e)
27auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET) #autentikasi ke api twitter deengan konsumer key dan consumer secret
28auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET) #set acces token
29listener = StreamListener(api=tweepy.API(wait_on_rate_limit=True)) #gunakan listener tweet
30streamer = tweepy.Stream(auth=auth, listener=listener) #gunakan streamer
31streamer.filter(track=keywords)