In [6]:
import tweepy
from time import time, sleep
In [7]:
consumer_key = 'M6OkpsVkxMo1m4oEpcKrxTG9L'
consumer_secret = 'huUxJYdPoddEkvRrmDOFQIuHspkBERTCshx2J5tcj7FeAFdgNp'
access_token = '13101632-jfzgS37obVEw5vEQhkg3iHuMSgZFwAnLz55OZcVyi'
access_token_secret = 'CeoEHGH6fzrFH1PbXxSwCvmL04rD6nQElJzKgMnAj9AY9'
In [8]:
autorizar = tweepy.OAuthHandler(consumer_key,consumer_secret)
In [9]:
autorizar.set_access_token(access_token,access_token_secret)
In [10]:
class DadosPublicosTwitter(tweepy.StreamListener):
def __init__(self, nome_arquivo, limit=300):
self.tempo_inicial = time()
self.limite = limit
self.arquivo = open(nome_arquivo, mode='a', newline='')
def on_data(self, dados):
if(time()-self.tempo_inicial < self.limite):
self.arquivo.write(dados)
else:
self.arquivo.close()
return False
In [11]:
dados_twitter = DadosPublicosTwitter()
In [12]:
fluxo = tweepy.Stream(autorizar,dados_twitter)
In [13]:
try:
fluxo.filter(track=['folha','folha de s.paulo', 'folha de sao paulo'])
except KeyboardInterrupt:
print("\n Finalizado via teclado")
In [ ]: