Este módulo proporciona un cliente para interactuar con los endpoints de actividad de la X API.
Las operaciones de streaming en tiempo real devuelven generadores que emiten datos a medida que llegan.
Las conexiones de streaming se gestionan automáticamente mediante lógica de reintentos con backoff exponencial para una gestión robusta.
Clase
Bases: object
Client de streaming para operaciones de actividad
Crear una suscripción de actividad en X
Crea una suscripción para un evento de actividad en X
body: Cuerpo de la solicitud
:returns: Datos de la respuesta
:rtype: CreateSubscriptionResponse
body.body
CreateSubscriptionRequest
El ID de la suscripción que se eliminará.
DeleteSubscriptionResponse - Datos de respuesta
Obtiene las suscripciones de actividad de X
Obtiene una lista de suscripciones activas para XAA
:returns: Datos de la respuesta
:rtype: GetSubscriptionsResponse
GetSubscriptionsResponse
Flujo de actividad (streaming)
Flujo de actividades de X
Este es un endpoint de streaming que emite datos en tiempo real a medida que están disponibles.
Cada elemento emitido representa un único dato del flujo.
La conexión se gestiona automáticamente con lógica de reintentos con backoff exponencial.
Si el flujo se desconecta, el SDK se volverá a conectar automáticamente sin intervención del cliente.
path.backfill_minutes
int or None
predeterminado:"None"
La cantidad de minutos de recuperación histórica solicitados.
path.start_time
str or None
predeterminado:"None"
YYYY-MM-DDTHH:mm:ssZ. La marca de tiempo UTC más antigua a partir de la cual se proporcionarán las etiquetas de las Publicaciones.
path.end_time
str or None
predeterminado:"None"
YYYY-MM-DDTHH:mm:ssZ. La marca de tiempo UTC más reciente a partir de la cual se proporcionarán las etiquetas de las Publicaciones.
StreamConfig opcional para personalizar el comportamiento de reintento, los tiempos de espera y los callbacks.
El ID de la suscripción que se va a actualizar.
body.body
UpdateSubscriptionRequest
Cuerpo de la solicitud
