#time.sleep(3)

#time.sleep(10)

#time.sleep(1)

#time period

#time.sleep(10)

/>token=tick['instrument_token']<br />#time = ticks[0]['timestamp']<br />times = time.time()<br />print(ltp,times)<br />sheet.range('A' + str(row_no)).value = times<br /

&lt;= 10:<br />try:<br />#time.sleep(0.5)<br />download_try = download_try+1<br />records = self.kite.historical_data(self.instrument_token\<br />,from_date,to_date,

#timestamp = datetime.fromtimestamp(_unpack_int(packet, 60, 64))

) <br />#time_correct_thread creation for first level of filtering data : removal of same tickers <br />correct_time=time_correct_mythread()<br />WebSocket.start() # Adds tick price

/>#tickdata = tick<br />#time.sleep(10)<br /># Callback for successful connection.<br />def on_connect(ws):<br /># Subscribe to a list of instrument_tokens (RELIANCE and AC

/>#tickdata = tick<br />#time.sleep(10)<br /># Callback for successful connection.<br />def on_connect(ws):<br /># Subscribe to a list of instrument_tokens (RELIANCE and AC

My requirement is :- websockets should be always streaming the data and store in a queue, i want to read that queue in another parallel thread and process the data.Please guide me from kiteconnect im