我正在尝试订阅Bitfinex.com websocket API公共频道BTCUSD
。
这是代码:
from websocket import create_connection
ws = create_connection("wss://api2.bitfinex.com:3000/ws")
ws.connect("wss://api2.bitfinex.com:3000/ws")
ws.send("LTCBTC")
while True:
result = ws.recv()
print ("Received '%s'" % result)
ws.close()
我相信ws.send("BTCUSD")
订阅公共频道的是什么?我收到一条消息,我认为正在确认订阅({"event":"info","version":1}
,但此后我没有得到数据流。我想念什么?
更新:这是最终起作用的代码。
import json
from websocket import create_connection
ws = create_connection("wss://api2.bitfinex.com:3000/ws")
#ws.connect("wss://api2.bitfinex.com:3000/ws")
ws.send(json.dumps({
"event": "subscribe",
"channel": "book",
"pair": "BTCUSD",
"prec": "P0"
}))
while True:
result = ws.recv()
result = json.loads(result)
print ("Received '%s'" % result)
ws.close()
该文档说所有消息都是JSON编码的。
讯息编码
通过Bitfinex的websocket通道发送和接收的每条消息均以JSON格式编码
您需要导入json
库,以对消息进行编码和解码。
该文件提到了三次公开渠道:book
,trades
和ticker
。
如果要订阅频道,则需要发送一个订阅事件。
根据文档,订阅LTCBTC交易的示例:
ws.send(json.dumps({
"event":"subscribe",
"channel":"trades",
"channel":"LTCBTC"
})
然后,您还需要解析传入的JSON编码的消息。
result = ws.recv()
result = json.loads(result)
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句