I am working with the Binance API. I am connecting to their API and trying to assess if Binance has a list of assets on their platform or not. The list of assets is seen below:
assets = ['tribe', 'pax']
I pass this through to their API by inserting the name of the assets into the SOCKET link:
SOCKET = f"wss://stream.binance.com:9443/ws/{asset}usdt@ticker"
I know the asset does exist on their website if on_message is called, because then I have accomplished a consistent connection with their API and it will keep printing messages unless I close the connection (which I do). However, if no message is received in n time I know they do not have the asset I am looking for. In this case Binance does have tribe, but not pax. I want to close the connection if the asset is not on their website after n time, how do I do this?
import ssl
import websocket
def on_open(ws):
print('connection: successful')
def on_close(ws, *args):
print('connection: lost')
print("---------------------------------------------------")
ws.close()
def on_message(ws, message):
print("message received")
print()
ws.close()
def on_error(ws, message):
print(message)
print()
assets = ['tribe', 'pax']
for asset in assets:
print(asset)
SOCKET = f"wss://stream.binance.com:9443/ws/{asset}usdt@ticker"
ws = websocket.WebSocketApp(SOCKET, on_open=on_open, on_close=on_close, on_message=on_message,
on_error=on_error)
ws.run_forever(sslopt={"cert_reqs": ssl.CERT_NONE})
I have attempted to write:
if on_message == False:
ws.close()
however this does not work because on_message is not even being called as far as my knowledge goes.
Here is the Binance API documentation: https://github.com/binance/binance-spot-api-docs/blob/master/web-socket-streams.md#klinecandlestick-streams Here is the websocket-client documentation: https://websocket-client.readthedocs.io/en/latest/examples.html