Saltar al contenido principal
Utilidades robustas de transmisión en tiempo real para el SDK de X API. Este módulo proporciona gestión de conexiones de transmisión en tiempo real con reconexión automática, backoff exponencial y manejo exhaustivo de errores. Los clientes pueden consumir endpoints de transmisión en tiempo real sin preocuparse por la gestión de la conexión: el SDK se encarga de todo el restablecimiento de forma automática.

class xdk.streaming.StreamConfig

Configuración para conexiones de streaming con lógica de reintento.

Parámetros

int
predeterminado:"10"
float
predeterminado:"1.0"
float
predeterminado:"64.0"
float
predeterminado:"2.0"
bool
predeterminado:"True"
float or None
predeterminado:"None"
int
predeterminado:"1024"
Callable[[], None] or None
predeterminado:"None"
Callable[[Exception or None], None] or None
predeterminado:"None"
Callable[[int, float], None] or None
predeterminado:"None"
Callable[[[StreamError

__init__

Parámetros

int
predeterminado:"10"
float
predeterminado:"1.0"
float
predeterminado:"64.0"
float
predeterminado:"2.0"
bool
predeterminado:"True"
float or None
predeterminado:"None"
int
predeterminado:"1024"
Callable[[], None] or None
predeterminado:"None"
Callable[[Exception or None], None] or None
predeterminado:"None"
Callable[[int, float], None] or None
predeterminado:"None"
Callable[[[StreamError

on_error : Callable[[[StreamError]

exception xdk.streaming.StreamError

Excepción que se lanza para errores de streaming con clasificación.

Parámetros

str
StreamErrorType

__init__

Parámetros

str
StreamErrorType

class xdk.streaming.StreamErrorType

Clasificación de errores de streaming para tomar decisiones de reintento.

Parámetros

Any

class xdk.streaming.StreamState

Estado interno de una conexión de streaming.

Parámetros

int
predeterminado:"0"
float
predeterminado:"1.0"
bool
predeterminado:"False"
int
predeterminado:"0"
StreamError

__init__

Parámetros

int
predeterminado:"0"
float
predeterminado:"1.0"
bool
predeterminado:"False"
int
predeterminado:"0"
StreamError

last_error : [StreamError]

xdk.streaming.stream_with_retry

Transmite datos desde un endpoint con reconexión automática y backoff exponencial. Esta función gestiona toda la conexión, incluyendo:
  • Reconexión automática ante desconexiones
  • Backoff exponencial con jitter para los retrasos entre reintentos
  • Clasificación de errores como reintentables o fatales
  • Callbacks de ciclo de vida para supervisar el estado de la conexión

Parámetros

Session
La sesión de requests que se utilizará para las llamadas HTTP.
str
Método HTTP (normalmente «GET»).
str
La URL completa desde la que se hará streaming.
StreamConfig
StreamConfig con configuración de reintentos y callbacks.