nicolas
/
python-okx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

delete retry logic

This commit is contained in:
shiyao.zhu 2023-03-28 11:25:17 +08:00
parent c9e9de68e6
commit 4594cda51e
3 changed files with 15 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
okx/__init__.py
View File

@ -2,4 +2,4 @@
Python SDK for the OKX API v5 Python SDK for the OKX API v5
""" """
__version__="0.1.7" __version__="0.1.8"

57
okx/client.py
View File

@ -1,18 +1,13 @@
import json import json
import time
import traceback
import httpx import httpx
from httpx import _client
from . import consts as c, utils from . import consts as c, utils, exceptions
class Client(object): class Client(object):
def __init__(self, api_key='-1', api_secret_key='-1', passphrase='-1', use_server_time=False, flag='1', def __init__(self, api_key = '-1', api_secret_key = '-1', passphrase = '-1', use_server_time=False, flag='1', base_api = c.API_URL,debug = 'True'):
base_api=c.DOMAIN, debug=False):
self.API_KEY = api_key self.API_KEY = api_key
self.API_SECRET_KEY = api_secret_key self.API_SECRET_KEY = api_secret_key
self.PASSPHRASE = passphrase self.PASSPHRASE = passphrase
@ -20,8 +15,7 @@ class Client(object):
self.flag = flag self.flag = flag
self.domain = base_api self.domain = base_api
self.debug = debug self.debug = debug
self.request_times = 0 self.client = httpx.Client(base_url=base_api, http2=True)
self.client = httpx.Client(base_url=base_api, http2=True, verify=False, timeout=None)
def _request(self, method, request_path, params): def _request(self, method, request_path, params):
if method == c.GET: if method == c.GET:
@ -31,57 +25,32 @@ class Client(object):
timestamp = self._get_timestamp() timestamp = self._get_timestamp()
body = json.dumps(params) if method == c.POST else "" body = json.dumps(params) if method == c.POST else ""
if self.API_KEY != '-1': if self.API_KEY != '-1':
sign = utils.sign(utils.pre_hash(timestamp, method, request_path, str(body), self.debug), sign = utils.sign(utils.pre_hash(timestamp, method, request_path, str(body), self.debug), self.API_SECRET_KEY)
self.API_SECRET_KEY)
header = utils.get_header(self.API_KEY, sign, timestamp, self.PASSPHRASE, self.flag, self.debug) header = utils.get_header(self.API_KEY, sign, timestamp, self.PASSPHRASE, self.flag, self.debug)
else: else:
header = utils.get_header_no_sign(self.flag, self.debug) header = utils.get_header_no_sign(self.flag, self.debug)
response = None response = None
if self.debug: if self.debug == True:
print('domain:', self.domain) print('domain:',self.domain)
print('url:', request_path) print('url:',request_path)
if method == c.GET: if method == c.GET:
response = self.client.get(request_path, headers=header) response = self.client.get(request_path, headers=header)
elif method == c.POST: elif method == c.POST:
response = self.client.post(request_path, data=body, headers=header) response = self.client.post(request_path, data=body, headers=header)
self.request_times += 1 if not str(response.status_code).startswith('2'):
if self.request_times > 512: raise exceptions.OkxAPIException(response)
self.client.close()
self.client._state = _client.ClientState.UNOPENED
self.request_times = 0
return response
def _request_until_success(self, method, request_path, params):
response = ''
retry_times = 0
while True:
try:
response = self._request(method, request_path, params)
if not str(response.status_code).startswith('2'):
print('response.status_code:', response.status_code)
print('response.json.code:', response.json()['code'])
print('response.json.msg:', response.json()['msg'])
time.sleep(1)
continue
break
except Exception as e:
traceback.format_exc()
print(e)
retry_times += 1
print('http request retry in 1 seconds, retry times:', retry_times)
time.sleep(1)
return response.json() return response.json()
def _request_without_params(self, method, request_path): def _request_without_params(self, method, request_path):
return self._request_with_params(method, request_path, {}) return self._request(method, request_path, {})
def _request_with_params(self, method, request_path, params): def _request_with_params(self, method, request_path, params):
return self._request_until_success(method, request_path, params) return self._request(method, request_path, params)
def _get_timestamp(self): def _get_timestamp(self):
request_path = self.domain + c.SERVER_TIMESTAMP_URL request_path = c.API_URL + c.SERVER_TIMESTAMP_URL
response = self.client.get(request_path) response = self.client.get(request_path)
if response.status_code == 200: if response.status_code == 200:
return response.json()['ts'] return response.json()['ts']
else: else:
return "" return ""

2
okx/consts.py
View File

@ -1,5 +1,5 @@
# http header # http header
DOMAIN = 'https://www.okx.com' API_URL = 'https://www.okx.com'
CONTENT_TYPE = 'Content-Type' CONTENT_TYPE = 'Content-Type'
OK_ACCESS_KEY = 'OK-ACCESS-KEY' OK_ACCESS_KEY = 'OK-ACCESS-KEY'