Websocket ile alakalı soru

Merhaba arkadaşlar bir sitenin websocket serverinden gelen paketlerin boyutuna göre filtreliyorum mesela 148 baytlık bir paket gelince bildirim alacağım aslında bunu yaptım zaten ama sorun çok gecikmeli(nerdeyse 7-8 saniye kadar) çalışması bu konuyu nasıl aşarım. Bir sürü paket geliyor chrome’nin inspect kısmındaki wss gibi görmek istiyorum.

import requests
import websocket
from websocket import create_connection


websocket_url = "wss://likurgus.com"

def filter_websocket_traffic(websocket_url):
    ws = create_connection(websocket_url)


    while True:
        try:
            data = ws.recv()
            print(f"Received data: {data}")

            if len(data) == 148:
                print("Filtered data:", data)
        except websocket.WebSocketConnectionClosedException:
            print("WebSocket connection closed.")
            break
filter_websocket_traffic(websocket_url)

Nerede yanlış bir şekilde sormuşum neresi yanlış anlamadım hocam. Zaten yüzlerce satır kod atmadım gayet açık bir kod.

Kod açık lakin çalıştıramıyoruz, bağlandığınız adresi bilmiyoruz. Kodda gecikmeye sebep olacak bir şey de gözükmüyor. Gecikmenin bu koddan kaynaklı olduğuna emin misiniz?

Hocam bağlandığım adresle alakalı olduğunu sanmıyorum zira başka adreslerde de denedim aynı sorun devam ediyor. İnternet bağlantımda da problem yok olsa chromede düzenli bir şekilde göremezdim paketleri

Programı nerede çalıştırıyorsunuz? Açılması birkaç saniye sürebilir. Bağlantı kurulması ve dosyanın gelmesi de birkaç saniye sürer. Bir saniye de print fonksiyonu için verebilirim.

Hangi andan itibaren 7-8 saniye gecikmeli geliyor ve ne ile karşılaştırıyorsunuz?

1 Beğeni
import asyncio
import websockets

websocket_url = "wss://likurgus.com"

async def filter_websocket_traffic(websocket_url):
    async with websockets.connect(websocket_url) as ws:
        while True:
            try:
                data = await ws.recv()
                print(f"Received data: {data}")

                if len(data) == 148:
                    print("Filtered data:", data)
            except websockets.exceptions.ConnectionClosedError:
                print("WebSocket connection closed.")
                break

asyncio.get_event_loop().run_until_complete(filter_websocket_traffic(websocket_url))

bunu dener misiniz hocam

pip install websockets