Anwendungsfall-Szenario

Stellen Sie sich vor, Sie sind Dateningenieur in Ihrem Unternehmen und mit der Verwaltung von Fahrzeugdatensätzen in der Unternehmensdatenbank betraut. Laden Sie die vorhandenen Datensätze in den Speicher hoch. Fügen Sie der vorhandenen Tabelle einen neuen Datensatz hinzu. Nach der Überprüfung stellen Sie fest, dass der neu hinzugefügte Datensatz nicht geeignet ist, und beschließen, die Tabelle auf einen früheren Zustand zurückzusetzen.

Das folgende Video bietet eine visuelle Methode zum Erlernen der Konzepte und Aufgaben in dieser Dokumentation.

Vorgehensweise

Tabelle erstellen und Daten laden

Dieser Abschnitt führt Sie durch das Verfahren zum Erstellen einer Tabelle mit dem Namen " cars und zum Einlesen von Daten aus der Datei " cars.csv mithilfe der Spark-Engine.

1. Melden Sie sich an der watsonx.data-Konsole an.

2. Wählen Sie im Navigationsmenü die Option Datenmanager.

3. Klicken Sie auf Ingest Data und wählen Sie Local System. Weitere Informationen zum Ingest von Daten finden Sie unter Ingest von Daten aus dem lokalen System.

4. Klicken Sie auf die Registerkarte Daten durchsuchen. Aktualisieren Sie den Iceberg-Katalog, um das neue Schema und die Tabelle mit Daten anzuzeigen. Sie können die Registerkarten Tabellenspalten, Zeitreise, Datenprobe und DDL anzeigen.

5. Klicken Sie auf Zeitreise. Sie können sehen, dass die Tabelle " 406 Datensätze enthält.

Laden weiterer Datensätze in die Tabelle

Führen Sie mehrere Transaktionen durch (zwei Transaktionen), um die Tabelle " cars zu aktualisieren. In der ersten Transaktion nehmen Sie zwei weitere Fahrzeugdatensätze für das Modell " TESLA auf und in der zweiten Transaktion einen Datensatz für das Modell Kia Optima.

Um das zu tun:

1. Gehen Sie zum Arbeitsbereich Abfrage.

2. Wählen Sie den Presto.

3. Verwenden Sie die folgende SQL-Abfrage, um den ersten Satz von Daten in die Tabelle " cars einzufügen.

   INSERT INTO iceberg_data.automobiles.cars VALUES
   ('Tesla Model S', 102, 0, 0, 670, 4766, 3.1, 2023, 'USA'),
   ('Tesla Model 3', 134, 0, 0, 283, 3582, 5.8, 2023, 'USA');
   

4. Führen Sie die Abfrage aus. Die Daten werden addiert und der gesamte Datensatz lautet " 408.

5. Verwenden Sie die folgende SQL-Abfrage, um den zweiten Satz von Daten in die Tabelle " cars einzufügen.

   INSERT INTO iceberg_data.automobiles.cars VALUES
   ('Kia Optima', 27, 4, 2457, 185, 3200, 8.5, 2023, 'South Korea');
   

6. Führen Sie die Abfrage aus. Die Daten werden addiert und der gesamte Datensatz wird zu " 409.

7. Gehen Sie zum Datenmanager.

8. Wählen Sie die Tabelle cars. Wählen Sie im Bereich Fahrzeuge die Registerkarte Zeitreise. Sie können die Snapshot-Datensätze (mit SnapshotID) zu den Datentransaktionen anzeigen.

Abrufen von Tabellendatensätzen mit Hilfe von Tabellen-Snapshots.

Dieser Abschnitt des Tutorials führt Sie durch das Verfahren zum Abrufen von Tabellendatensätzen mit Hilfe von Tabellen-Snapshots. Sie führen Abfragen aus, um Daten zu Prüfungs- und Regulierungszwecken abzurufen.

1. Gehen Sie zum Arbeitsbereich Abfrage.

2. Führen Sie die folgende Abfrage aus, um die Snapshot-Datensätze abzurufen, die den drei durchgeführten Einfügetransaktionen entsprechen.

   SELECT * FROM iceberg_data.automobiles."cars$snapshots" ORDER BY committed_at;
   

   Die Ergebnismenge enthält drei Snapshot-Datensätze mit snapshot_id, Datum, Uhrzeit und Zeitzone. In diesem Lernprogramm werden die SnapshotID, Datum und die Uhrzeit für jede Transaktion als "code1", "code2", "code3", "code4", "code5" und "code6" bezeichnet: <Tran1Time>, ' <Tran1SnapshotID>, ' <Tran2Time>, ' <Tran2SnapshotID>, ' <Tran3Time> und ' <Tran3SnapshotID>.

   Sie können die Snapshot-Datensätze auch über Datenmanager > Tabelle " cars > Registerkarte " Zeitreise" einsehen.

3. Geben Sie die Snapshot-ID oder den Zeitpunkt in die folgenden Abfragen ein und führen Sie die Abfragen aus, um die Tabelleninformationen zu diesem Zeitpunkt abzurufen.

Rollback der Tabelle durchführen

{Mit watsonx.data von Snapshots können Sie eine Tabelle auf einen früheren Zeitpunkt zurücksetzen.

Um die Tabellendaten auf einen früheren Snapshot zurückzusetzen, gehen Sie wie folgt vor:

1. Gehen Sie zum Datenmanager.

2. Wählen Sie die Tabelle cars. Wählen Sie im Bereich Fahrzeuge die Registerkarte Zeitreise. Sie können die Snapshot-Datensätze (mit SnapshotID) anzeigen.

3. Klicken Sie auf das Überlaufmenü am Ende der Zeile für den zweiten Snapshot (der zweite Snapshot umfasst 408 Datensätze) und klicken Sie auf Zurück zum Snapshot. Ein Fenster zum Bestätigen des Rollbacks zum Snapshot wird geöffnet. Klicken Sie auf Rollback zum Snapshot. Der Daten-Rollback ist erfolgreich. Die Tabelle muss nun 408 Datensätze enthalten.

4. Um den Rollback zu überprüfen, führen Sie die folgende Abfrage aus, um festzustellen, ob die Zeilen, die der dritten Transaktion entsprechen, entfernt wurden.

   • Beispielabfrage, um zu überprüfen, dass die Tabelle den Datensatz "Kia Optima" nicht enthält.

   SELECT * FROM iceberg_data.automobiles.cars WHERE car IN ('Kia Optima', 'Tesla Model S', 'Tesla Model 3');
   

   Das Ergebnis listet nur die Datensätze für "Tesla Model S" und "Tesla Model 3" auf. Die Tabelle enthält nicht den Datensatz für "Kia Optima" (dritte Transaktion), da die Tabelle jetzt auf den zweiten Snapshot zurückgesetzt wurde.

   • Beispielabfrage zum Zählen der Gesamtzahl der Zeilen in der Tabelle.

   SELECT COUNT(*) FROM iceberg_data.automobiles.cars;
   

   Sie müssen eine Anzahl von 408 Zeilen sehen, die mit der Anzahl übereinstimmt, als Sie die zweite Transaktion in der Tabelle durchgeführt haben. Die Tabelle befindet sich wieder in ihrem vorherigen Zustand (zweite Transaktion).