Les tâches Ultra Pipeline sont utilisées pour mettre en œuvre des intégrations de services web en temps réel qui nécessitent des temps de réponse proches de quelques sous secondes. Dans la première série de billets, je décrirai certains des aspects clés de la conception des Ultra Pipelines. Dans la deuxième série de billets, je me concentrerai sur la surveillance de ces tâches à faible latence.
Les outils Ultra Pipelines étant analogues à l'architecture requête/réponse des services web, les aspects suivants doivent être pris en compte lors de la conception des Ultra Pipelines dans SnapLogic.
Nombre de vues :
Ultra Pipelines peut prendre en charge une combinaison de vues d'entrée et de sortie :
- Pas de vue d'entrée non connectée, pas de vue de sortie non connectée - Bien qu'il s'agisse d'une combinaison rare, cette conception pourrait être utilisée dans une construction de type auditeur-consommateur. Avec 0 vue d'entrée et 0 vue de sortie, un Ultra Pipeline toujours en cours d'exécution peut être utilisé pour interroger et consommer les documents à partir d'un point final, sans avoir besoin d'une alimentation en documents à partir d'un maître d'alimentation.
Cas d'utilisation : Concevoir un mécanisme d'interrogation pour la capture des modifications à l'aide de Idoc Listener Snap et mettre à jour la table des données de base avec les modifications. Comme les documents ne sont pas reçus du maître d'alimentation, la vue de sortie du pipeline peut être fermée.
- Une vue d'entrée non connectée, une ou plusieurs vues de sortie non connectées - La conception la plus populaire d'Ultra Pipeline est une construction demande-réponse simple qui peut être utilisée comme couche d'accès aux données pour les services web en temps réel. Cette conception transforme un pipeline en un travail toujours en cours d'exécution ; les documents sont fournis au pipeline par l'intermédiaire d'un maître d'alimentation qui maintient une file d'attente de documents, analysés par le pipeline et les réponses sont renvoyées à l'appelant par l'intermédiaire du maître d'alimentation.
Cas d'utilisation 1 : Concevoir une API en temps réel pour les services web sur site à utiliser dans cloud. Le pipeline ci-dessous utilise les informations contenues dans le document entrant pour valider l'utilisateur, analyser la demande, appeler un serveur d'application sur site et renvoyer la réponse. Pour un traitement robuste, une capacité de gestion des erreurs et une vue de sortie supplémentaire pour renvoyer les erreurs en cas d'échec ont été ajoutées à la conception du pipeline.
Cas d'utilisation 2 : Un point de terminaison consommateur peut être défini en utilisant le JMS Producer Snap pour consommer des documents à partir du flux de données, en créant un Ultra Pipeline avec une vue d'entrée. La fonctionnalité du maître de flux étant basée sur un cadre demande-réponse, pour chaque document de demande envoyé à une instance de tâche Ultra Pipeline, le maître de flux doit recevoir une réponse, ce qui implique qu'au moins une vue de sortie doit être présente. L'Ultra Pipeline illustré ci-dessous lit les données d'un document d'entrée, les analyse et les écrit dans la file d'attente JMS, et une copie de la réponse est renvoyée à l'appelant.
Dans le prochain article de cette série, je passerai en revue les types de vues disponibles pour Ultra Pipelines. J'aborderai ensuite la gestion des erreurs et des exceptions, ainsi que la gestion et la surveillance des performances.
Prochaines étapes : Consultez nos ressources vidéo pour des démonstrations SnapLogic intéressantes et n'hésitez pas à nous contacter si vous souhaitez en savoir plus sur SnapLogic Elastic Integration Platform.
