Comment surveiller les données de liquidation des contrats à terme ETHUSDT ?

Comprendre les sources de données de liquidation

1. Les points de terminaison de liquidation natifs de la bourse fournissent des enregistrements bruts et non filtrés des fermetures forcées de positions. OKX expose /api/v5/public/liquidation-orders avec des champs comprenant instId, side, fillPx, fillSz et ts.

2. Binance propose des événements de liquidation via le flux WebSocket !forceOrder@arr , diffusant des remplissages en temps réel sur tous les symboles avec une précision à la milliseconde.

3. Bybit publie les liquidations historiques via REST /v5/position/liq-record , prenant en charge la pagination et le filtrage de plages de temps jusqu'à 90 jours.

4. Le public/get_last_trades_by_instrument de Deribit inclut un indicateur de liquidation dans chaque objet commercial, permettant une identification post-hoc sans points de terminaison dédiés.

5. Les agrégateurs tiers comme Coinglass et Glassnode proposent des flux de liquidation normalisés mais introduisent une latence et peuvent omettre les exécutions partielles ou les règlements hors bourse.

Structure des données et interprétation des champs

1. instId identifie l'instrument (ETH-USDT-SWAP pour OKX, ETHUSDT pour Binance) nécessitant une logique de mappage de symboles avant l'agrégation.

Le deuxième côté indique si la position liquidée était longue ou courte, signalant directement une pression directionnelle sur l'action des prix.

3. fillPx reflète le prix d'exécution, souvent regroupé à proximité des zones de support/résistance clés où les appels de marge se cascadent.

4. fillSz désigne la taille du contrat en unités de base ; la multiplication par le prix mark donne une valeur notionnelle, essentielle pour évaluer l’exposition au risque systémique.

5. ts est un horodatage Unix en millisecondes ; l’alignement entre les échanges exige une logique d’analyse et de déduplication tenant compte des fuseaux horaires.

Architecture d'ingestion en temps réel

1. Les connexions WebSocket doivent mettre en œuvre une surveillance du rythme cardiaque et une reconnexion automatique pour éviter les événements manqués lors des interruptions du réseau.

2. Chaque charge utile de message nécessite une validation immédiate du schéma : un fillPx manquant ou un ts mal formé déclenche une suppression et une journalisation plutôt qu'un crash.

3. La déduplication repose sur des identifiants uniques spécifiques à l'échange : OKX utilise ordId , Binance utilise tradeId , nécessitant un hachage d'identifiant par source avant le stockage.

4. La mise en mémoire tampon locale avec Redis Streams permet de gérer la contre-pression lorsque les bases de données en aval sont à la traîne lors de pics de volatilité.

5. La synchronisation des horodatages entre les sources utilise des horloges système alignées sur NTP (et non des horodatages fournis par l'échange) pour éviter les distorsions dues à la dérive de l'horloge du serveur.

Stratégies de remplissage historiques

1. Le remplissage basé sur REST démarre à partir du dernier horodatage connu et revient en arrière par blocs de 100 enregistrements pour éviter les déclencheurs de limite de débit.

2. OKX applique une limite de 20 requêtes/2 secondes sur les points de terminaison publics ; le traitement par lots par instrument réduit le nombre total de demandes de 60 %.

3. Binance limite les requêtes historiques d'ordres forcés aux 7 derniers jours via REST ; les données plus anciennes nécessitent une analyse des journaux d’archives ou des archives tierces.

4. Bybit autorise les requêtes par plage de dates mais ne renvoie que 50 enregistrements par page : la logique de pagination doit suivre les jetons de curseur, pas seulement les entiers décalés.

5. Les intervalles manquants sont signalés par des rapports d'écart avec somme de contrôle, déclenchant une vérification manuelle par rapport aux journaux de règlement en chaîne, le cas échéant.

Questions et réponses courantes

Q : Puis-je compter uniquement sur WebSocket pour une couverture complète de liquidation ? Les flux WebSocket ne garantissent pas l’ordre de livraison ou l’absence de perte de paquets. Une approche hybride combinant l’ingestion WebSocket avec une réconciliation REST périodique est obligatoire pour une précision de niveau production.

Q : Pourquoi les prix de liquidation diffèrent-ils entre les bourses pour le même horodatage ETHUSDT ? Les divergences proviennent de méthodologies de prix de référence différentes, du calendrier d'accumulation des taux de financement et de la profondeur isolée du carnet de commandes : il n'existe pas de « véritable » prix de liquidation universel d'un site à l'autre.

Q : Existe-t-il un analyseur open source pour les WebSockets de liquidation OKX ? Oui, le package npm okx-liquidation-parser gère la désérialisation des messages, la normalisation des champs et la récupération des erreurs pour tous les flux OKX publics.

Q : À quelle fréquence les bourses suppriment-elles les enregistrements de liquidation historiques ? OKX conserve les données de liquidation publique pendant 30 jours. Binance conserve 7 jours via REST. Bybit maintient 90 jours. Ces fenêtres sont fixes et non négociables.