Python Websockets Handle login errors elegantly
Hi,
I am trying to make the samples more production ready by handling error conditions. Testing an incorrect password, I am receiving the following text:
ERROR:root:LOGIN STATUS: {
"Domain":"Login",
"ID":1,
"Key":{
"Name":"rateserverss"
},
"State":{
"Code":"UserUnknownToPermSys",
"Data":"Suspect",
"Stream":"Closed",
"Text":"rateserverss, unknown to system."
},
"Type":"Status"
}
I am detecting this, however how do I terminate the loop in the main program?
logger.error("LOGIN STATUS: %s", json.dumps(message_json, sort_keys=True, indent=2, separators=(',', ':')))
if message_json['State']['Stream'] != "Open" or message_json['State']['Data'] != "Ok":
logger.error("Login Request rejected / failed:"+message_json['State']['Text'])
shutdown_app = True
exit(5000)
The routine exits, however the main code is never executed and the program just hangs, processing additional callbacks.
Note I am using threading and the run_forever version of the web socket app:
ws_address = "ws://{}:{}/WebSocket".format(host, port)
print("Connecting to WebSocket " + ws_address + " ...")
logger.info("Connecting to WebSocket " + ws_address + " ...")
web_socket_app = websocket.WebSocketApp(ws_address, header=['User-Agent: Python'],
on_message=on_message,
on_error=on_error,
on_close=on_close,
subprotocols=['tr_json2'])
web_socket_app.on_open = on_open
# Event loop
wst = threading.Thread(target=web_socket_app.run_forever)
Best Answer
-
I found a solution on StackOverflow.
In the callback method, you can call the ws.close() method to close the websocket connection.
if message_type == "Status" and message_json['State']['Stream']=="Closed" and message_json['Domain']=="Login":
print("Login Closed")
ws.close()In the main thread, you can call wst.is_alive() method to check whether a thread is alive.
try:
while True:
time.sleep(1)
if wst.is_alive() == False:
exit(0)1
Answers
-
Note that the code works perfectly with correct login credentials0
-
The problem was not in the callback...it was in the main routine where there was a loop waiting for a successful login.
My code:
while not logged_in:
time.sleep(1)This would lead to an endless loop when login fails.
Sample code on github:
while not logged_in and (not shutdown_app):
time.sleep(1)shutdown_app also needs to be set in the callback routine:
else:
logger.error("LOGIN STATUS: %s", json.dumps(message_json, sort_keys=True, indent=2, separators=(',', ':')))
if message_json['State']['Stream'] != "Open" or message_json['State']['Data'] != "Ok":
logger.error("Login Request rejected / failed:"+message_json['State']['Text'])
shutdown_app = True0 -
Thanks for the response - turns out the callback was working OK and the problem was actually in the main code - see my posted response for details0
Categories
- All Categories
- 6 AHS
- 39 Alpha
- 161 App Studio
- 4 Block Chain
- 4 Bot Platform
- 16 Connected Risk APIs
- 47 Data Fusion
- 30 Data Model Discovery
- 608 Datastream
- 1.3K DSS
- 577 Eikon COM
- 4.9K Eikon Data APIs
- 7 Electronic Trading
- Generic FIX
- 7 Local Bank Node API
- Trading API
- 2.7K Elektron
- 1.3K EMA
- 236 ETA
- 519 WebSocket API
- 33 FX Venues
- 10 FX Market Data
- 1 FX Post Trade
- 1 FX Trading - Matching
- 12 FX Trading – RFQ Maker
- 5 Intelligent Tagging
- 2 Legal One
- 20 Messenger Bot
- 2 Messenger Side by Side
- 9 ONESOURCE
- 7 Indirect Tax
- 59 Open Calais
- 264 Open PermID
- 39 Entity Search
- 2 Org ID
- PAM
- PAM - Logging
- 8.4K Private Comments
- 6 Product Insight
- Project Tracking
- ProView
- ProView Internal
- 20 RDMS
- 1.4K Refinitiv Data Platform
- 367 Refinitiv Data Platform Libraries
- 3 Refinitiv Due Diligence
- LSEG Due Diligence Portal API
- 3 Refinitiv Due Dilligence Centre
- Rose's Space
- 1.1K Screening
- 18 Qual-ID API
- 13 Screening Deployed
- 23 Screening Online
- 10 World-Check Customer Risk Screener
- 990 World-Check One
- 44 World-Check One Zero Footprint
- 45 Side by Side Integration API
- Test Space
- 3 Thomson One Smart
- 1.2K TR Internal
- Global Hackathon 2015
- 2 Specialists Who Code
- 10 TR Knowledge Graph
- 150 Transactions
- 142 REDI API
- 1.7K TREP APIs
- 4 CAT
- 21 DACS Station
- 117 Open DACS
- 1.1K RFA
- 103 UPA
- 172 TREP Infrastructure
- 224 TRKD
- 886 TRTH
- 5 Velocity Analytics
- 5 Wealth Management Web Services
- 60 Workspace SDK
- 9 Element Framework
- 5 Grid
- 13 World-Check Data File
- Yield Book Analytics
- 46 中文论坛