mirror/pyTelegramBotAPI
1
0
Fork 0
mirror of https://github.com/eternnoir/pyTelegramBotAPI.git synced 2023-08-10 21:12:57 +03:00
Code Releases Activity

Merge pull request #1356 from Badiboy/master

Browse Source 
RETRY_ENGINE
This commit is contained in:
Badiboy 2021-11-08 18:33:00 +03:00 committed by GitHub
commit 5f5298bcd1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
telebot/apihelper.py
View File

@ -9,6 +9,7 @@ except ImportError:
import requests import requests
from requests.exceptions import HTTPError, ConnectionError, Timeout from requests.exceptions import HTTPError, ConnectionError, Timeout
from requests.adapters import HTTPAdapter
try: try:
# noinspection PyUnresolvedReferences # noinspection PyUnresolvedReferences
@ -38,6 +39,7 @@ SESSION_TIME_TO_LIVE = 600 # In seconds. None - live forever, 0 - one-time
RETRY_ON_ERROR = False RETRY_ON_ERROR = False
RETRY_TIMEOUT = 2 RETRY_TIMEOUT = 2
MAX_RETRIES = 15 MAX_RETRIES = 15
RETRY_ENGINE = 1
CUSTOM_SERIALIZER = None CUSTOM_SERIALIZER = None
CUSTOM_REQUEST_SENDER = None CUSTOM_REQUEST_SENDER = None
@ -107,38 +109,41 @@ def _make_request(token, method_name, method='get', params=None, files=None):
params = params or None # Set params to None if empty params = params or None # Set params to None if empty
result = None result = None
if RETRY_ON_ERROR: if RETRY_ON_ERROR and RETRY_ENGINE == 1:
got_result = False got_result = False
current_try = 0 current_try = 0
while not got_result and current_try<MAX_RETRIES-1: while not got_result and current_try<MAX_RETRIES-1:
current_try+=1 current_try+=1
try: try:
result = _get_req_session().request( result = _get_req_session().request(
method, request_url, params=params, files=files, method, request_url, params=params, files=files,
timeout=(connect_timeout, read_timeout), proxies=proxy) timeout=(connect_timeout, read_timeout), proxies=proxy)
got_result = True got_result = True
except HTTPError: except HTTPError:
logger.debug("HTTP Error on {0} method (Try #{1})".format(method_name, current_try)) logger.debug("HTTP Error on {0} method (Try #{1})".format(method_name, current_try))
time.sleep(RETRY_TIMEOUT) time.sleep(RETRY_TIMEOUT)
except ConnectionError: except ConnectionError:
logger.debug("Connection Error on {0} method (Try #{1})".format(method_name, current_try)) logger.debug("Connection Error on {0} method (Try #{1})".format(method_name, current_try))
time.sleep(RETRY_TIMEOUT) time.sleep(RETRY_TIMEOUT)
except Timeout: except Timeout:
logger.debug("Timeout Error on {0} method (Try #{1})".format(method_name, current_try)) logger.debug("Timeout Error on {0} method (Try #{1})".format(method_name, current_try))
time.sleep(RETRY_TIMEOUT) time.sleep(RETRY_TIMEOUT)
if not got_result: if not got_result:
result = _get_req_session().request( result = _get_req_session().request(
method, request_url, params=params, files=files, method, request_url, params=params, files=files,
timeout=(connect_timeout, read_timeout), proxies=proxy) timeout=(connect_timeout, read_timeout), proxies=proxy)
else: elif RETRY_ON_ERROR and RETRY_ENGINE == 2:
if CUSTOM_REQUEST_SENDER: http = _get_req_session()
retry_strategy = requests.packages.urllib3.util.retry.Retry(
total=MAX_RETRIES,
)
adapter = HTTPAdapter(max_retries=retry_strategy)
for prefix in ('http://', 'https://'):
http.mount(prefix, adapter)
result = http.request(
method, request_url, params=params, files=files,
timeout=(connect_timeout, read_timeout), proxies=proxy)
elif CUSTOM_REQUEST_SENDER:
result = CUSTOM_REQUEST_SENDER( result = CUSTOM_REQUEST_SENDER(
method, request_url, params=params, files=files, method, request_url, params=params, files=files,
timeout=(connect_timeout, read_timeout), proxies=proxy) timeout=(connect_timeout, read_timeout), proxies=proxy)