Хорошо, вот в чем дело: я делаю этот код, который обращается к Reddit, загружаю кое-что, а затем публикую в твиттере, другая его часть наблюдает за потоком контента и жду, пока некоторые ключевые слова не сделают что-то . Поскольку часть наблюдения уже постоянна, теперь я просто хочу, чтобы вторая запустилась через некоторое время, а пока я использую наблюдатель потока для запуска функции (иначе говоря, когда наблюдатель потока получает сигнал от Twitter, он запускает function), и это вроде работает, но не согласованно. Я видел эту ссылку , но это меня немного смутило, так как я не очень разбираюсь в python многопоточности.
вот код, который я использую:
def buscarreddit():
*function that searchs on reddit and posts*
api = tweepy.API(auth, wait_on_rate_limit=True,
wait_on_rate_limit_notify=True)
class MyStreamListener(tweepy.StreamListener):
def __init__(self, api):
self.api = api
self.me = api.me()
def on_status(self, tweet):
print(f"{tweet.user.name}:{tweet.text}")
api.create_favorite(tweet.id)
frequency = 2500
duration = 200
winsound.Beep(frequency, duration)
buscarreddit()
def on_error(self, status):
print("Error detected")
api = tweepy.API(auth)
try:
api.verify_credentials()
print("Authentication OK")
except:
print("Error during authentication")
tweets_listener = MyStreamListener(api)
stream = tweepy.Stream(api.auth, tweets_listener)
stream.filter(track=["trigger"], languages=["en"])
Я принимаю предложения и / или объяснения, которые вы можете мне дать
Заранее спасибо.