Der End-user des Fachbereichs erstellt in der AV-Oberfläche ein Warenlager und aktualisiert ein anderes. Ein Talend DI-Job lädt regelmäßig Daten aus der AV Datenbank zur Beladung eines DWH in Google BigQuery. Wenn die Übertragung durch Talend erfolgreich beendet ist, wird ein Log-Eintrag in AWS CloudWatch geschrieben.
CloudWatch (AWS Service) bietet ein Alarmsystem. Dieses kann ausgelöst werden, wenn die vordefinierte Log-Nachricht von Talend auftritt. In diesem Fall sendet der Alarm eine Nachricht an ein AWS SNS-Topic, was diese Nachricht published.
Eine SQS-Queue, die beim SNS-Topic als Subscriber registriert ist, empfängt die Nachricht und startet damit eine Lambda Funktion.
Die Lambda Funktion lädt Daten aus dem Stammdatenmanagementsystem und Daten aus BigQuery, vergleicht diese gegeneinander und entscheidet am Ende, dass ein neues Warenlager erstellt und ein altes im Stammdatenmanagementsystem aktualisiert werden muss.
Dafür werden zwei Nachrichten erzeugt und über eine weitere SQS-Queue an eine zweite Lambda Funktion gesendet. Diese kümmert sich um Übertragung der Daten an die Stammdatenmanagementsystem-API.
Mehrere weitere Schnittstellen sind nach dem gleichen Konzept implementiert worden.
