to
Distribution des données en streaming vers tous les endpoints cibles. Par défaut, si aucune option de distribution n'est paramétrée sur l'URL une copie de chaque message est streamée vers chaque endpoint cible (mode broadcasting).
Patterns
distribution: selon les options de l'URL de distribution (load-balancing, broadcasting, routage, etc.) flux asynchrone: streaming asynchrone des données vers des nodes distants
Usage
public LinkStream to(String label, String url, [(LinkStream stream, Event event) -> { <lambda> }],..) throws StreamDefinitionException;
@param label: libellé de la lambda
@param url: URL de distribution de la lambda
@param stream: instance du stream
@param event: évenement ou message reçu par la lambda
@function lambda: implémentation de la fonction lambda. Doit retouner un objet sérialisable comme input pour les traitements suivants de l'algorithme. Si la lambda retourne null alors les clauses suivantes ne sont pas exécutées.
Lorsque plusieurs fonctions lambda sont définies, elles sont exécutées séquentiellement sur les mêmes données reçues en entrée et tous les résultats sont transmis vers la clause suivante de l'algorithme (à la façon d'une fonction "JOIN")
caution
Si la lambda retourn un itérable (implémente l'interface java.lang.Iterable) alors chaque élément est transmis en streaming (au fil de l'eau); dans le cas contraire, l'objet entier est transmis vers la clause suivante.
Exemple de code
@Override
public void build() throws Exception {
// Flux asynchrone (Publish/subscribe): Collecte des données de production
make("power data collect")
.from("collect", "www.mddynamics.fr/app/data", (stream, data) -> {
// transmet chaque métrique à distribuer sur le réseau de consolidation
return data.resource().list("metrics");
})
.to("metrics", "www.mddynamics.fr/app/consolidation?mddynamics.id=/name", (stream, metric) -> ...);
}