stream.py 文件源码

def run(self):
        l = Listener(self.queue)
        stream = tweepy.Stream(auth, l)
        while True:
            try:
                stream.userstream()
            except Exception as e:
                api.send_direct_message(
                    screen_name=debug_id, text="Stream down. And now restarting. Wait 60s...")
                log.exception(e)
                time.sleep(60)
                stream = tweepy.Stream(auth, l)
                api.send_direct_message(
                    screen_name=debug_id, text="Start streaming.")