连接到cryptocompare的Python socketio示例

Question

我正在尝试使用来自Python客户端的socketIO连接到Cryptocompare的websocket流.这被证明是具有挑战性的.以下是一些示例Python代码:

from socketIO_client import SocketIO

print "connecting to server"
socketIO = SocketIO('https://streamer.cryptocompare.com/',443, transports=['websocket'])
print "Connected"

但是,无论我做什么,我都无法连接.实际上,这是连接的结果

connecting to server
Traceback (most recent call last):
  File "test.py", line 4, in <module>
socketIO = SocketIO('https://streamer.cryptocompare.com/',443, transports=['websocket'])
  File "/usr/local/lib/python2.7/site-packages/socketIO_client/__init__.py", line 353, in __init__
resource, hurry_interval_in_seconds, **kw)
  File "/usr/local/lib/python2.7/site-packages/socketIO_client/__init__.py", line 54, in __init__
self._transport
  File "/usr/local/lib/python2.7/site-packages/socketIO_client/__init__.py", line 62, in _transport
self._engineIO_session = self._get_engineIO_session()
  File "/usr/local/lib/python2.7/site-packages/socketIO_client/__init__.py", line 76, in _get_engineIO_session
transport.recv_packet())
StopIteration

将上述代码包装在try-catch中并打印异常不会产生额外信息.任何帮助将不胜感激.

Answer 1

您需要在设置套接字后立即调用emit来设置您想要接收的订阅。

socketIO.emit('SubAdd', { subs: ['0~Poloniex~BTC~USD'] });