streaming.py 文件源码

def __init__(self, credentials, data):
        super(Streamer, self).__init__(name='Streamer')
        self.data = data
        self.text_processing_queue = data['queues']['text_processing']
        self.stoprequest = threading.Event()
        self.filter_params = data['filters']
        self.keyword_queue = data['queues']['keywords']
        self.keywords = set()
        self.auth = tweepy.OAuthHandler(credentials['consumer_key'], 
                                        credentials['consumer_secret'])
        self.auth.set_access_token(credentials['access_token'],
                                   credentials['access_token_secret'])
        self.limit_queue = data['queues']['limit']
        self.message_queue = data['queues']['messages']
        self.last_connection = 0
        self.min_reconnect_pause = 20