WebSocket API для рынков прогнозов: Безопасная реконструкция котировок в реальном времени
Подключение к сокету — это просто. Поддержание правильной котировки с помощью начальных данных, дельт, повторных подключений и специфичной для площадки каденции — это реальная инженерная работа.
WebSocket-клиент для рынка прогнозов нуждается в полной начальной котировке, детерминированном порядке обновления, исходных и полученных временных метках, обработке сердцебиения и пути восстановления после любого пропусков. Данные Polymarket можно получить из обновлений CLOB, данные Kalshi могут поступать через другой механизм площадки. Нормализованный фрейм для последующей обработки полезен только тогда, когда он сохраняет эти исходные различия, а не притворяется, что у каждой площадки одинаковый транспорт.
Минимальный правильный конечный автомат
- Разрешите стабильные идентификаторы рынка и исхода перед подпиской.
- Загрузите или получите полную котировку перед применением инкрементных изменений.
- Применяйте обновления в задокументированном исходном порядке и отклоняйте устаревшие состояния.
- Отслеживайте сердцебиение или время последнего сообщения независимо для каждого соединения.
- При разрыве последовательности или неопределенном повторном подключении отбросьте локальную котировку и перезагрузите ее.
- Публикуйте исходное время, время получения и четкий флаг снимка против дельты для последующей обработки.
Снимок и дельта не взаимозаменяемы
Снимок заменяет состояние; дельта изменяет его. Отношение одного к другому приводит к котировке, которая может выглядеть правдоподобно, сохраняя удаленные уровни или опуская неизмененный размер. Напишите явные тесты для вставки уровня, замены размера, удаления и отклонения пересекающихся котировок.
Последующие потребители не должны гадать, получили ли они полный «лестницу». Включите тип сообщения или предоставляйте нормализованные полные фреймы котировок, когда простота стоит дополнительной пропускной способности.
Нормализация, учитывающая площадку
DepthFeed получает данные Polymarket из потока CLOB и записывает нормализованные наблюдения. Книги Kalshi для спортивных и крипто-рынков следуют задокументированным специфичным для площадки путям сбора, включая адаптивный публичный REST, где это применимо. Последующая схема может оставаться согласованной, в то время как метаданные идентифицируют, как и когда каждый источник был зафиксирован.
Для платных планов WebSocket DepthFeed предоставляет нормализованные каналы котировок в реальном времени с ограничениями подключения и подписки, специфичными для плана. Исторические запросы REST используют одну и ту же форму цену-размер, что позволяет повторно использовать логику разбора и заполнения между живым мониторингом и воспроизведением.
Тесты на сбои в производстве
| Сбой | Ожидаемое поведение | Небезопасное поведение |
|---|---|---|
| Соединение обрывается | Повторное подключение, перезагрузка, возобновление из известного состояния | Продолжение мутации устаревшей локальной котировки |
| Дублирующееся обновление | Идемпотентная обработка или проверка порядка источника | Двойной размер котировки |
| Обновление вне порядка | Отклонение или перестроение | Применение по порядку прибытия без доказательств |
| Медленный потребитель | Обработка обратной связи, объединение или политика отключения | Неограниченный рост памяти |
| Отсутствие недавнего обновления | Отображение свежести по рынку | Сообщение о последней цене как о живой |
Key takeaways
- 01Полная котировка должна существовать до того, как дельты могут сформировать надежную котировку.
- 02Неопределенность повторного подключения должна вызывать перезагрузку, а не оптимистичное продолжение.
- 03Исходное время и время получения отвечают на разные вопросы о задержке.
- 04Нормализация должна сохранять метаданные захвата, специфичные для площадки.
- 05Самые безопасные API для живого и исторического использования имеют одну явную форму «лестницы».
Подключение к сокету — это просто. Поддержание правильной котировки с помощью начальных данных, дельт, повторных подключений и специфичной для площадки каденции — это реальная инженерная работа.
Начать бесплатно