In [ ]:
import tweepy
In [ ]:
consumer_key = ''
consumer_secret = ''
access_token = ''
access_token_secret = ''
In [ ]:
autorizar = tweepy.OAuthHandler(consumer_key, consumer_secret)
autorizar.set_access_token(access_token, access_token_secret)
In [ ]:
class DadosPublicosTwitter(tweepy.StreamListener):
def on_data(self, dados):
print(dados)
return False
In [ ]:
dados_twitter = DadosPublicosTwitter()
fluxo = tweepy.Stream(autorizar, dados_twitter)
In [ ]:
fluxo.filter(track=['Big Data'])
Note que os dados que foram retornados estão no formato JSON. Veja o notebook sobre JSON
In [ ]:
class DadosPublicosTwitter(tweepy.StreamListener):
def __init__(self):
self.salvar_arquivo = open('tweets.json', mode='a')
def on_data(self, dados):
self.salvar_arquivo.write(dados)
In [ ]:
dados_twitter = DadosPublicosTwitter()
In [ ]:
fluxo = tweepy.Stream(autorizar, dados_twitter)
In [ ]:
try:
fluxo.filter(track=['Big Data'])
except KeyboardInterrupt:
print("\n\n **Execução foi encerrada via teclado (Ctrl+C)**")
Ótimo! Já estamos conseguindo salvar os tweets em um arquivo. Porém ainda temos alguns tratamentos que precisam ser realizados:
1) Falta fechar o arquivo;
2) Falta finalizar a execução do Streaming;
3) Cada tweet deve ficar em uma linha; Abra o arquivo tweets.json e veja que existe uma linha em branco entre os tweets salvos.
Vamos ao próximo Desafio!!!
In [ ]: