? ???? Python?? WebSocket ??? ??? ??? ??? ?????.

??? ??? ??? ??? ????.

• ????? ?? ??: ????? ??? ???? ?? ? ?????? ??? "??? ?(API ?)"? ??? ?????.
• ?? WebSocket? ??: ??? ??? WebSocket ??? ?????.
• ??? ???: ??? ??? WebSocket?? ???? ???? ??? ?? ?????? ????.

???? ??:

• Python 3.6 ?? ??? ????? ?????. WebSocket?? Python 3.6 ??? ?????.
• WebSockets ????? ??: ????? ?? ??? ???? ??? ? ????.

pip install websockets

1. ????

• ????? ?? ? ??? ????.
• ?? ?? ? Python ??? ??? ??? 'websocket_proxy_server.py'? ?????. ? ???? ??? ?? ??? ?? ????.

2. WebSocket ?? ??

• ??? ?????? ?????. ??? ??? ?????? ?????.
• ??? ?? ??? ?????. WebSockets ?????? ???? ??? ??? ????.

import asyncio
import websockets
import json

class WebSocketProxy:

    def init(self, source_url, symbols):

        self.source_url = source_url
        self.clients = set()
        self.symbols = symbols
        self.valid_user_key = "yourValidUserKey"  # Single valid user key for authentication

    async def on_open(self, ws):

        print("Connected to source")
        symbols_str = ",".join(self.symbols.keys())
        init_message = f"{{"userKey":"your_api_key", "symbol":"{symbols_str}"}}"
        await ws.send(init_message)

3. ????? ?? ? ??

• ??? ?????? ??? ????? ?? ???? ??? ?????.
• ? ??? ??? ????? ??? ?????. ?????? ??? ???? ??? "??? ?"? ???? ???. ??? ?? ?? ?????? ??? ?????.

async def client_handler(self, websocket, path):

        try:

            # Wait for a message that should contain the authentication key
            auth_message = await asyncio.wait_for(websocket.recv(), timeout=10)
            auth_data = json.loads(auth_message)
            user_key = auth_data.get("userKey")

            if user_key == self.valid_user_key:
                self.clients.add(websocket)
                print(f"Client authenticated with key: {user_key}")

                try:
                    await websocket.wait_closed()

                finally:
                    self.clients.remove(websocket)

            else:

                print("Authentication failed")
                await websocket.close(reason="Authentication failed")
        except (asyncio.TimeoutError, json.JSONDecodeError, KeyError):
            print("Failed to authenticate")
            await websocket.close(reason="Failed to authenticate")

4. ??? ???? ??? ??

• ??? ?? WebSocket? ?? ???? ??? ????.
• ? ??? ?? WebSocket?? ?? ???? ????? ??? ?? ?????? ???? ??? ???.

async def source_handler(self):
        async with websockets.connect(self.source_url) as websocket:
            await self.on_open(websocket)
            async for message in websocket:
                await self.broadcast(message)

    async def broadcast(self, message):
        if self.clients:
            await asyncio.gather(*(client.send(message) for client in self.clients))

5. ?? ??

• ??? ???? ??? ???? ??? ????.
• WebSocket ??? ??? ???? ? ??? ???? ??? ?????.

def run(self, host="localhost", port=8765):
        start_server = websockets.serve(self.client_handler, host, port)
        asyncio.get_event_loop().run_until_complete(start_server)
        asyncio.get_event_loop().run_until_complete(self.source_handler())
        asyncio.get_event_loop().run_forever()

if name == "main":
    symbols = {"EURUSD": {}, "GBPUSD": {}, "USDJPY": {}, "AUDUSD": {}, "USDCAD": {}}
    source_url = "ws://example.com/source"
    proxy = WebSocketProxy(source_url, symbols)
    proxy.run()

????

Python ?? WebSocket ??? ??? ????? ???????. ? ??? ????? ID? ????, ??? ??? ??? ?? ???? ??? ????, ???? ?? ???? ??? ?? ?????? ????? ??? ? ????. ? ??? ?? ???? ??? ??? ???? ???? ???? ????? ???? ?? ??????? ?? ??? ??? ???????.

?? ??

??? ??? ???? ????? ??? ?? ???? ?????. ?? ? ??? ??? ???? ????? ?????. ???? ???? ?? ??? ????? ???? ?? ??? ??? ???? ?? ????. ?????, ??? ???? ??? ????? ??? ??? ???? ??? ? ???? ??? ??? ??? ??? ???? ?? ????.

?? ?? ????? ?? ??? ????? Python ???? ???? Forex WebSocket ??

? ????? ????.

? ??? Python ???? ???? ?? ??? Forex WebSocket ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!