Websocket Streaming Error - Reactor Not Restrtable

Anuj

Hi Vivek,

I am using your code (exact copy/paste from another thread) but am still getting the Reactor not Restartable error. Pl


The code is:

from kiteconnect import KiteTicker, KiteConnect

logging.basicConfig(level=logging.DEBUG)

def init(api_key, api_secret):
kite = KiteConnect(api_key=api_key)
request_token="abc"
data = kite.generate_session(request_token, api_secret)
kite.set_access_token(data["access_token"])
return data["access_token"]

# Initialise
api_key="abc"
api_secret="abc"
access_token=init(api_key, api_secret)

kws = KiteTicker(api_key, access_token, debug=True)

def on_ticks(ws, ticks):
print(ticks)

def on_connect(ws, response):
logging.debug("on connect: {}".format(response))
ws.subscribe([738561, 5633])
ws.set_mode(ws.MODE_FULL, [738561])


def on_close(ws, code, reason):
logging.error("closed connection on close: {} {}".format(code, reason))


def on_error(ws, code, reason):
logging.error("closed connection on error: {} {}".format(code, reason))


def on_noreconnect(ws):
logging.error("Reconnecting the websocket failed")


def on_reconnect(ws, attempt_count):
logging.debug("Reconnecting the websocket: {}".format(attempt_count))


def on_order_update(ws, data):
print("order update: ", data)

# Assign the callbacks.
kws.on_ticks = on_ticks
kws.on_connect = on_connect
kws.on_close = on_close
kws.on_error = on_error
kws.on_noreconnect = on_noreconnect
kws.on_reconnect = on_reconnect
kws.on_order_update = on_order_update


# Infinite loop on the main thread. Nothing after this will run.
# You have to use the pre-defined callbacks to manage subscriptions.
kws.connect()