Websocket2.0 just stops after running for 1 min without any errors etc.

af

@projectSB can you share the code i am not able to find the exact version

projectSB

@af I'm using the Websocket version 2.0 code as provided in this Github link:

https://github.com/angel-one/smartapi-python

This portion:

####### Websocket V2 sample code #######

from SmartApi.smartWebSocketV2 import SmartWebSocketV2
from logzero import logger

AUTH_TOKEN = "Your Auth_Token"
API_KEY = "Your Api_Key"
CLIENT_CODE = "Your Client Code"
FEED_TOKEN = "Your Feed_Token"
correlation_id = "abc123"
action = 1
mode = 1
token_list = [
{
"exchangeType": 1,
"tokens": ["26009"]
}
]
sws = SmartWebSocketV2(AUTH_TOKEN, API_KEY, CLIENT_CODE, FEED_TOKEN)

def on_data(wsapp, message):
logger.info("Ticks: {}".format(message))
# close_connection()

def on_open(wsapp):
logger.info("on open")
sws.subscribe(correlation_id, mode, token_list)

def on_error(wsapp, error):
logger.error(error)

def on_close(wsapp):
logger.info("Close")

def close_connection():
sws.close_connection()

Assign the callbacks.

sws.on_open = on_open
sws.on_data = on_data
sws.on_error = on_error
sws.on_close = on_close

sws.connect()

ajileshparolla

@projectSB Did you find any solution for this? I am having the same issue.

projectSB

@ajileshparolla Nope! no solutions so far
no admins replied as well

kishan9907

@projectSB see if this helps, I've added below code when I got a similar error

def on_data(wsapp, message):
        if message != b'\x00':
            #process data

af

@projectSB i have been getting same problem. but i got the solution. go to your on
smartWebscketV2.py and find this " def on_close(self, wsapp):
pass
" on your side the argument would be 4 in there make it like this. and thats it. it will work

J88913

Watch the video and download the code to get the live data into Excel
Youtube Video

Bhuva008

@admin
yes facing same , connection is getting disconnected
in first 30 sec,
Attempting to resubscribe/reconnect...
next 30 sec,
Connection closed
Connection closed
Connection closed

Bhuva008

Hello looks like i found solution !

use try: expect : in you on_data definition , looks like sometime in socket it is not able to decode stream and get close rather then printing error.

def on_data(wsapp, msg):
#print("Ticks: {}".format(msg))
try:
LIVE_FEED_JSON[msg['token']] = {'token' : msg['token'],'ltp' : msg['last_traded_price']/100 , 'timestamp' : datetime.fromtimestamp(msg['exchange_timestamp']/1000).isoformat()}
print(LIVE_FEED_JSON)
except Exception as e:
print(e)

projectSB

@kishan9907 said in Websocket2.0 just stops after running for 1 min without any errors etc.:

if message != b'\x00':

Thanks! I have implemented this into my code. Hope this works!

projectSB

@Bhuva008 Thanks! will try this as well