Caso práctico

Imagina que eres ingeniero de datos en tu empresa y que tienes la tarea de gestionar los registros de coches en la base de datos de la empresa. Cargue los registros de datos existentes en el almacén. Añade un nuevo conjunto de datos a la tabla existente. Tras la revisión, ve que el nuevo conjunto de datos añadido no es apropiado y decide revertir la tabla a un estado anterior.

El siguiente vídeo proporciona un método visual para aprender los conceptos y tareas de esta documentación.

Procedimiento

Creación de tablas y carga de datos

Esta sección le guiará a través del procedimiento para crear una tabla llamada " cars " e ingerir los datos presentes en el archivo " cars.csv " utilizando el motor Spark.

1. Inicie una sesión en la consola de watsonx.data.

2. En el menú de navegación, seleccione Gestor de datos.

3. Haga clic en Ingest Data y seleccione Local System. Para obtener más información sobre cómo ingerir datos, consulte Ingesta de datos desde el sistema local.

4. Haga clic en la pestaña Examinar datos. Actualice el catálogo Iceberg para ver el nuevo esquema y la tabla con datos. Puede ver las pestañas Columnas de tabla, Recorrido temporal, Muestra de datos y DDL.

5. Haga clic en Viajar en el tiempo. Puede ver que la tabla tiene registros ' 406.

Cargar más registros en la tabla

Realice varias transacciones (dos transacciones) para actualizar la tabla ' cars '. En la primera transacción, ingiere otros dos registros de coches para el modelo " TESLA y en la segunda transacción, ingiere un registro para el modelo Kia Optima.

Para ello:

1. Vaya al espacio de trabajo Consulta.

2. Seleccione el motor Presto.

3. Utilice la siguiente consulta SQL para insertar el primer conjunto de datos en la tabla ' cars.

   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. Ejecute la consulta. Los datos se suman y el registro total es ' 408.

5. Utilice la siguiente consulta SQL para insertar el segundo conjunto de datos en la tabla " cars ".

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

6. Ejecute la consulta. Los datos se suman y el registro total pasa a ser ' 409.

7. Vaya al Gestor de datos.

8. Seleccione la tabla cars. En la sección Coches, seleccione la pestaña Viaje en el tiempo. Puede ver los registros de instantáneas (con SnapshotID) correspondientes a las transacciones de datos.

Recuperación de registros de tablas mediante el uso de instantáneas de tablas.

Esta sección del tutorial le guía a través del procedimiento para recuperar registros de tablas utilizando instantáneas de tablas. Se ejecutan consultas para recuperar datos con fines de auditoría y normativos.

1. Vaya al espacio de trabajo Consulta.

2. Ejecute la siguiente consulta para recuperar los registros instantáneos correspondientes a las tres transacciones de inserción realizadas.

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

   El conjunto de resultados incluye tres registros de instantáneas con snapshot_id, fecha, hora y zona horaria. En este tutorial, el SnapshotID, fecha y la hora de cada transacción se denominan: <Tran1Time>, ' <Tran1SnapshotID>, ' <Tran2Time>, ' <Tran2SnapshotID>, ' <Tran3Time>, y ' <Tran3SnapshotID>.

   También puede ver los registros de instantáneas desde Gestor de datos > tabla ' cars > pestaña Recorrido temporal.

3. Proporcione el ID o la hora de la instantánea en las siguientes consultas y ejecute las consultas para recuperar la información de la tabla en ese punto.

Realización del rollback de la tabla

watsonx.data permite revertir una tabla a un punto anterior en el tiempo mediante el uso de instantáneas.

Para revertir los datos de la tabla a una instantánea anterior, haga lo siguiente:

1. Vaya al Gestor de datos.

2. Seleccione la tabla cars. En la sección Coches, seleccione la pestaña Viaje en el tiempo. Puede ver los registros de instantáneas (con SnapshotID).

3. Haga clic en el menú de desbordamiento al final de la fila de la segunda instantánea (la segunda instantánea incluye 408 registros) y haga clic en Retroceder a instantánea. Se abre la ventana Confirmar reversión a instantánea. Haga clic en Retroceder a la instantánea. La reversión de datos se ha realizado correctamente. Ahora, la tabla debe tener 408 registros.

4. Para verificar la reversión, ejecute la siguiente consulta para comprobar si se eliminan las filas correspondientes a la tercera transacción.

   • Ejemplo de consulta para comprobar que la tabla no incluye el registro "Kia Optima".

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

   El resultado sólo muestra los registros de datos correspondientes a "Tesla Model S" y "Tesla Model 3". La tabla no tiene el registro correspondiente a "Kia Optima" (tercera transacción), ya que la tabla se ha revertido a la segunda instantánea.

   • Ejemplo de consulta para contar el número total de filas de la tabla.

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

   Debe ver un recuento de 408 filas, que coincide con el recuento cuando realizó la segunda transacción en la tabla. La tabla vuelve a su estado anterior (segunda transacción).