Error while live streaming data

@rakeshr
Thanks for the reply. I went through this thread but couldn't get a suitable solution.

But I saw in one comment that you have mentioned to remove threaded=True from kws.connect( threaded=True)

I am using this threaded option because I am using Tkinter alongwith kiteconnect. Since tkinter also has a mainloop I had to use this, otherwise I was not able to update LTP in tkinter window.

One thing to mention is that I am not using threading module for this case. Putting kws.connect(threaded=True) serves my purpose of properly updating the LTP in tkinter window.

Do you have any suggestions for this?

Below is the code to print ticker only and it is based on your documentation itself . No additional logic implemented. Please let me know where blocking in on_tick() callback because this time also , within 30 min I am getting the same error message.

If the code(which is exactly like your documentation) is buggy the provide me the exact code line which has bug and why

Please Note : I didn't use on_close() on purpose because I don't want the execution to stop. And that is too according to your suggestion provided in different discussion thread.

import time
import logging
from kiteconnect import KiteConnect
from kiteconnect import KiteTicker
import pandas as pd
api_key="************"
api_secret="************************"
kite=KiteConnect(api_key=api_key)
access_token="******************"
kite.set_access_token(access_token)
tokens=[260105]
kws=KiteTicker(api_key, access_token)

def on_ticks(ws,ticks):
    data1 = pd.DataFrame(ticks)
    print(data1[["timestamp", "last_price"]])

def on_connect(ws,response):
    ws.subscribe(tokens)
    ws.set_mode(ws.MODE_FULL,[260105])

def on_close(ws,code,reason):
    ws.stop()

kws.on_ticks = on_ticks
kws.on_connect = on_connect
kws.connect()

Below are the are the error messages occurs at different time

0 2019-01-16 09:25:39    27503.35
            timestamp  last_price
0 2019-01-16 09:25:40     27501.5
Connection error: 1006 - connection was closed uncleanly (None)
Connection closed: 1006 - connection was closed uncleanly (None)
            timestamp  last_price
0 2019-01-16 09:25:52     27499.3
            timestamp  last_price
0 2019-01-16 09:25:53     27501.2

0 2019-01-16 09:59:39    27522.95
            timestamp  last_price
0 2019-01-16 09:59:40    27523.65
            timestamp  last_price
0 2019-01-16 09:59:41    27523.55
Connection error: 1006 - connection was closed uncleanly (None)
Connection closed: 1006 - connection was closed uncleanly (None)
Connection error: 1006 - connection was closed uncleanly (WebSocket opening handshake timeout (peer did not finish the opening handshake in time))
Connection closed: 1006 - connection was closed uncleanly (WebSocket opening handshake timeout (peer did not finish the opening handshake in time))
            timestamp  last_price
0 2019-01-16 10:00:43    27533.15
            timestamp  last_price
0 2019-01-16 10:00:44     27531.1
            timestamp  last_price
0 2019-01-16 10:00:45    27532.75

0 2019-01-16 10:37:10    27532.95
            timestamp  last_price
0 2019-01-16 10:37:11     27533.2
            timestamp  last_price
0 2019-01-16 10:37:12     27530.6
Connection error: 1006 - connection was closed uncleanly (None)
Connection closed: 1006 - connection was closed uncleanly (None)
            timestamp  last_price
0 2019-01-16 10:37:28    27531.65
            timestamp  last_price
0 2019-01-16 10:37:29    27534.15
            timestamp  last_price
0 2019-01-16 10:37:30    27534.05

Please do not say here that these error only occurring at my side and everywhere its working fine BECAUSE below is the link for another discussion thread where someone else has faced the same issue and there also you guys didn't provide the solution

https://kite.trade/forum/discussion/5426/error-while-live-streaming-data#latest

If these evidence are not enough then please let me know what else is required and how I can provide them

@zartimus
Any updates ?

thanks @razcads for replying.

The problem is , I am converting these ticks in 5min candles and after that I do many calculation like body and shadow length,ATR etc. These calculation are necessary to generate buy or sell call. So if there are missing ticks frequently then all the output of those calculations will be changed , which generate wrong Trade Calls.

Do you have any trick to overcome this issue or get data for those missing ticks?

@zartimus @sujith Can you confirm this behavior of your websocket ?

@razcads Thanks for the suggesstion

You can try this.

def on_error(ws,code,reason):
        message  = ("Error from KiteTicker %s, Error code %s, Error reason %s" %(ws,code, reason))
        if code == '1006':
             #  or just write this error to log or any other mechanism 
             print message 
        else:
             # if you want to abort processing for other errors           
             print message 
             ws.close()

Sorry for delayed reply. I would like to know if I put in my code kws.connect( threaded=True) this will create one thread. So whenever at runtime I want to add new token/token_list should I be executing this code again?

@drunkNifty :: Were you able to develop full code without these kinds of errors. If you have can you share some suggestions.. that would be really appreciated.

@razcads :: Surely I will try and let you know