Ultra Pipeline-Tasks werden zur Implementierung von Echtzeit-Webdienstintegrationen verwendet, bei denen die erwarteten Antwortzeiten im Bereich von wenigen Sekunden liegen müssen. In der ersten Serie von Beiträgen werde ich einige der wichtigsten Aspekte des Designs von Ultra Pipelines erläutern. In der zweiten Serie von Beiträgen werde ich mich auf die Überwachung dieser Aufgaben mit geringer Latenz konzentrieren.
Da die Ultra Pipelines-Tools analog zur Web-Service-Anfrage/Antwort-Architektur sind, sollten die folgenden Aspekte bei der Entwicklung von Ultra Pipelines in SnapLogic berücksichtigt werden.
Anzahl der Ansichten:
Ultra Pipelines können eine Kombination von Eingabe- und Ausgabeansichten unterstützen:
- Keine unverbundene Eingabesicht, keine unverbundene Ausgabesicht - Diese Kombination ist zwar selten, kann aber in einem Listener-Consumer-Konstrukt verwendet werden. Mit 0 Eingabe- und 0 Ausgabeansichten kann eine ständig laufende Ultra Pipeline verwendet werden, um die Dokumente von einem Endpunkt abzurufen und zu konsumieren, ohne dass eine Dokumentenzufuhr vom Feed-Master erforderlich ist.
Anwendungsfall: Entwerfen Sie einen Polling-Mechanismus für die Erfassung von Änderungen unter Verwendung des Idoc Listener Snap und aktualisieren Sie die Stammdatentabelle mit der Änderung. Da die Dokumente nicht vom Feed-Master empfangen werden, kann die Ausgabeansicht der Pipeline geschlossen werden.
- Eine unverbundene Eingabeansicht, eine oder mehrere unverbundene Ausgabeansichten - Das beliebteste Ultra-Pipeline-Design ist ein unkompliziertes Anfrage-Antwort-Konstrukt, das als Datenzugriffsschicht für Echtzeit-Webdienste verwendet werden kann. Bei diesem Entwurf wird eine Pipeline in einen ständig laufenden Auftrag umgewandelt; Dokumente werden der Pipeline über einen Feed-Master zugeführt, der eine Warteschlange von Dokumenten verwaltet, die von der Pipeline geparst werden, und die Antworten werden über den Feed-Master an den Aufrufer zurückgegeben.
Anwendungsfall 1: Entwurf einer Echtzeit-API für lokale Webdienste, die in der Cloud verwendet werden sollen. Die nachstehende Pipeline verwendet Informationen im eingehenden Dokument, um den Benutzer zu validieren, die Anforderung zu analysieren, einen lokalen Anwendungsserver aufzurufen und die Antwort zurückzugeben. Um eine robuste Verarbeitung zu gewährleisten, wurden dem Pipeline-Entwurf Funktionen zur Fehlerbehandlung und eine zusätzliche Ausgabeansicht hinzugefügt, die im Falle eines Fehlers Fehler zurückgibt.
Anwendungsfall 2: Ein Consumer-Endpunkt kann durch Verwendung des JMS Producer Snap definiert werden, um Dokumente aus dem Datenfeed zu konsumieren, indem eine Ultra Pipeline mit einer Eingabeansicht erstellt wird. Da die Feed-Master-Funktionalität auf einem Anfrage-Antwort-Framework basiert, muss der Feed-Master für jedes an eine Ultra Pipeline-Task-Instanz gesendete Anfragedokument eine Antwort erhalten, was bedeutet, dass mindestens eine Ausgabeansicht vorhanden sein sollte. Die unten gezeigte Ultra Pipeline liest Daten aus einem Eingabedokument, analysiert sie und schreibt sie in die JMS-Warteschlange, und eine Kopie der Antwort wird an den Aufrufer zurückgegeben.
Im nächsten Beitrag dieser Serie werde ich die Arten von Ansichten besprechen, die für Ultra Pipelines verfügbar sind. Anschließend werde ich die Fehler- und Ausnahmebehandlung sowie das Leistungsmanagement und die Überwachung behandeln.
Nächste Schritte: Sehen Sie sich unsere Video-Ressourcen für einige coole SnapLogic-Demos an und kontaktieren Sie uns, wenn Sie mehr über die SnapLogic Elastic Integration Platform erfahren möchten.
