python - secret - tweepy se detiene después de unas horas

twitter python

Question

Yo uso tweepy para transmitir algunos tweets. Este es mi procedimiento:

import tweepy
import json

consumer_key = "***" 
consumer_secret = "***"
access_token_key="***"
access_token_secret="***"

auth1 = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth1.set_access_token(access_token_key, access_token_secret)
api = tweepy.API(auth1)

class StreamListener(tweepy.StreamListener):
    def on_status(self, status):
        try:
            print status.text
        except Exception, e:
            print ''Encountered Exception Tweet:'', e
            pass
        return True

    def on_error(self, status_code):
        print ''Encountered error with status code:'' + repr(status_code)
        return True 

    def on_data(self, data):
        if ''in_reply_to_status_id'' in data:
            status = tweepy.Status.parse(self.api, json.loads(data))
            if self.on_status(status) is False:
                return True
        elif ''delete'' in data:
            delete = json.loads(data)[''delete''][''status'']
            if self.on_delete(delete[''id''], delete[''user_id'']) is False:
                return True
        elif ''limit'' in data:
            if self.on_limit(json.loads(data)[''limit''][''track'']) is False:
                return True
        return True

    def on_timeout(self):
        print ''Timeout...''
        return True

l = StreamListener()
streamer = tweepy.Stream(auth=auth1, listener=l, timeout=36000000)

setTerms = [''enbrel'']
streamer.filter(follow=None,track = setTerms)

Después de dos / tres horas, este procedimiento se detiene. No hay error de señal, tiempo de espera, etc. Simplemente no recibe más tweet. ¿Dónde estoy haciendo mal?

Answer 1

Intenta agregar un método on_disconnect a tu clase. Podría ser que Twitter te esté desconectando (no es un error, tampoco es un tiempo de espera) y no manejas esto. Puede manejar diferentes errores de Twitter de forma diferente, si lo desea.

def on_disconnect(self, notice):
    """Called when twitter sends a disconnect notice

    Disconnect codes are listed here:
    https://dev.twitter.com/docs/streaming-apis/messages#Disconnect_messages_disconnect
    """
    return

Consulte el módulo de streaming de tweepy para obtener más información.

También puede intentar habilitar las advertencias de bloqueo en su streamer.filter() . A continuación se encuentran todas las opciones y sus valores predeterminados de la fuente Tweepy:

def filter(self, follow=None, track=None, async=False, locations=None,
           stall_warnings=False, languages=None, encoding=''utf8''):

Answer 2

Es posible que desee iniciar la API con un tiempo de espera para comenzar con

api = tweepy.API(auth1,timeout=60)