Das Beispielprogramm 'Data Warehouse' ausführen
Sie können das Beispielprogramm 'Data Warehouse' starten, um folgende Verarbeitungsvorgänge auszuführen:
- Eine WebSphere MQ-Nachricht mit Nutzdaten im XML-Format lesen.
- Die gesamten Nutzdaten einer eingehenden Nachricht in ein BLOB konvertieren und
in eine Datenbank einfügen.
- Eine Bestätigungsnachricht formatieren.
- Eine WebSphere MQ-Bestätigungsnachricht für das Einfügen der Nachricht in der
Datenbank schreiben.
- Die Anzahl der Datensätze, die in der Datenbank eingefügt wurden, überprüfen.
Wie Sie den Inhalt der Datenbank des Beispielprogramms anzeigen, hängt vom installierten Datenbankprodukt ab. Verwenden Sie für DB2-Datenbanken die Tools, die von DB2 bereitgestellt werden, z. B. die DB2-Steuerzentrale. Wenn Sie kein Datenbankprodukt installiert haben, verwenden die Beispielprogramme die Datenbank 'Apache Derby'. Sie finden Anweisungen zur Anzeige von Daten in einer Derby-Datenbank unter Den Inhalt einer Derby-Datenbank anzeigen.
So führen Sie den Nachrichtenfluss 'WarehouseData' aus:
- Stellen Sie sicher, dass die Beispielnachrichtenflüsse und -nachrichtengruppen implementiert wurden.
Wenn Sie das Beispielprogramm importiert haben, wird unter Umständen eine Anzahl Fehler angezeigt, die sich auf die .msgflow-Dateien beziehen. Diese Fehler beziehen sich auf Datenbanken und beeinträchtigen die Ausführung des Beispielprogramms nicht.
- Klicken Sie in dem Nachrichtenflussprojekt, in das das Beispielprogramm importiert
wurde, doppelt auf 'Datawarehouse_input_message.enqueue'.
- Überprüfen Sie auf der Registerkarte 'Allgemein' die Werte für den WS-Managernamen und den WS-Namen. Wenn der Standardwarteschlangenmanager und die Standardnachrichtenbrokerkonfiguration verwendet werden, ist es nicht nötig, die Werte zu ändern. Stellen Sie jedoch sicher, dass das Feld "Port" den Wert 2414 enthält.
- Klicken sie auf In Warteschlange schreiben, um eine WebSphere MQ-Nachricht in die Eingabewarteschlange des WarehouseData-Nachrichtenflusses einzureihen.
- Starten Sie eine Instanz der Anwendung 'Dequeue':
- Klicken Sie in der Workbench-Funktionsleiste auf den Pfeil des Symbols
'Nachricht aus Warteschlange abrufen'
.
- Klicken Sie im Dropdown-Menü auf 'Nachricht
abrufen', um das Fenster 'Nachricht aus Warteschlange
entfernen' zu öffnen.
- Geben Sie die Namen des gewünschten WS-Managers und der Warteschlange ein.
Geben Sie als WS-Managernamen
'WBRK6_DEFAULT_QUEUE_MANAGER' und als Warteschlangennamen
'DATAWAREHOUSE_OUT_Q' ein, wenn Sie die
Standardkonfiguration verwenden möchten.
- Klicken Sie auf 'Aus Warteschlange lesen', um eine
Nachricht aus der Warteschlange zu lesen.
- Nachdem Sie das Fenster geschlossen haben, wird beim nächsten Klick auf den
Pfeil des Symbols 'Nachricht aus Warteschlange abrufen'
die zuvor erstellte Konfiguration zum Entfernen von Nachrichten aus Warteschlangen im
Dropdown-Menü aufgelistet. Klicken Sie im Menü auf diese Datei (oder wenn sie in der Dateiliste an erster Stelle steht, klicken Sie direkt auf das Symbol), um eine Nachricht aus der Warteschlange abzurufen.
- Optional: Während das Fenster Nachricht aus Warteschlange entfernen geöffnet ist, können Sie eine schreibgeschützte Nachricht in einer Datei in Ihrem Nachrichtenflussprojekt für die spätere Verwendung speichern. Klicken Sie auf 'Speichern unter', wählen Sie im
Fenster 'Nachricht speichern unter' das gewünschte
Nachrichtenflussprojekt aus, und geben Sie einen Namen für die Datei ein.
- Zeigen Sie den Inhalt der abgerufenen Nachricht an, und stellen Sie sicher, dass
eine Nachricht in der Datenbank gespeichert wurde. Notieren Sie die Uhrzeit, zu der
die Nachricht in der Datenbank gespeichert wurde. Diese Uhrzeit muss berücksichtigt werden,
wenn der Nachrichtenfluss 'VerifyDatabaseContents' ausführt wird.
- Starten Sie eine weitere Instanz der Anwendung 'Dequeue' (gleiche Vorgehensweise wie
zuvor in Schritt 5).
- Geben Sie als WS-Managernamen
'WBRK6_DEFAULT_QUEUE_MANAGER' und als Warteschlangennamen
'DATAWAREHOUSE_FAILURE_Q' ein, wenn Sie die
Standardkonfiguration verwenden möchten.
- Klicken Sie auf 'Aus Warteschlange lesen', um eine
Nachricht aus der Warteschlange zu lesen.
- Stellen Sie sicher, dass keine Nachricht abgerufen wurde. Diese Instanz der
Anwendung 'Dequeue' liest alle Fehlernachrichten für Einfügungsvorgänge in der Datenbank.
Es dürfen keine vorliegen.
Damit wurde der Nachrichtenfluss 'WarehouseData' erfolgreich ausgeführt.
Als nächster Schritt wird der Nachrichtenfluss 'VerifyDatabaseContents' ausgeführt, um
die Anzahl der Datensätze in der Datenbank zu ermitteln. Führen Sie folgende Schritte
aus:
- Klicken Sie in dem Nachrichtenflussprojekt, in das das Beispielprogramm importiert
wurde, doppelt auf
'Datawarehouse_verify_contents_input_message.enqueue'.
- Überprüfen Sie auf der Registerkarte 'Allgemein' die Werte für den WS-Managernamen und den WS-Namen. Wenn der Standardwarteschlangenmanager und die Standardnachrichtenbrokerkonfiguration verwendet werden, ist es nicht nötig, die Werte zu ändern.
- Geben Sie im Feld 'Nachrichtendaten' Werte für das Start- und Enddatum sowie die
Start- und Endzeit der Abfrage an. Der Zeitpunkt, zu dem die Nachricht durch Ausführen
des Nachrichtenflusses 'WarehouseData' in die Datenbank eingefügt wurde, muss innerhalb
dieses Zeitraums liegen. Der Zeitpunkt der Einfügung wird in der Nachricht dokumentiert,
die in die Warteschlange 'DATAWAREHOUSE_OUT_Q' eingereiht wird.
- Klicken Sie auf ''In Warteschlange schreiben'', um
eine WebSphere MQ-Nachricht in die Eingabewarteschlange des Nachrichtenflusses
'VerifyDatabaseContents' einzureihen.
- Starten Sie eine weitere Instanz der Anwendung 'Dequeue':
- Geben Sie als WS-Managernamen
'WBRK6_DEFAULT_QUEUE_MANAGER' und als Warteschlangennamen
'DATAWAREHOUSE_VERIFY_CONTENTS_OUT_Q' ein, wenn Sie die Standardkonfiguration
verwenden möchten.
- Klicken Sie auf 'Aus Warteschlange lesen', um eine
Nachricht aus der Warteschlange zu lesen.
- Stellen Sie sicher, dass die Anzahl der Datensätze in der Datenbank 1 beträgt.
- Führen Sie mit dem Nachrichtenfluss 'WarehouseData' mehrere weitere
Archivabfragen aus, und ermitteln Sie anschließend jedes Mal mit dem Nachrichtenfluss
'VerifyDatabaseContents' die Anzahl der Datensätze in der Datenbank, um sicherzustellen,
dass die Zählung der Datensätze korrekt fortgesetzt wird und mit der Anzahl der Abfragen
übereinstimmt. Je nachdem, welche Endzeit Sie zuvor in der Datei
'Datawarehouse_verify_contents_input_message.enqueue' angegeben haben,
muss dieser Wert möglicherweise aktualisiert werden.
Wenn Sie festgestellt haben, dass die Archivabfragen korrekt ausgeführt werden und
die Zählung der Datensätze in der Datenbank mit der Anzahl der Abfragen übereinstimmt,
wurde das Beispielprogramm 'Data Warehouse' damit erfolgreich ausgeführt.
Zurück zum Beginn des Beispielprogramms