Как сделать постоянное подключение к LongPoll вк при обрыве?

Question

toha_man @toha_man

Как сделать постоянное подключение к LongPoll вк при обрыве?

Написал простенький скрипт для личных нужд на питоне с помощью api от вк - LongPoll.
Работает как и требуется, но проблема в том, что через какое-то время контакт его отрубает.

Слушаю новые события так:

for event in longpoll.listen():
       далее код

спустя какое-то время получаю выход из скрипта и сообщение:

requests.exceptions.ConnectionError: ('Connection aborted.', ConnectionResetError(10054, 'Удаленный хост принудительно разорвал существующее подключение', None, 10054, None))

Подключаюсь так:

session = requests.Session()
login, password = ####

vk_session = vk_api.VkApi(login, password)
try:
	vk_session.auth(token_only=True)
	print('auth successful... proceed')
except vk_api.AuthError as error_msg:
	print(error_msg)

Какой конструкцией организовать код , чтобы работало вечно)))) ?

Вопрос задан более трёх лет назад
2741 просмотр

1 комментарий

Подписаться 1 Простой 1 комментарий

Решения вопроса 1

3 комментария

toha_man @toha_man Автор вопроса

я верно понимаю, что в такой конструкции при срабатывание except'a будет выполнен код нового соединения, а вот код после try: повторно не выполнится ?

если да , то снова мимо

Написано более трёх лет назад
Дмитрий Шицков @Zarom

toha_man, в данном случае, после обработки исключения, выполнение программы перейдет в точку сразу же после блока try. Т.е. цикл продолжит выполнение.

Написано более трёх лет назад
Zacher @Zacher

это решение не очень подойдет
так как сообщение которое привело к ошибке, не будет обработано ботом.

Написано более двух лет назад

Пригласить эксперта

Ответы на вопрос 2

6 комментариев

toha_man @toha_man Автор вопроса

я читал статью по ссылке. но всё как-то странно.
во-первых бот отслеживает события гораздо дольше чем 25 или 90 секунд, при мне он работал более 15 минут. во-вторых даже если происходит событие работа не завершается. В довесок соединение с Long Poll у меня в скрипте совсем по-другому устанавливается

longpoll = VkLongPoll(vk_session)

не знаю куда тут таймаут запихнут, да и какой от него будет толк, если у меня задача перезапуск соединения в случае разрыва

Написано более трёх лет назад
Yar Rick @Yar_Rick

toha_man, видимо ты использовал какой-то готовый фреймворк для своего бота?

Ошибка, скорее всего, возникает, когда какой-то прокси на канале между твоим ботом и сервером VK решит, что соединение живёт слишком долго и рвёт его. Это может быть твой провайдер. Именно поэтому VK и советует использовать таймаут 25 сек.

Либо покопайся в классе VKLongPoll и найди метод, где происходит запрос getLongPollServer (их, кстати теперь два groups и messages). Выглядит он так:

https://{$server}?act=a_check&key={$key}&ts={$ts}&...

(инфа для сообщений здесь - https://vk.com/dev/using_longpoll)

и проверь, что таймаут подходящий, либо не заморачивайся - сделай, как написано в первом комментарии от Дмитрий Шицков, т. е. при разрыве - просто соединяйся заново.

P.S. своим первым комментарием я просто хотел донести, что Long Poll - это не вечное соединение, это тот же постоянный опрос, просто каждый запрос держится сервером в ожидания событий для экономии трафика. НО соединение периодически завершается в любом случае (будь то возврат ответа с данными или сброс по таймауту без данных, либо ошибка, потому что какой-то прокси решил, что он главный), так что обрыв соединения с ошибкой - не такая уж и беда, просто соединяйся заново.

Написано более трёх лет назад

toha_man @toha_man Автор вопроса

Порылся я в доках, поставил таймаут в 25 для соединения с LongPoll
longpoll = VkLongPoll(vk_session, wait=25)

проблему это не решило. Время от времени (примерно через 10 минут) и преимущественно в момент отправки сообщения скриптом, т.е. через vk.messages.send происходит остановка. Вообще ошибка довольно рандомно появляется, что и является главной проблемой, т.к. от скрипта требуется в первую очередь постоянно мониторить чат в группе и отвечать.
Вот такой трейсбек:

spoiler

Traceback (most recent call last):
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 600, in urlopen
    chunked=chunked)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 384, in _make_request
    six.raise_from(e, None)
  File "<string>", line 2, in raise_from
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 380, in _make_request
    httplib_response = conn.getresponse()
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 1321, in getresponse
    response.begin()
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 296, in begin
    version, status, reason = self._read_status()
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 257, in _read_status
    line = str(self.fp.readline(_MAXLINE + 1), "iso-8859-1")
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\socket.py", line 589, in readinto
    return self._sock.recv_into(b)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\ssl.py", line 1052, in recv_into
    return self.read(nbytes, buffer)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\ssl.py", line 911, in read                                               17:58
    return self._sslobj.read(len, buffer)
ConnectionResetError: [WinError 10054] Удаленный хост принудительно разорвал существующее подключение

Еще:

spoiler

Traceback (most recent call last):
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\requests\adapters.py", line 449, in send
    timeout=timeout
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 638, in urlopen
    _stacktrace=sys.exc_info()[2])
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\util\retry.py", line 367, in increment
    raise six.reraise(type(error), error, _stacktrace)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\packages\six.py", line 685, in reraise
    raise value.with_traceback(tb)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 600, in urlopen
    chunked=chunked)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 384, in _make_request
    six.raise_from(e, None)
  File "<string>", line 2, in raise_from
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\urllib3\connectionpool.py", line 380, in _make_request
    httplib_response = conn.getresponse()
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 1321, in getresponse
    response.begin()
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 296, in begin
    version, status, reason = self._read_status()
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\http\client.py", line 257, in _read_status
    line = str(self.fp.readline(_MAXLINE + 1), "iso-8859-1")
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\socket.py", line 589, in readinto
    return self._sock.recv_into(b)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\ssl.py", line 1052, in recv_into
    return self.read(nbytes, buffer)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\ssl.py", line 911, in read
    return self._sslobj.read(len, buffer)
urllib3.exceptions.ProtocolError: ('Connection aborted.', ConnectionResetError(10054, 'Удаленный хост принудительно разорвал существующее подключение', None, 10054, None))

Еще:

spoiler

Traceback (most recent call last):
  File "vsk_bot.py", line 37, in <module>
    vk.messages.send(
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\vk_api\vk_api.py", line 671, in __call__
    return self._vk.method(self._method, kwargs)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\vk_api\vk_api.py", line 602, in method
    values
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\requests\sessions.py", line 581, in post
    return self.request('POST', url, data=data, json=json, **kwargs)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\requests\sessions.py", line 533, in request
    resp = self.send(prep, **send_kwargs)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\requests\sessions.py", line 646, in send
    r = adapter.send(request, **kwargs)
  File "C:\Users\XXX\AppData\Local\Programs\Python\Python37-32\lib\site-packages\requests\adapters.py", line 498, in send
    raise ConnectionError(err, request=request)
requests.exceptions.ConnectionError: ('Connection aborted.', ConnectionResetError(10054, 'Удаленный хост принудительно разорвал существующее подключение', None, 10054, None))

И еще вопрос, пожалуйста, я не нашел это в доках. Как можно определить от какого пользователя пришло сообщение ? Что-то типа VkEventType.user_id ? Мне нужно, чтобы скрипт реагировал исключительно на сообщение определенного пользователя.
Спасибо !

Написано более трёх лет назад

toha_man @toha_man Автор вопроса
Вообщем , ошибка совершенно точно происходит если:
1. Запустить скрипт
2. Подождать 10-15 минут
3. Дать сработать функции vs.messages.new() в скрипте - и бам вуаля приехали

Попробую переписать скрипт вот с такой конструкцией:
spoiler
while True; longPoll = post('%s'%server, data = {'act': 'a_check', 'key': key, 'ts': ts, 'wait': 25}).json() #мой код ts = longPoll['ts']

А в чем разница модулей vk и vk_api ?
Написано более трёх лет назад
Yar Rick @Yar_Rick

toha_man, в доках есть, просто доки не очень понятно и скудно оформлены. Приведу выдержку оттуда:

Новое сообщение от user_id=123456 с текстом "hello" и двумя вложениями (фото и аудио):
[4,2105994,561,123456,1496404246,"hello",{"title":" ... "},{"attach1_type":"photo","attach1":"123456_417336473","attach2_type":"audio","attach2":"123456_456239018"}]

Событие - это массив, в данном случае user_id находится на четвертом месте, то есть event[3]. Я на питоне не пишу, точную реализацию не подскажу, но должно быть понятно. Каждое событие надо распарсить таким образом, причём структура зависит от типа события, которое всегда находится на первом месте. В данном случае событие с номером 4 - новое сообщение. В других типах событий user_id может быть на другом месте.

Ссылка на всякий случай, мотай в самый низ, п. 8 - https://vk.com/dev/using_longpoll_2

Написано более трёх лет назад
Yar Rick @Yar_Rick

toha_man, про разницу модулей тоже не скажу, я делал реализацию на Java и с нуля, читая документацию VK.

Добавлю, что в идеале поллинг сервера должен выполняться в отдельном потоке, чтобы постоянно слушать события. А ответы можно слать в основном потоке. Я пока не знаю, может ли возникнуть обсуждаемая ошибка, если шлешь ответ и держишь соединение с Long Poll в одном потоке одновременно. Возможно, на время отсылки ответа нужно сделать паузу в опросе Long Poll, если программа однопоточная, то есть не делать несколько запросов сразу, а формировать из них очередь.

Написано более трёх лет назад

Комментировать

Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации

Похожие вопросы

Python

+2 ещё

Простой
Как установить 2 версии libssl в kubuntu 22.04?
- 2 подписчика
- 8 часов назад
- 78 просмотров
0

ответов
Python

Простой
Как в библиотеке Flet при нажатии на кнопку сделать, чтобы появилось всплывающее окно?
- 1 подписчик
- 8 часов назад
- 19 просмотров
0

ответов
Python

+1 ещё

Сложный
Интерпретация результатов модели lambdamart?
- 1 подписчик
- 10 часов назад
- 21 просмотр
0

ответов
Python

Простой
Как в конце каждой строки файла добавить тэг?
- 1 подписчик
- вчера
- 118 просмотров
1

ответ
Python

+1 ещё

Простой
Почему asyncio.current_task() не передается в функцию?
- 1 подписчик
- вчера
- 91 просмотр
1

ответ
Python

+2 ещё

Простой
Срабатывает антивирус на скомпилированный файл python, как исправить?
- 1 подписчик
- 22 апр.
- 197 просмотров
1

ответ
WordPress

+2 ещё

Средний
Как сделать автоматический выбор региона по IP в Wordpress?
- 1 подписчик
- 22 апр.
- 57 просмотров
2

ответа
Python

Простой
Почему не срабатывает if? как это пофиксить?
- 1 подписчик
- 22 апр.
- 146 просмотров
2

ответа
Python

+2 ещё

Простой
Как транслировать аудио в микрофон, py, c#, c++?
- 1 подписчик
- 22 апр.
- 169 просмотров
3

ответа
Python

Средний
Почему Низкий FPS анализ изображения yolov8 YOLO?
- 2 подписчика
- 22 апр.
- 33 просмотра
0

ответов
Показать ещё Загружается…

Team Lead (С++, Python)

TopAssistant • Москва

от 400 000 ₽

Python developer

Bell Integrator

До 350 000 ₽

Python developer

Greenway Global • Новосибирск

от 150 000 ₽

Доработка андроид приложения на kotlin

24 апр. 2024, в 23:13

130000 руб./за проект

Внести правки в Телеграм-бота с помощью кода(PHP-разработчик)

24 апр. 2024, в 22:44

11000 руб./за проект

HFT (high frequency trading) разработка торгового бота c#/c++

24 апр. 2024, в 22:30

200000 руб./за проект

У вас нет возможности использовать callback? С лонгпуллом чтобы учесть все возможные варианты -- нужно очень запариться. Нужно учесть четыре типа ошибок, которые возвращает callback, разрывы соединения, таймауты и ошибку 500, которую ВК тоже любит отдавать. Я такое делал, но это геморрой, конечно. В некоторых случаях нужно получить новые данные для доступа к lp серверу, в некоторых достаточно старых.

Answer 1 · 2019-02-09 21:07:38

Мне кажется, как-то так:

for event in longpoll.listen():
	try:
		далее код
	except requests.exceptions.ConnectionResetError:
		тут вызов функции для попытки повторного подключения

Answer 2 · 2019-02-09 21:39:57

Ошибочно думать, что Long Poll - "вечное соединение", это не так. Сервер держит соединение какое-то время, например 30 секунд, и если никаких событий за этот период не случилось, он его сбрасывает. Если событие случилось, то соединение закрывается с ответом. Поэтому нужно снова предпринимать попытку соединения - либо после получения события, либо после истечения таймаута. В документации VK этот момент описан, а также можно при помощи параметра указать таймаут. Они рекомендуют 25 сек, так как большинство прокси сбрасывают соединение через 30 сек. Подробнее здесь - https://vk.com/dev/bots_longpoll

Answer 3 · 2021-05-13 03:09:44

for event in longpoll.listen():
когда ты ставишь wait 25, то список событий получается пустой, в итоге цикл for не запускается, а longpoll запускается заново
Так происходит пока не появится новое событие, например новое сообщение, но почему после него прилетает бан я тоже не пойму. У тебя есть решение этой проблемы? У меня тоже самое...

Как сделать постоянное подключение к LongPoll вк при обрыве?

Войдите, чтобы написать ответ

Минуточку внимания

Войдите на сайт