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 [ ]: