Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/python
# -*- coding: utf-8 -*-
from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
 
import twitter_credentials
 
# # # # TWITTER STREAMER # # # #
class TwitterStreamer():
    """
    Class for streaming and processing live tweets.
    """
    def __init__(self):
        pass

    def stream_tweets(self, fetched_tweets_filename, hash_tag_list):
        # This handles Twitter authetification and the connection to Twitter Streaming API
        listener = StdOutListener(fetched_tweets_filename)
        auth = OAuthHandler(twitter_credentials.CONSUMER_KEY, twitter_credentials.CONSUMER_SECRET)
        auth.set_access_token(twitter_credentials.ACCESS_TOKEN, twitter_credentials.ACCESS_TOKEN_SECRET)
        stream = Stream(auth, listener)

        # This line filter Twitter Streams to capture data by the keywords: 
        stream.filter(track=hash_tag_list)


# # # # TWITTER STREAM LISTENER # # # #
class StdOutListener(StreamListener):
    """
    This is a basic listener that just prints received tweets to stdout.
    """
    def __init__(self, fetched_tweets_filename):
        self.fetched_tweets_filename = fetched_tweets_filename

    def on_data(self, data):
        try:
            print(data)
            with open(self.fetched_tweets_filename, 'a') as tf:
                tf.write(data)
            return True
        except BaseException as e:
            print("Error on_data %s" % str(e))
        return True
          

    def on_error(self, status):
        print(status)

 
if __name__ == '__main__':
 
    # Authenticate using config.py and connect to Twitter Streaming API.
    hash_tag_list = ["#besserbeideeltern"]
    fetched_tweets_filename = "tweets.txt"

    twitter_streamer = TwitterStreamer()
    twitter_streamer.stream_tweets(fetched_tweets_filename, hash_tag_list)

Code: Alles auswählen

import tweepy

#Add your credentials here
twitter_keys = {
        'consumer_key':        '',
        'consumer_secret':     '',
        'access_token_key':    '',
        'access_token_secret': '
    }

#Setup access to API
auth = tweepy.OAuthHandler(twitter_keys['consumer_key'], twitter_keys['consumer_secret'])
auth.set_access_token(twitter_keys['access_token_key'], twitter_keys['access_token_secret'])

api = tweepy.API(auth)

#Make call on home timeline, print each tweets text
public_tweets = api.home_timeline()
for tweet in public_tweets:
    print(tweet.text)

Code: Alles auswählen

#!/usr/bin/env python3
from tweepy import OAuthHandler, Stream
from tweepy.streaming import StreamListener

import twitter_credentials


class Listener(StreamListener):
    """
    This is a basic listener that just prints received data and saves it into a
    file.
    """

    def __init__(self, fetched_tweets_filename):
        StreamListener.__init__(self)
        self.fetched_tweets_filename = fetched_tweets_filename

    def on_data(self, raw_data):
        try:
            print(raw_data)
            with open(
                self.fetched_tweets_filename, "a", encoding="utf-8"
            ) as file:
                file.write(raw_data)
        except Exception as error:
            print("Error on_data", ascii(error))
        
        return StreamListener.on_data(self, raw_data)

    def on_error(self, status_code):
        print(status_code)
        return False


def stream_tweets(fetched_tweets_filename, hash_tag_list):
    #
    # This handles Twitter authetification and the connection to Twitter
    # Streaming API.
    #
    auth = OAuthHandler(
        twitter_credentials.CONSUMER_KEY, twitter_credentials.CONSUMER_SECRET
    )
    auth.set_access_token(
        twitter_credentials.ACCESS_TOKEN,
        twitter_credentials.ACCESS_TOKEN_SECRET,
    )
    stream = Stream(auth, Listener(fetched_tweets_filename))
    #
    # This line filter Twitter Streams to capture data by the keywords:
    #
    stream.filter(track=hash_tag_list)


def main():
    hash_tag_list = ["#besserbeideeltern"]
    fetched_tweets_filename = "tweets.txt"
    stream_tweets(fetched_tweets_filename, hash_tag_list)


if __name__ == "__main__":
    main()