in datahub/rest.py [0:0]
def __init__(self, account, endpoint, user_agent=None, proxies=None, stream=False, retry_times=3, conn_timeout=5,
read_timeout=120, pool_connections=10, pool_maxsize=10, exception_handler_=exception_handler,
use_client=False):
if endpoint.endswith('/'):
endpoint = endpoint[:-1]
self._account = account
self._endpoint = endpoint
self._user_agent = user_agent or default_user_agent(use_client)
self._proxies = proxies
self._stream = stream
self._retry_times = retry_times
self._conn_timeout = conn_timeout
self._read_timeout = read_timeout
self._session = requests.Session()
self._session.headers.update({Headers.ACCEPT_ENCODING: ''})
# mount adapters with retry times
adapter = HTTPAdapter(pool_connections=pool_connections, pool_maxsize=pool_maxsize,
max_retries=self._retry_times)
self._session.mount('http://', adapter)
self._session.mount('https://', adapter)
# exception handler
self._exception_handler = exception_handler_