我需要监听用户数据流，每当发生订单事件时——订单执行、取消等等——我希望能够监听这些事件并创建通知。
所以我得到了我的"；listenKey"；我不确定它是否以正确的方式完成，但我执行了这段代码，它给了我类似listenKey的东西。
获取列表的代码密钥：
def get_listen_key_by_REST(binance_api_key):
url = 'https://api.binance.com/api/v1/userDataStream'
response = requests.post(url, headers={'X-MBX-APIKEY': binance_api_key})
json = response.json()
return json['listenKey']
print(get_listen_key_by_REST(API_KEY))
以及监听用户数据流的代码——这不起作用，我没有得到json响应。
socket = f"wss://fstream-auth.binance.com/ws/btcusdt@markPrice?listenKey=<listenKeyhere>"
def on_message(ws, message):
json_message = json.loads(message)
print(json_message)
def on_close(ws):
print(f"Connection Closed")
# restart()
def on_error(ws, error):
print(f"Error")
print(error)
ws = websocket.WebSocketApp(socket, on_message=on_message, on_close=on_close, on_error=on_error)
我看了那些文件，但没有用。如果有人能为我指明正确的方向，我将不胜感激。
您可以从这里的文档中创建一个基本的异步用户套接字连接，以及Binance API的其他有用信息。这里有一个简单的例子：
import asyncio
from binance import AsyncClient, BinanceSocketManager
async def main():
client = await AsyncClient.create(api_key, api_secret, tld='us')
bm = BinanceSocketManager(client)
# start any sockets here, i.e a trade socket
ts = bm.user_socket()
# then start receiving messages
async with ts as tscm:
while True:
res = await tscm.recv()
print(res)
await client.close_connection()
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
我自己刚刚想好了，我能够让我的工作开始，所以我会尽力指导你。我相信你只是在创建WebSocket对象后错过了这行代码：
ws.run_forever()
其他一些原因可能不起作用；如果你想检测期货账户上的订单，那么你需要使用期货端点。我认为你使用的是现货交易(不确定(。
url = 'https://fapi.binance.com'
以防你不清楚。您必须更换：
<listenkeyhere>
在套接字url中，使用侦听键、尖括号等。