Desafio 1

1. Entender a API de Streaming do Twitter

Ver slides 14 até 21.

Da mesma forma que fizemos na API REST do Twitter, temos que salvar as chaves de acesso, bem como definir o objeto OAuthHandler para cuidar da autenticação e validação do acesso.



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)

2 .Criar uma classe herdando os atributos da classe StreamListener



In [ ]:

    
class DadosPublicosTwitter(tweepy.StreamListener):
    def on_status(self, dados):
        print("---> ", dados.text)

3. Instanciar essa classe e utilizá-la para se conectar a API através de um objeto de Stream.



In [ ]:

    
dados_twitter = DadosPublicosTwitter()



In [ ]:

    
fluxo = tweepy.Stream(autorizar, dados_twitter)

4. Iniciar um fluxo (Stream)

O parâmetro track aceita uma lista como argumento e cada elemento da lista é um termo que será filtrado.

Para parar a execução do código será necessário clicar em Kernel -> Interrupt ou no botão de parar, representado por um quadrado.

Um erro será gerado: Provavelmente o KeyboardInterrupt.



In [ ]:

    
fluxo.filter(track=['Big Data'])

Exercício

Modifique o código de Iniciar um fluxo (Stream) para tratar o erro que apareceu quando interrompemos a execução do código: KeyboardInterrupt.

Lembre-se antes de rodar esse exercício de reiniciar a execução desse notebook. (Kernel -> Restart & Clean Output).



In [ ]: