Continously processing the websocket data on website.

It is a very vague statement. Websocket API seems fine at our end. How can someone help you out without any context or logs?

You asked such a general question like "How will I recieve sunlight in my home?" But then blaming @sujith for your vagueness instead of explaining it furthur.

You really wanted to ask a question, or just wanted that someone provide you the code and spoon feed you?

By the way here is the elaboration I can provide

1 - I was using Django to send triggers on UI after doing certain checks but when I am pulling data from a queue in Python it gets lost (as it is a normal behavior). Here I am using two threads
1st is to receive the data continuously and 2nd one to process the received data from a queue in Python and do certain checks. In a second thread where I am using the process tick function I want to do a synchronization say, We should not process other sets of ticks until the old ticks are processed or checked.

The approach which I have with me is -

1 - use Kafka and other queues
2 - manage this through a flag in data frame instead of a queue.

Is there another approach I can use.

class KiteCons(AsyncWebsocketConsumer):
def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs)
# self.list_data = Queue()

async my_connect():
await self.accept() # accepting the UI connection

#other processing and db operations

def on_ticks(self, ws, ticks):
# Add ticks to the queue
self.list_data.put(ticks)

def on_connect(self, ws, response):
# Subscribe to desired instrument tokens
ws.subscribe([4451329, 415745, 1427969, 7982337, 1195009])
print("Subscribed to instrument tokens")

def on_close(self, ws, code, reason):
print(f"WebSocket closed: {code}, {reason}")

self.kite_ticker.on_ticks = self.on_ticks
self.kite_ticker.on_connect = self.on_connect
self.kite_ticker.on_close = self.on_close

self.kite_ticker.connect(threaded=True)

self.loop = asyncio.get_event_loop()
self.processing_thread = threading.Thread(target=self.process_ticks, args=(self.loop,))
self.processing_thread.start()
print("Processing thread started")

async def disconnect(self, code):
print('Disconnecting...')
self.stop_event.set()
# Close the KiteTicker WebSocket connection
if self.kite_ticker:
self.kite_ticker.close()
# Stop the processing thread
self.processing_thread.join()

def process_ticks(self, loop):
#fetching data here from the queue and doing the process

I suggest instead of using queue, use redis instead where your key would be token id. It also allow to debug the problems of your program more efficiently. If that works, then move to kafka.