Telegram +
This commit is contained in:
@@ -508,10 +508,10 @@ async def get_tg_messages(client_tg, channel_username_tg):
|
|||||||
|
|
||||||
def check_tg_news():
|
def check_tg_news():
|
||||||
session_file = 'LG_news'
|
session_file = 'LG_news'
|
||||||
loop = asyncio.new_event_loop() # Создание нового цикла событий
|
loop = asyncio.new_event_loop()
|
||||||
asyncio.set_event_loop(loop) # Установка нового цикла событий
|
asyncio.set_event_loop(loop)
|
||||||
|
|
||||||
client_tg = TelegramClient('LG_news', keys.api_id_tg, keys.api_hash_tg)
|
client_tg = TelegramClient(session_file, keys.api_id_tg, keys.api_hash_tg)
|
||||||
|
|
||||||
@client_tg.on(events.NewMessage(chats=keys.channel_username_tg))
|
@client_tg.on(events.NewMessage(chats=keys.channel_username_tg))
|
||||||
async def handler(event):
|
async def handler(event):
|
||||||
@@ -540,7 +540,7 @@ def check_tg_news():
|
|||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
await client_tg.send_message(keys.channel_username_tg, content)
|
await client_tg.send_message(keys.channel_username_tg, content)
|
||||||
break # Сообщение отправлено успешно, выходим из цикла
|
break
|
||||||
except FloodWaitError as e:
|
except FloodWaitError as e:
|
||||||
logging.warning(f"Flood wait error: нужно подождать {e.seconds} секунд.")
|
logging.warning(f"Flood wait error: нужно подождать {e.seconds} секунд.")
|
||||||
await asyncio.sleep(e.seconds) # Ждем указанное время перед повторной попыткой
|
await asyncio.sleep(e.seconds) # Ждем указанное время перед повторной попыткой
|
||||||
@@ -550,6 +550,5 @@ def check_tg_news():
|
|||||||
loop.run_until_complete(main_tg())
|
loop.run_until_complete(main_tg())
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
main()
|
main()
|
||||||
|
Reference in New Issue
Block a user