parser group.py - master - Hrust116/Parser

parser group.py
58 строк2 KB
Hrust116
upload files
23 мар 2025, 22:50
23 мар 2025, 22:509273a9d
import asyncio
from tqdm import tqdm
from data import config
from loguru import logger
from telethon import TelegramClient
from datetime import timedelta, timezone

async def process_parser_url(client):
    url = 'https://t.me/+jcxyfYgkOl0yMWRi'
    count_message = 10
    get_mes = await client.get_messages(url, limit=count_message)

    for message_from_client in tqdm(get_mes):
        if message_from_client.buttons:
           continue
        print(message_from_client)
        title = message_from_client.chat.title
        message_id = message_from_client.id

        moscow_tz = timezone(timedelta(hours=3))
        moscow_time = message_from_client.date.astimezone(moscow_tz)
        formatted_time = moscow_time.strftime('%Y-%m-%d %H:%M:%S %Z')

        if formatted_time < '2025-02-27 00:00:00 UTC+03:00':
            break

        message_text = message_from_client.message

        # if message_from_client.replies:
        #
        #     comments = await client.get_messages(message_from_client.replies.channel_id, limit=100)
        #
        #     for comment in comments:
        #         if message_from_client.replies.max_id == comment.id:
        #             print(f"{comment.sender_id}: {comment.text}")


async def main():
    client = TelegramClient(config.SESSION_NAME, config.API_ID, config.API_HASH, connection_retries=5, system_version='1.2.3-zxc-custom', device_model='aboba-linux-custom', app_version='1.0.1')
    await client.start()

    if not client.is_connected():
        await client.connect()

    try:
        while True:
            logger.info(f"Новый цикл.")
            await process_parser_url(client)

    except KeyboardInterrupt:
        logger.info("Остановка программы (Ctrl+C).")

    finally:
        await client.disconnect()
        logger.info("Завершение работы программы.")

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