It seems that f.add_feed(OKX(channels=[TRADES], symbols=okx_tickers, callbacks={TRADES: TradeInflux(INFLUX_ADDR, ORG, BUCKET, TOKEN)})) doesn't work for OKX
ERROR : OKX: Failed to parse symbol information: ('Connection aborted.', ConnectionResetError(104, 'Connection reset by peer'))
Traceback (most recent call last):
File "/usr/local/lib/python3.8/dist-packages/urllib3/connectionpool.py", line 703, in urlopen
httplib_response = self._make_request(
File "/usr/local/lib/python3.8/dist-packages/urllib3/connectionpool.py", line 386, in _make_request
self._validate_conn(conn)
File "/usr/local/lib/python3.8/dist-packages/urllib3/connectionpool.py", line 1042, in _validate_conn
conn.connect()
File "/usr/local/lib/python3.8/dist-packages/urllib3/connection.py", line 414, in connect
self.sock = ssl_wrap_socket(
File "/usr/local/lib/python3.8/dist-packages/urllib3/util/ssl_.py", line 449, in ssl_wrap_socket
ssl_sock = _ssl_wrap_socket_impl(
File "/usr/local/lib/python3.8/dist-packages/urllib3/util/ssl_.py", line 493, in _ssl_wrap_socket_impl
return ssl_context.wrap_socket(sock, server_hostname=server_hostname)
File "/usr/lib/python3.8/ssl.py", line 500, in wrap_socket
return self.sslsocket_class._create(
File "/usr/lib/python3.8/ssl.py", line 1040, in _create
self.do_handshake()
File "/usr/lib/python3.8/ssl.py", line 1309, in do_handshake
self._sslobj.do_handshake()
ConnectionResetError: [Errno 104] Connection reset by peer
File "bot.py", line 53, in main
f.add_feed(OKX(channels=[TRADES], symbols=okx_tickers, callbacks={TRADES: TradeInflux(INFLUX_ADDR, ORG, BUCKET, TOKEN)}))
File "/usr/local/lib/python3.8/dist-packages/cryptofeed/feed.py", line 63, in __init__
super().__init__(**kwargs)
File "/usr/local/lib/python3.8/dist-packages/cryptofeed/exchange.py", line 49, in __init__
self.symbol_mapping()
File "/usr/local/lib/python3.8/dist-packages/cryptofeed/exchange.py", line 100, in symbol_mapping
data.append(cls.http_sync.read(ep, json=True, uuid=cls.id))
File "/usr/local/lib/python3.8/dist-packages/cryptofeed/connection.py", line 54, in read
r = requests.get(address, headers=headers, params=params)
File "/usr/local/lib/python3.8/dist-packages/requests/api.py", line 73, in get
return request("get", url, params=params, **kwargs)
File "/usr/local/lib/python3.8/dist-packages/requests/api.py", line 59, in request
return session.request(method=method, url=url, **kwargs)
File "/usr/local/lib/python3.8/dist-packages/requests/sessions.py", line 587, in request
resp = self.send(prep, **send_kwargs)
File "/usr/local/lib/python3.8/dist-packages/requests/sessions.py", line 701, in send
r = adapter.send(request, **kwargs)
File "/usr/local/lib/python3.8/dist-packages/requests/adapters.py", line 547, in send
raise ConnectionError(err, request=request)
requests.exceptions.ConnectionError: ('Connection aborted.', ConnectionResetError(104, 'Connection reset by peer'))
Describe the bug
It seems that
f.add_feed(OKX(channels=[TRADES], symbols=okx_tickers, callbacks={TRADES: TradeInflux(INFLUX_ADDR, ORG, BUCKET, TOKEN)}))
doesn't work for OKXTo Reproduce Steps to reproduce the behavior:
f.add_feed(OKX(channels=[TRADES], symbols=okx_tickers, callbacks={TRADES: TradeInflux(INFLUX_ADDR, ORG, BUCKET, TOKEN)}))
Operating System:
Cryptofeed Version