Requete Flux de Donnees

Interroge un flux de donnees (stream) en temps reel. Permet de recuperer les derniers evenements d'un stream specifique.

Parametres

Parametre	Type	Requis	Variable	Description
entityId	valeur dynamique	Non	Oui	Identifiant de l'entite pour laquelle interroger les donnees temps reel.
timeRange	choix (1h, 6h, 24h, 7d, 30d)	Non	Non	Fenetre temporelle des donnees a recuperer. (Defaut: "24h")
metricNames	liste	Non	Non	Noms des metriques specifiques a filtrer. Vide pour toutes les metriques.
aggregation	choix (none, avg, sum, min, max, count)	Non	Non	Fonction d'agregation a appliquer sur les donnees. (Defaut: "none")
bucketSize	choix (1m, 5m, 15m, 1h, 6h, 1d)	Non	Non	Taille des intervalles pour l'agregation temporelle (utilise quand l'agregation n'est pas none). (Defaut: "1h")
limit	nombre	Non	Non	Nombre maximum de lignes a retourner. (Defaut: 1000)
includeStats	oui/non	Non	Non	Inclure les statistiques (min, max, moyenne, nombre) dans les resultats. (Defaut: false)
outputVariable	texte	Non	Non	Nom de la variable de sortie contenant les donnees de stream.

Les parametres marques Variable = Oui acceptent la syntaxe {{nomBloc.champ}}.

Sortie

Variable de sortie : streamResult

{
  "entityId": "...",
  "entityName": "...",
  "timeRange": {},
  "data": [],
  "freshness": {},
  "pagination": {}
}

Exemple

Recuperer les derniers evenements d'un stream.

Entree :

{"query": "type:order AND status:pending"}

Sortie :

{"events": [{"id": "evt-1", "type": "order", "data": {}}], "count": 1}

Astuce

Les streams sont alimentes par les connecteurs Live Data. Utilisez des filtres pour cibler les evenements pertinents.