☰
›

Getting No Data When I am putting Websocket code in Python class

sudheer1990
sudheer1990 in Python client
from kiteconnect import WebSocket
#import pandas as pd

class GetWebsocketData:

def __init__(self, user_auth):
self.kws = WebSocket(user_auth.api_key, user_auth.public_token, user_auth.user_id)

def on_tick(tick, ws):
print("Sudheer")
print(type(tick[0]))
print(len(tick[0]))
#print(pd.Panel(tick[0])['ohlc'])
for x, y in tick[0].items():
print("Key - Value ", x, y)

def on_connect(ws):
# Subscribe to a list of instrument_tokens (RELIANCE and ACC here).
ws.subscribe([5633])

# Set RELIANCE to tick in `full` mode.
#self.kws.set_mode(ws.MODE_FULL, [5633])


# Assign the callbacks.
def assign_callback(self):
self.kws.on_tick = self.on_tick
self.kws.on_connect = self.on_connect
self.kws.connect()



getwebsocket = GetWebsocketData(user_auth)
getwebsocket.assign_callback()


user_auth object reference contains api_key, public_token, user_id..

Can you please tell me what is the problem here
  • Kailash
    Kailash
    Are you on Ubuntu? Please refer to this thread https://kite.trade/forum/discussion/388/default-websocket-code-doesnt-work#latest
  • sudheer1990
    sudheer1990
    no I am on windows .....using spyder(python) enviornment
  • Kailash
    Kailash
    Okay. What version is your Python?
  • sudheer1990
    sudheer1990
    Ver 3.5
  • sudheer1990
    sudheer1990
    for me below is working .......but when I am trying to put below code in class, this is not working ....

    do we need to handle the callback kind of thing in special way ..while using in class?



    public_token = "xxxxxx"
    api_key="xxxx"
    user_id = "xxx"

    #--------------------------------------------------#
    # Initialise.
    kws = WebSocket(api_key, public_token, user_id)

    # Callback for tick reception.
    def on_tick(tick, ws):
    print("Sudheer")
    print(type(tick[0]))
    print(len(tick[0]))
    #print(pd.Panel(tick[0])['ohlc'])
    for x, y in tick[0].items():
    print("Key - Value ", x, y)


    #data_dict = tick[0]
    # print(data_dict)
    #data = pd.DataFrame(data_dict)
    #print(data)
    #print(pd.DataFrame(eval(tick)['ohlc'], columns=["open", "high", "low", "close"]))



    # Callback for successful connection.
    def on_connect(ws):
    # Subscribe to a list of instrument_tokens (RELIANCE and ACC here).
    ws.subscribe([5633])

    # Set RELIANCE to tick in `full` mode.
    #ws.set_mode(ws.MODE_FULL, [5633])

    # Assign the callbacks.
    kws.on_tick = on_tick
    kws.on_connect = on_connect

    # Infinite loop on the main thread. Nothing after this will run.
    # You have to use the pre-defined callbacks to manage subscriptions.
    kws.connect()
  • Kailash
    Kailash
    I am not sure what's wrong here. If the sample code is working fine and your class based code isn't, there's an issue with the class implementation at your end.
  • sudheer1990
    sudheer1990
    I wanted to know that whether above code for websocket support class based implementation or not ?

    If it support, then i guess the code that I have written should work ?
Sign In or Register to comment.