如何解决在流式传输 Websocket 时使用 REST API 1.通过 Websocket 流式传输2.通过 REST API 发送订单
如何通过 REST API 请求,同时通过 Websocket 进行流式传输?
示例:
客户端和交易所服务器之间的通信使用交易所的 API 进行交易。
具体来说,我想使用 REST API 请求发送订单,
然后我想通过私有 Websocket 从交易所接收我的订单信息。
下面是代码。
如果我开始订阅 Websocket(参见 1),它将处于 ws.run_forever()
循环中。
如何在 ws.run_forever()
循环中执行 2. 以便一旦执行订单我立即从交易服务器接收订单信息?
1.通过 Websocket 流式传输
# Subscribing to order information from an exchange via WebSocket API
import json
import websocket
def on_open(self):
message = {
"command": "subscribe","channel": "orderEvent"
}
ws.send(json.dumps(message))
def on_message(self,message):
# do something...
endpoint = "url"
ws = websocket.WebSocketApp(endpoint,on_open=on_open,on_message=on_message
)
ws.run_forever()
2.通过 REST API 发送订单
# Sending order
import requests
reqBody = {
"side": BUY,"amount" : AMOUNT,}
requests.post("request_url",headers=headers,data=json.dumps(reqBody))
解决方法
在处理消息时,您可以决定提交订单。这样的事情应该可以工作
def on_message(self,message):
if something:
response = buy_stock(AMOUNT)
def buy_stock(AMOUNT):
reqBody = {
"side": BUY,"amount" : AMOUNT,}
r = requests.post("request_url",headers=headers,data=json.dumps(reqBody))
return r
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。