Что делать если юзербот Pyrogram не видит новых сообщений от каналов >1000 человек?

Question

[Den_Rou_OFFICIAL]

Уже давно заметил это, но не особо волновался потому что не особо требовалось и я обходился получением сообщений через обработку preview канала, сейчас стало нужно и искренне не знаю как фиксить, т.е клиент юзер бота просто не видит новых сообщений от каналов/чатов в которых больше 1000 человек, можно ли как то это исправить что бы я смог получать сообщения от таких каналов?

Comments

[dezcode]

Добрый день! Не нашли решение проблемы?

[Den_Rou_OFFICIAL]

dezcode, доброго вечера, нет, до сих пор ищу

[dezcode]

Den_Rou_OFFICIAL, решаемо переходом на Telethon. Там всё работает корректно, и код почти не отличается

[Den_Rou_OFFICIAL]

dezcode, пытался и там, может быть в коде что то не то написал, но он так же получал сообщения откуда угодно кроме каналов/чатов больше 1000 человек, можете кинуть код для получения сообщений который заработал у вас?

[Евгений]

Да, действительно библиотека Telethon все решает.

from telethon import TelegramClient, events

# Замените эти значения на свои
api_id = 
api_hash = ""

# Создаем клиент
client = TelegramClient('my_account2', api_id, api_hash)


@client.on(events.NewMessage)
async def handler(event):
    # Получаем информацию о чате, откуда пришло сообщение
    chat = await client.get_entity(event.chat_id)

    # Печатаем название чата и его ID

    print(f'ID чата: {chat.id}')

    # Печатаем текст входящего сообщения
    print(f'Новое сообщение: {event.message.text}\n\n')

# Запускаем клиент
with client:
    client.run_until_disconnected()

[Den_Rou_OFFICIAL]

Евгений, благодарю, да, действительно начал принимать сообщения со всех каналов, но появилась проблема что теперь тг может снести сессии аккаунта на котором запускается бот, посмотрел в интернете и там тоже много пишут про данную проблему именно с телетоном, у вас было такое и решаемо ли это?

Answer 1

[Али Профи]

Что за проблема? Купите себе 1000 подписчиков ботов обычных и будет вас счастье ))

Comments

[Den_Rou_OFFICIAL]

Не до конца понял вашего ответа, у меня имеется юзербот на пайрограме который должен получать сообщения с каналов и обрабатывать их, но если канал больше 1000 человек то он просто отказывается видеть новые сообщения с него, вот я и спрашиваю, как это фиксить?

Answer 2

[nikita_kataev_dev]

Pyrogram не поддерживают уже больше года, есть форк - pyrotgfork.
Удаляешь Pyrogram, устанавливаешь pyrotgfork, и всё. Код менять не нужно. Всё будет работать.

Comments

[romanraspopov]

Именно так и сделал: удалил Pyrogram, и установил pyrotgfork (чтобы обойти ограничение в 1000 подписчиков на канале, от которого должны поступать сообщения). В итоге довольно простой код, логирующий входящие сообщения, перестал работать.

Стал выдавать ошибку: "sqlite3.OperationalError: table update_state already exists".

По поиску этой ошибки выдаются далекие от темы результаты - по БД, хотя БД в коде никак не участвуют.
Что делать в этой ситуации?

from pyrogram import Client
from pyrogram import filters

app = Client("my_account")


@app.on_message(filters.channel | filters.group)
def log(client, message):
    print(f"{message}\n")


app.run()

Полный лог ошибок:

Traceback (most recent call last):
  File "c:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\onMessage_1.py", line 12, in <module>
    app.run()
    ~~~~~~~^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\methods\utilities\run.py", line 84, in run
    self.start()
    ~~~~~~~~~~^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\sync.py", line 66, in async_to_sync_wrap
    return loop.run_until_complete(coroutine)
           ~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^
  File "C:\Users\roman\AppData\Local\Programs\Python\Python313\Lib\asyncio\base_events.py", line 721, in run_until_complete
    return future.result()
           ~~~~~~~~~~~~~^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\methods\utilities\start.py", line 58, in start
    is_authorized = await self.connect()
                    ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\methods\auth\connect.py", line 40, in connect
    await self.load_session()
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\client.py", line 804, in load_session
    await self.storage.open()
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\storage\file_storage.py", line 131, in open
    await self.update()
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\storage\file_storage.py", line 113, in update
    await self.loop.run_in_executor(self.executor, self._update_from_four_impl)
  File "C:\Users\roman\AppData\Local\Programs\Python\Python313\Lib\concurrent\futures\thread.py", line 58, in run
    result = self.fn(*self.args, **self.kwargs)
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\storage\file_storage.py", line 83, in _update_from_four_impl
    self.conn.executescript(UPDATE_STATE_SCHEMA)
    ~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^
sqlite3.OperationalError: table update_state already exists

Answer 3

[romanraspopov]

Удалось ли решить проблему?
Я сделал, как написал Никита: удалил pyrogram, и установил pyrotgfork. В итоге довольно простой код, логирующий входящие сообщения, перестал работать.

Стал выдавать ошибку: "sqlite3.OperationalError: table update_state already exists".

По поиску этой ошибки выдаются далекие от темы результаты - по БД, хотя БД в коде никак не участвуют.
Что делать в этой ситуации?

from pyrogram import Client
from pyrogram import filters

app = Client("my_account")


@app.on_message(filters.channel | filters.group)
def log(client, message):
    print(f"{message}\n")


app.run()

Полный лог ошибок:

Traceback (most recent call last):
  File "c:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\onMessage_1.py", line 12, in <module>
    app.run()
    ~~~~~~~^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\methods\utilities\run.py", line 84, in run
    self.start()
    ~~~~~~~~~~^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\sync.py", line 66, in async_to_sync_wrap
    return loop.run_until_complete(coroutine)
           ~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^
  File "C:\Users\roman\AppData\Local\Programs\Python\Python313\Lib\asyncio\base_events.py", line 721, in run_until_complete
    return future.result()
           ~~~~~~~~~~~~~^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\methods\utilities\start.py", line 58, in start
    is_authorized = await self.connect()
                    ^^^^^^^^^^^^^^^^^^^^
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\methods\auth\connect.py", line 40, in connect
    await self.load_session()
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\client.py", line 804, in load_session
    await self.storage.open()
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\storage\file_storage.py", line 131, in open
    await self.update()
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\storage\file_storage.py", line 113, in update
    await self.loop.run_in_executor(self.executor, self._update_from_four_impl)
  File "C:\Users\roman\AppData\Local\Programs\Python\Python313\Lib\concurrent\futures\thread.py", line 58, in run
    result = self.fn(*self.args, **self.kwargs)
  File "C:\Users\roman\AppData\Local\Programs\Python\SoberMonitor\.venv\Lib\site-packages\pyrogram\storage\file_storage.py", line 83, in _update_from_four_impl
    self.conn.executescript(UPDATE_STATE_SCHEMA)
    ~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^
sqlite3.OperationalError: table update_state already exists