Ce module fournit un client pour interagir avec les endpoints d’activité de la X API.
Les opérations de streaming en temps réel renvoient des générateurs qui produisent les données au fur et à mesure de leur arrivée.
Les connexions de streaming sont automatiquement gérées avec une logique de reprise et un backoff exponentiel pour une gestion robuste.
Classe
Bases : object
Client de streaming pour les opérations d’activité
Créer un abonnement d’activité X
Crée un abonnement à un événement d’activité X
body: Corps de la requête
:returns: Données de la réponse
:rtype: CreateSubscriptionResponse
body.body
CreateSubscriptionRequest
L’identifiant de l’abonnement à supprimer.
Renvoie
DeleteSubscriptionResponse - Données de la réponse
Récupère les abonnements à l’activité X
Renvoie la liste des abonnements actifs pour XAA
:returns: Données de la réponse
:rtype: GetSubscriptionsResponse
GetSubscriptionsResponse
Flux d’activité (streaming)
Flux d’activités X
Il s’agit d’un endpoint de streaming qui renvoie des données en temps réel au fur et à mesure qu’elles deviennent disponibles.
Chaque élément émis représente un point de données unique provenant du flux.
La connexion est gérée automatiquement à l’aide d’une stratégie de nouvelle tentative avec backoff exponentiel.
Si le flux se déconnecte, le SDK se reconnectera automatiquement sans intervention du client.
Le nombre de minutes de rattrapage demandées.
YYYY-MM-DDTHH:mm:ssZ. L’horodatage UTC le plus ancien à partir duquel les libellés de Publication seront fournis.
YYYY-MM-DDTHH:mm:ssZ. L’horodatage UTC le plus récent à partir duquel les libellés de Publication seront fournis.
StreamConfig facultatif pour personnaliser le comportement de réessai, les délais d’expiration et les callbacks.
L’identifiant de l’abonnement à mettre à jour.
body.body
UpdateSubscriptionRequest
Corps de la requête
