WebSockets في Polymarket: بيانات آنية لا تنقطع

إذا كان بوتك يستطلع GET /book على مؤقت، فستوفر عليك هذه الصفحة معظم ميزانية حد المعدل وجزءًا من زمن الاستجابة. تدفع Polymarket تحديثات الدفتر عبر WebSocket، والاشتراك يكلفك اتصالًا واحدًا بدلًا من آلاف الطلبات.

التدفقات الأربعة

الاشتراك في قناة السوق

اتصل، ثم أرسل رسالة اشتراك JSON واحدة. يأخذ assets_ids معرّفات التوكنات — نفسها التي تحصل عليها من البيانات الوصفية للأسواق — ويجب أن يكون type هو "market".

{
  "assets_ids": ["65818619657568813474341868652308942079804919287380422192892211131408793125422"],
  "type": "market",
  "initial_dump": true,
  "level": 2,
  "custom_feature_enabled": true
}

أبقِ على initial_dump: true ما لم يكن لديك سبب محدد لعدم ذلك. بدونه تبدأ بلا حالة للدفتر وعليك انتظار التحديثات التدريجية لإعادة بنائها، ما يعني أن بوتك يبدأ حياته بصورة ناقصة.

أنواع الرسائل

تحمل كل رسالة event_type. تفرّع عليه بشكل شامل — النوع غير المعروف يجب تسجيله لا إسقاطه بصمت، لأن هذه هي الطريقة التي تكتشف بها أن البروتوكول تغيّر.

البقاء متصلًا: PING كل 10 ثوانٍ

هذا هو الاشتراط الذي يوقع الجميع. يجب على العميل إرسال PING كل 10 ثوانٍ؛ ويرد الخادم بـ PONG. فوّت النبضة وسيُقطع الاتصال.

لاحظ الاتجاه: هذه نبضة من العميل. أنت لا تنتظر أن يرسل لك الخادم ping. وآلية keepalive المدمجة في مكتبة WebSocket بفاصل زمني آخر ليست بديلًا — أرسل PING على مستوى التطبيق بنفسك.

import asyncio, json, time
import websockets

URL = "wss://ws-subscriptions-clob.polymarket.com/ws/market"
STALE_AFTER = 30          # seconds without any message = treat as dead


async def stream(token_ids, on_event):
    backoff = 1
    while True:
        try:
            async with websockets.connect(URL) as ws:
                await ws.send(json.dumps({
                    "assets_ids": token_ids,
                    "type": "market",
                    "initial_dump": True,
                    "custom_feature_enabled": True,   # or lose 3 event types
                }))
                backoff = 1                            # reconnected cleanly
                last_msg = time.monotonic()

                async def heartbeat():
                    while True:
                        await asyncio.sleep(10)        # required cadence
                        await ws.send("PING")

                hb = asyncio.create_task(heartbeat())
                try:
                    while True:
                        # Silence is a failure mode, not a quiet market.
                        raw = await asyncio.wait_for(ws.recv(), timeout=STALE_AFTER)
                        last_msg = time.monotonic()
                        if raw == "PONG":
                            continue
                        for msg in json.loads(raw) if raw.startswith("[") else [json.loads(raw)]:
                            on_event(msg)
                finally:
                    hb.cancel()

        except Exception as exc:
            # Reconnect with capped exponential backoff + jitter.
            wait = min(backoff, 30) * (0.5 + 0.5 * asyncio.get_event_loop().time() % 1)
            print(f"ws down ({exc}); reconnecting in {wait:.1f}s")
            await asyncio.sleep(wait)
            backoff = min(backoff * 2, 30)

تغيير الاشتراكات دون إعادة الاتصال

تنتهي أسواق الخمس دقائق باستمرار، لذا يحتاج بوت يتتبع "أسواق BTC 5m الحالية" إلى تغيير مجموعة اشتراكاته باستمرار. لا يتعين عليك هدم الاتصال لذلك — قناة السوق تدعم الاشتراك وإلغاء الاشتراك على اتصال حي.

هذا أهم مما يبدو. إعادة الاتصال عند كل تدوير للأسواق تعني دفع تكلفة إعداد الاتصال مرارًا، وإعادة طلب اللقطات الأولية، وخلق نافذة لا تتلقى فيها شيئًا في اللحظة نفسها التي يُفتتح فيها سوق جديد.

نمط الفشل الذي يكلّف المال

انقطاع WebSocket لا يطلق استثناءً. بل يتوقف عن توصيل الرسائل. بالنسبة لبوت ساذج، لا يمكن تمييز "لا تحديثات" عن "السوق لا يتحرك" — لذا سيبقى بوت يحمل مركزًا على سعر متقادم إلى أجل غير مسمى، واثقًا من أن شيئًا لم يتغير.

• تتبّع عمر آخر رسالة. إذا لم يصل شيء خلال ~30 ثانية في سوق نشط، فأنت منقطع، لا في هدوء. مهلة asyncio.wait_for أعلاه تؤدي هذه المهمة بالضبط.
• تعامل مع التقادم كحالة خطأ. توقف عن التسعير، وصفِّ مراكزك إن كانت قواعد المخاطر لديك تقتضي ذلك، وأعد الاتصال — لا تواصل التداول على دفتر متجمد.
• تراجع عند إعادة الاتصال، مع تذبذب عشوائي. حلقة إعادة اتصال ضيقة أثناء انقطاع هي الطريقة التي تُقيَّد بها بحد المعدل فوق انقطاعك، وأسطول يعيد الاتصال بالتزامن يزيد الأمر سوءًا.
• أعد مزامنة الحالة بعد إعادة الاتصال. فاتتك تحديثات أثناء غيابك. اعتبر initial_dump الجديد هو الحقيقة وتخلّص من دفترك السابق، بدلًا من دمج التحديثات التدريجية في لقطة متقادمة.
• طابق المراكز بعد أي فجوة. إذا انقطعت عن قناة User، فربما فاتك تنفيذ. أعد قراءة المراكز قبل التصرف بناءً على حالة مفترضة.

WebSockets وحدود المعدل

سؤال متكرر، وإجابته هي الغاية من التمرين كله: الاشتراك لا يستهلك ميزانية حد المعدل لكل طلب كما يفعل الاستطلاع. حدود Polymarket الموثقة هي حدود HTTP لكل نقطة نهاية، والبث يتجاوزها بالكامل تقريبًا.

ستظل تجري استدعاءات HTTP — لاكتشاف الأسواق، وأحجام التيك، وتقديم الأوامر، ومطابقة المراكز — وتبقى خاضعة لـ حدود المعدل الموثقة. البث يزيل فقط أكبر مصادر حجم الطلبات وأقلها فائدة.

ما لن تمنحك إياه التدفقات

حد يستحق التصريح به بوضوح، لأنه الشيء الذي يحاوله الناس بعد ذلك. يمنحك WebSocket الدفتر من لحظة اشتراكك. ولا يمكنه أن يمنحك الدفتر يوم الثلاثاء الماضي.

لا تحتفظ Polymarket بأي دفتر أوامر تاريخي. بمجرد حسم السوق، يُرجع دفتره 404، ولا تحتفظ prices-history إلا بنقطة واحدة تقريبًا في الدقيقة. إذا أردت اختبار استراتيجية مقابل الطريقة التي تداولت بها الأسواق فعلًا، فأنت تحتاج إلى لقطات سجّلها أحدهم في حينها. تفعل PolyTest ذلك لأسواق Up/Down للعملات المشفرة، مع 8 مستويات من العمق لكل جانب والاحتفاظ بالأسواق المحسومة. أو ابدأ أداة الجمع الخاصة بك اليوم، وتقبّل أنك تبدأ بلا أي سجل، وانتظر.