Программная остановка/запуск потока Tweepy Stream

Я пытаюсь создать веб-приложение на Django для отслеживания твитов по хэштегам. Я использую Tweepy Asyncstreaming и все работает нормально. Я новичок в асинхронном программировании. Мне нужна помощь в том, как остановить запущенный поток и начать новый поток, когда добавляется новый хэштег.

Вот мой код:

import os

from tweepy.asynchronous import AsyncStream 
import asyncio


consumer_key = os.getenv('XXXXXXXXXXX')
consumer_secret = os.getenv('XXXXXXXXXXX')
access_token = os.getenv('XXXXXXXXXXX')
access_token_secret = os.getenv('XXXXXXXXXXX')


async def main():
    stream = TweetStream(consumer_key, consumer_secret,
                        access_token, access_token_secret)
    await stream.filter(follow=['web3', 'crypto'])


class TweetStream(AsyncStream):
    async def on_connect(self):
        print('Stream connected')

    async def on_status(self, status):
        if status.in_reply_to_user_id == None and not(status.entities['user_mentions']):
            print(status.text)
            print(status.user.screen_name)
    
    async def on_error(self, status):
        print(status)


if __name__ == '__main__':
    asyncio.run(main())

Вернуться на верх