Se usó la API de Cloud Translation para traducir esta página.

Usar las API de DataStream

DataStream

Descripción general

Para las empresas con muchas fuentes de datos aisladas, el acceso a los datos empresariales en toda la organización, especialmente en tiempo real, puede ser difícil. Esto da como resultado un mundo de acceso limitado y lento a los datos, lo que impide que la organización pueda hacer una introspección.

Datastream proporciona acceso casi en tiempo real a los datos modificados desde una variedad de fuentes de datos locales y basadas en la nube para crear acceso a los datos de la organización. Datastream proporciona una experiencia de configuración sencilla y una API de consumo unificada que democratiza el acceso de la organización a los datos empresariales más recientes disponibles en toda la organización, lo que potencia situaciones integradas casi en tiempo real.

Una de esas situaciones es transferir datos de una base de datos de origen a un servicio de almacenamiento basado en la nube o una cola de mensajería y transformarlos en un formato legible para otras aplicaciones y servicios que se comunican con este servicio de almacenamiento o cola de mensajería.

En este instructivo, aprenderás a usar Datastream para transferir esquemas, tablas y datos de una base de datos de origen de Oracle a una carpeta de un bucket de Cloud Storage. Cloud Storage es un servicio web para almacenar datos y acceder a ellos en Google Cloud. El servicio combina el rendimiento y la escalabilidad de la nube de Google con funciones avanzadas de seguridad y uso compartido.

Como parte de la transferencia de esta información a una carpeta en el bucket de Cloud Storage de destino, Datastream la traduce a Avro. Avro se define mediante un esquema escrito en notación de objetos de JavaScript (JSON). Esta traducción te permite leer datos de diferentes fuentes de datos de manera uniforme.

Objetivos

En este instructivo, aprenderás a realizar lo siguiente:

Configurar variables de entorno Usarás estas variables cuando realices solicitudes a Datastream para crear y administrar perfiles de conexión y una transmisión.
Crear y administrar perfiles de conexión para una base de datos de origen y un bucket de destino en Cloud Storage Cuando creas estos perfiles de conexión, estás creando registros que contienen información sobre la base de datos de origen y el bucket de Cloud Storage de destino. La transmisión en Datastream usa la información de los perfiles de conexión para transferir datos de la base de datos de origen a una carpeta en el bucket de destino.
Crea y administra una transmisión. Datastream usa esta transmisión para transferir datos, esquemas y tablas de la base de datos de origen a una carpeta en el bucket de destino.
Verifica que Datastream transfiera los datos y las tablas asociadas con un esquema de la base de datos de Oracle de origen a una carpeta en el bucket de destino y traduzca estos datos al formato de archivo Avro.
Limpia los recursos que creaste en Datastream para que no consuman tu cuota y no se facturen en el futuro.

Costos

En este documento, usarás los siguientes componentes facturables de Google Cloud:

Cloud Storage

Para generar una estimación de costos en función del uso previsto, usa la calculadora de precios. Es posible que los usuarios nuevos de Google Cloud califiquen para obtener una prueba gratuita.

Antes de comenzar

Sign in to your Google Cloud account. If you're new to Google Cloud, create an account to evaluate how our products perform in real-world scenarios. New customers also get $300 in free credits to run, test, and deploy workloads.

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Go to project selector

Make sure that billing is enabled for your Google Cloud project.

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Go to project selector

Make sure that billing is enabled for your Google Cloud project.

Habilita la API de Datastream.
Habilitación de la API
Asegúrate de tener asignado el rol de administrador de Datastream a tu cuenta de usuario.
Ir a la página IAM
Asegúrate de tener una base de datos de origen a la que Datastream pueda acceder. En este instructivo, se usa una base de datos de Oracle como fuente.
Configura tu base de datos de origen para permitir conexiones entrantes desde direcciones IP públicas de Datastream. Consulta las listas de entidades permitidas y las regiones de IP para acceder a las ubicaciones de todas las regiones de Datastream y sus direcciones IP públicas asociadas.
Asegúrate de haber configurado un bucket de Cloud Storage de destino al que pueda acceder Datastream mediante la lista de IP permitidas, el túnel SSH de reenvío o el método de conectividad de red de intercambio de tráfico entre VPC.
Asegúrate de tener datos, tablas y esquemas en la base de datos de origen que Datastream pueda transferir a una carpeta en el bucket de Cloud Storage de destino.
Descarga Cloud Shell y, luego, instálalo. Esta aplicación cliente te proporciona acceso de línea de comandos a tus recursos en la nube (incluido Datastream).
Instala y configura la utilidad jq. Esta utilidad es un procesador JSON ligero y flexible de línea de comandos. Usarás este procesador para mostrar comandos cURL complejos en texto fácil de leer.

Configura variables de entorno

En este procedimiento, configurarás las siguientes variables:

$PROJECT: Esta variable está asociada a tu proyecto de Google Cloud. Todos los recursos de Google Cloud que asignas y usas deben pertenecer a un proyecto.
$TOKEN: Esta variable está asociada con un token de acceso. El token de acceso proporciona una sesión que Cloud Shell usa para realizar tareas en Datastream con las APIs de REST.

Inicia tu aplicación de Cloud Shell.
Después de autenticarte en tu aplicación con tu Cuenta de Google, ingresa gcloud auth login.
En el mensaje Do you want to continue (Y/n)?, ingresa Y.
Abre un navegador web y copia la URL en el navegador.
Realiza la autenticación en el SDK de Google Cloud con tu Cuenta de Google. Aparecerá un código en la página de acceso. Este código es tu token de acceso.
Copia el token de acceso, pégalo en el parámetro Enter verification code: en tu aplicación de Cloud Shell y presiona Enter.
Cuando se te solicite, ingresa PROJECT="YOUR_PROJECT_NAME" para establecer tu proyecto de Google Cloud como la variable de entorno $PROJECT.
Cuando se te solicite, ingresa gcloud config set project YOUR_PROJECT_NAME para establecer tu proyecto de Google Cloud como el proyecto en el que deseas trabajar.

El símbolo del sistema se actualiza para reflejar el proyecto activo y respeta este formato: USERNAME@cloudshell:~ (YOUR_PROJECT_NAME)$.
Cuando se te solicite, ingresa TOKEN=$(gcloud auth print-access-token) para recuperar el token de acceso y almacenarlo como una variable.
Cuando se te solicite, ingresa los siguientes comandos para asegurarte de que las variables $PROJECT y $TOKEN estén configuradas de forma correcta:
- echo $PROJECT
- echo $TOKEN

Ahora que ya configuraste las variables, puedes realizar solicitudes a Datastream para crear y administrar perfiles de conexión y una transmisión.

Crea y administra perfiles de conexión

En esta sección, crearás y administrarás los perfiles de conexión de una base de datos de Oracle de origen y un bucket de Cloud Storage de destino.

Cuando creas estos perfiles de conexión, creas registros que contienen información sobre la base de datos de origen y el bucket de Cloud Storage de destino. Datastream usa la información de los perfiles de conexión para transferir datos de la base de datos de origen a una carpeta en el bucket de destino.

La creación y administración de perfiles de conexión incluye lo siguiente:

Crea perfiles de conexión para una base de datos de Oracle de origen y un bucket de destino en Cloud Storage
Cómo recuperar información sobre un perfil de conexión
Modificar un perfil de conexión
Realiza una llamada a la API de Descubre en el perfil de conexión de origen de Oracle. Esta llamada te permite ver dentro de la base de datos para ver los objetos asociados con ella. Estos objetos incluyen los esquemas y las tablas que contienen los datos de la base de datos. Cuando usas Datastream para configurar una transmisión, es posible que no quieras extraer todos los objetos de la base de datos, sino un subconjunto de ellos (por ejemplo, solo ciertas tablas y esquemas de la base de datos). Usa la API de descubrimiento para encontrar (o descubrir) el subconjunto de objetos de base de datos que quieres extraer.

Crea perfiles de conexión

En este procedimiento, crearás dos perfiles de conexión: uno a una base de datos de Oracle de origen y otro a un bucket de destino en Cloud Storage.

Crea un perfil de conexión a una base de datos de Oracle de origen. En la solicitud, ingresa el siguiente comando:

ORACLE="{\"displayName\":\"DISPLAY_NAME\",\"oracle_profile\":{\"hostname\":\"HOSTNAME\",\"username\":\"USERNAME\",\"password\":\"PASSWORD\",\"database_service\":\"DATABASE_SERVICE\",\"port\":"PORT_NUMBER\"},\"no_connectivity\":{}}"

Usa la siguiente tabla para comprender los valores de los parámetros para la base de datos Oracle de origen:

Valor del parámetro	Reemplazar por
`DISPLAY_NAME`	El nombre visible del perfil de conexión con la base de datos de origen.
`HOSTNAME`	El nombre de host del servidor de la base de datos de origen.
`USERNAME`	Es el nombre de usuario de la cuenta de la base de datos de origen (por ejemplo, `ROOT`).
`PASSWORD`	Es la contraseña de la cuenta para la base de datos de origen.
`DATABASE_SERVICE`	Es el servicio que garantiza que la base de datos de origen esté protegida y supervisada. Para las bases de datos de Oracle, el servicio de base de datos suele ser `ORCL`.
`PORT_NUMBER`	Es el número de puerto reservado para la base de datos de origen. En el caso de una base de datos de Oracle, el número de puerto suele ser 1521.

Nota: En este instructivo, se usa el método de conectividad de red no_connectivity porque configuraste tu base de datos de Oracle de origen para permitir conexiones entrantes desde direcciones IP públicas de Datastream. Además de no_connectivity, hay dos métodos de conectividad de red admitidos que puedes usar para establecer una conexión entre la base de datos de origen y la carpeta en el bucket de Cloud Storage de destino.

Lista de IP permitidas: Este método funciona configurando la base de datos de origen para que acepte conexiones desde la dirección IP pública de Datastream. Si usas la lista de IP permitidas como método de conectividad de red, reemplaza no_connectivity por StaticIpConnectivity.
Reenviar túnel SSH: Este método establece la conectividad de la base de datos de origen a Datastream a través de un túnel SSH seguro. Si usas el túnel SSH de reenvío como método de conectividad de red, reemplaza no_connectivity por forwardSshTunnelConnectivity. Para obtener información sobre los valores que puedes establecer para este método de conectividad de red, consulta la documentación de referencia.

En el mensaje, ingresa el comando echo $ORACLE | jq para ver el perfil de conexión de origen que creaste en texto fácil de leer.

{
  "displayName": "DISPLAY_NAME",
  "oracle_profile": {
    "hostname": "HOSTNAME",
    "username": "USERNAME",
    "password": "PASSWORD",
    "database_service": "DATABASE_SERVICE",
    "port": PORT_NUMBER
   },
  "no_connectivity": {}
}

Envía el perfil de conexión de Oracle para que se pueda crear. En el mensaje, ingresa el siguiente comando:

curl -X POST -d $ORACLE -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles?connection_profile_id=SOURCE_CONNECTION_PROFILE_ID

Usa la siguiente tabla para comprender los valores de los parámetros para este comando:

Valor del parámetro	Reemplazar por
`DATASTREAM_API_VERSION`	La versión actual de la API de Datastream (por ejemplo, `v1`).
`PROJECT_PATH`	La ruta de acceso completa de tu proyecto de Google Cloud (por ejemplo, `projects/$PROJECT/locations/YOUR_PROJECT_LOCATION`).
`SOURCE_CONNECTION_PROFILE_ID`	Es el identificador único reservado para este perfil de conexión (por ejemplo, `cp-1`).

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-SOURCE_CONNECTION_PROFILE_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "datastream.googleapis.com/DATASREAM_VERSION/PROJECT_PATH/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "verb": "create",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Crea un perfil de conexión a un bucket de destino en Cloud Storage. En el mensaje, ingresa el siguiente comando:

GOOGLECLOUDSTORAGE="{\"displayName\":\"DISPLAY_NAME\",\"gcs_profile\":{\"bucket_name\":\"BUCKET_NAME\",\"root_path\":\"/FOLDER_PATH\"},\"no_connectivity\":{}}"

Usa la siguiente tabla para comprender los valores de los parámetros para el bucket de destino:

Valor del parámetro	Reemplazar por
`DISPLAY_NAME`	El nombre visible del perfil de conexión con el bucket de destino.
`BUCKET_NAME`	Es el nombre del bucket de destino.
`FOLDER_PATH`	Es la carpeta del bucket de destino a la que Datastream transferirá los datos de la base de datos de origen (por ejemplo, `/root/path`).

En el mensaje, ingresa el comando echo $GOOGLECLOUDSTORAGE | jq para ver el perfil de conexión de destino que creaste en texto fácil de leer.

{
  "displayName": "DISPLAY_NAME",
  "gcs_profile": {
    "bucket_name": "BUCKET_NAME",
    "root_path": "/FOLDER_PATH"
  },
  "no_connectivity": {}
}

Envía el perfil de conexión de Cloud Storage para que se pueda crear. En la solicitud, ingresa el siguiente comando:
```
curl -X POST -d $GOOGLECLOUDSTORAGE -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles?connection_profile_id=DESTINATION_CONNECTION_PROFILE_ID
```
Importante: Para el valor del parámetro DESTINATION_CONNECTION_PROFILE_ID, asegúrate de especificar un identificador diferente para este perfil de conexión (por ejemplo, cp-2).

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-DESTINATION_CONNECTION_PROFILE_OPERATION_ID",
  "metadata": {
    "@type": "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "datastream.googleapis.com/DATASTREAM_VERSION/PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
    "verb": "create",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Confirma que se hayan creado ambos perfiles de conexión. En la solicitud, ingresa el siguiente comando:
```
curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles
```
Nota: La cadena connectionProfiles al final del comando indica que deseas recuperar información sobre ambos perfiles de conexión para confirmar que se crearon.

Verifica que se muestren dos resultados para los perfiles de conexión de origen y destino.

{
  "connectionProfiles": [
    {
      "name": "PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
      "createTime": "DATE_AND_TIME_STAMP",
      "updateTime": "DATE_AND_TIME_STAMP",
      "displayName": "DISPLAY_NAME",
      "gcsProfile": {
        "bucketName": "BUCKET_NAME",
        "rootPath": "FOLDER_PATH"
      },
      "noConnectivity": {}
    },
   {
    "name": "PROJECT_PATH/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "createTime": "DATE_AND_TIME_STAMP",
    "updateTime": "DATE_AND_TIME_STAMP",
    "displayName": "DISPLAY_NAME",
    "oracleProfile": {
      "hostname": "HOSTNAME",
      "port": PORT_NUMBER,
      "username": "USERNAME",
      "databaseService": "DATABASE_SERVICE"
    },
    "noConnectivity": {}
    }
  ]
}

Administrar perfiles de conexión

En este procedimiento, administras los perfiles de conexión que creaste para una base de datos de Oracle de origen y un bucket de destino en Cloud Storage. Incluye lo siguiente:

Recupera información sobre el perfil de conexión de destino de Cloud Storage
Modificar este perfil de conexión En este instructivo, cambiarás la carpeta del bucket de Cloud Storage de destino a /root/tutorial. Datastream transfiere datos de la base de datos de origen a esta carpeta.
Realiza una llamada a la API de Descubre en el perfil de conexión de origen de Oracle

Recupera información sobre el perfil de conexión de destino de Cloud Storage. En la solicitud, ingresa el siguiente comando:

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID

Verifica que veas información sobre este perfil de conexión.

{
  "name": "PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
  "createTime": "DATE_AND_TIME_STAMP",
  "updateTime": "DATE_AND_TIME_STAMP",
  "displayName": "DISPLAY_NAME",
  "gcsProfile": {
    "bucketName": "BUCKET_NAME",
    "rootPath": "FOLDER_PATH"
  },
  "noConnectivity": {}
}

Modifica este perfil de conexión. Para ello, primero, establece una variable UPDATE. Esta variable contiene los valores del perfil de conexión que quieres cambiar. En este instructivo, cambiarás la carpeta del bucket de destino a /root/tutorial.

Para configurar la variable, ingresa el siguiente comando en la solicitud:
```
UPDATE="{\"gcsProfile\":{\"rootPath\":\"/root/tutorial\"}}"
```

En la solicitud, ingresa el siguiente comando:

curl -X PATCH -d $UPDATE -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID?update_mask=gcsProfile.rootPath

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-DESTINATION_CONNECTION_PROFILE_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
    "verb": "update",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Confirma que se modificó el perfil de conexión. En la solicitud, ingresa el siguiente comando:

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID

Verifica que la carpeta del bucket de destino del perfil de conexión de Cloud Storage ahora sea /root/tutorial.

{
  "name": "PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
  "createTime": "DATE_AND_TIME_STAMP",
  "updateTime": "DATE_AND_TIME_STAMP",
  "displayName": "DISPLAY_NAME",
  "gcsProfile": {
    "bucketName": "BUCKET_NAME",
    "rootPath": "/root/tutorial"
  },
  "noConnectivity": {}
}

Usa la API de descubrimiento de Datastream para descubrir los esquemas y las tablas de la base de datos de origen de Oracle. Datastream proporciona acceso a esta base de datos a través del perfil de conexión de origen.
1. Descubre los esquemas de la base de datos de Oracle. En la solicitud, ingresa el siguiente comando:
```
curl -X POST -d "{\"connection_profile_name\":\"projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID\", \"oracle_rdbms\":{\"oracleSchemas\":[{\"schema\":\"ROOT\"}]}}" -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles:discover
```
  Nota: Reemplaza el marcador de posición YOUR_PROJECT_NUMBER por el número de identificación de 10 dígitos de tu proyecto de Google Cloud. La parte del código connectionProfiles:discover indica que deseas usar el perfil de conexión de la base de datos de origen de Oracle para descubrir todos los esquemas de esa base de datos.
2. Verifica que Datastream recupere todos los esquemas de tu base de datos.
3. Recupera las tablas de un esquema en tu base de datos. En este instructivo, usarás la API de Descubre para recuperar las tablas del esquema ROOT. Sin embargo, puedes descubrir las tablas de cualquier esquema en tu base de datos.
  
  En la solicitud, ingresa el siguiente comando:
```
curl -X POST -d "{\"connection_profile_name\":\"projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID\", \"oracle_rdbms\":{\"oracleSchemas\":[{\"schema\":\"ROOT\"}]}}" -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles:discover
```
1. Verifica que Datastream recupere todas las tablas del esquema que especificaste (para este instructivo, el esquema ROOT).

Ahora que creaste y administraste perfiles de conexión para una base de datos de origen de Oracle y un bucket de destino en Cloud Storage, estás listo para crear y administrar una transmisión en Datastream.

Crea y administra una transmisión

En esta sección, crearás y administrarás una transmisión. Datastream usa esta transmisión para transferir datos, esquemas y tablas de la base de datos de origen a una carpeta en el bucket de Cloud Storage de destino.

Crear y administrar una transmisión incluye lo siguiente:

Validar una transmisión para garantizar que se ejecute correctamente y que se aprueben todas las verificaciones de validación Estas verificaciones incluyen lo siguiente:
- Si la fuente está configurada correctamente para permitir que Datastream transmita datos desde ella.
- Si la transmisión puede conectarse tanto al origen como al destino.
- La configuración de extremo a extremo de la transmisión.
Crear la transmisión con las siguientes listas:
- Una lista de entidades permitidas En esta lista, se especifican las tablas y los esquemas de la base de datos de origen que Datastream puede transferir a una carpeta del bucket de destino en Cloud Storage. En este instructivo, esta es la carpeta /root/tutorial.
- Una lista de rechazos En esta lista, se especifican las tablas y los esquemas de la base de datos de origen que Datastream no puede transferir a la carpeta del bucket de destino de Cloud Storage.
Recuperar información sobre la transmisión
Modificar la transmisión
Iniciar la transmisión para que Datastream pueda transferir datos, esquemas y tablas desde la base de datos de origen hacia una carpeta en el bucket de Cloud Storage de destino.
Usar la API de recuperación de errores para detectar cualquier error asociado con la transmisión
Pausar la transmisión. Cuando se pausa una transmisión, Datastream no extraerá datos nuevos de la base de datos de origen al bucket de destino.
Reanudar la transmisión en pausa para que Datastream pueda continuar transfiriendo datos al bucket de destino.

Crea una transmisión

En este procedimiento, crearás una transmisión desde la base de datos de Oracle de origen a una carpeta en el bucket de Cloud Storage de destino. La transmisión que crees incluirá una lista de entidades permitidas y una lista de entidades rechazadas.

Configura una variable SCHEMAS. Esta variable define los esquemas que contienen los datos y las tablas que quieres que Datastream recupere de la base de datos de origen y transfiera a la carpeta /root/tutorial del bucket de destino de Cloud Storage. En este instructivo, establecerás la variable SCHEMAS para asociarla con el esquema ROOT.

En el mensaje, ingresa el siguiente comando:
```
SCHEMAS="{\"oracleSchemas\":[{\"schema\":\"ROOT\"}]}"
```
Cuando se te solicite, ingresa el comando echo $SCHEMAS | jq para ver el esquema ROOT que definiste para esta variable en texto fácil de leer.

Crea una transmisión. En la solicitud, ingresa el siguiente comando:

STREAM="{\"display_name\":\"DISPLAY_NAME\",\"source_config\":{\"source_connection_profile_name\":\"PROJECT_PATH/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",\"oracle_source_config\":{\"allowlist\":$SCHEMAS,\"rejectlist\":{}}},\"destination_config\":{\"destination_connection_profile_name\":\"PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID\",\"gcs_destination_config\":{\"file_rotation_mb\":5,\"file_rotation_interval\":{\"seconds\":15},\"avro_file_format\":{}},\"backfill_all\":{}}}"

En el mensaje, ingresa el comando echo $STREAM | jq para ver el flujo que creaste en texto fácil de leer.

{
  "display_name": "DISPLAY_NAME",
  "source_config": {
    "source_connection_profile_name": "PROJECT_PATH/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "oracle_source_config": {
      "allowlist": {
        "oracleSchemas": [
          {
            "schema": "ROOT"
          }
        ]
      },
      "rejectlist": {}
    }
  },
  "destination_config": {
    "destination_connection_profile_name": "PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
    "gcs_destination_config": {
      "file_rotation_mb": 5,
      "file_rotation_interval": {
        "seconds": 15
      },
      "avro_file_format": {}
    }
  },
  "backfill_all": {}
}

Usa esta tabla para comprender los siguientes parámetros de la transmisión:

Parámetro	Descripción
`allowlist`	Los esquemas, que contienen tablas y datos, que se transferirán de la base de datos de origen a una carpeta del bucket de destino de Cloud Storage. En este instructivo, todas las tablas y los datos del esquema `ROOT` (y solo este esquema) se transferirán a la carpeta `/root/tutorial` del bucket de destino.
`rejectlist`	Cualquier esquema, con tablas y datos, que no se transferirá a una carpeta del bucket de destino de Cloud Storage. En este instructivo, el valor `{}` significa que no se impedirá que se transfieran tablas ni datos de la base de datos de origen al bucket de destino.
`file_rotation_mb`	El tamaño (en MBytes) de los archivos que contienen los datos que se transfieren desde la base de datos de origen hacia una carpeta en el bucket de destino de Cloud Storage. En este instructivo, a medida que se recuperan los datos de la base de datos de origen, se escriben en archivos de 5 MB. Si se supera este tamaño, los datos se segmentarán en varios archivos de 5 MB.
`file_rotation_interval`	Es la cantidad de segundos que deben transcurrir antes de que Datastream cierre un archivo existente en una carpeta del bucket de destino de Cloud Storage y abra otro archivo para contener los datos que se transfieren desde la base de datos de origen. Para este instructivo, el intervalo de rotación de archivos se establece en 15 segundos.
`avro_file_format`	Es el formato de los archivos que Datastream transferirá de la base de datos de origen a una carpeta del bucket de destino de Cloud Storage. Para este instructivo, Avro es el formato de archivo. Además de Avro, Datastream ahora admite el formato de salida JSON para archivos escritos en Cloud Storage. En lugar de `avro_file_format`, esto se representa con el parámetro `json_file_format`. En el formato JSON, puedes hacer lo siguiente: Incluye un archivo de esquema de tipos unificados en la ruta de acceso. Como resultado, Datastream escribe dos archivos en Cloud Storage: un archivo de datos JSON y un archivo de esquema Avro. El archivo de esquema tiene el mismo nombre que el archivo de datos, con una extensión `.schema`. Habilita la compresión gzip para que Datastream comprima los archivos que se escriben en Cloud Storage. Debido a que estas dos propiedades no se aplican a Avro, el valor del parámetro `avro_file_format` se establece en un diccionario vacío (`{}`).
`backfill_all`	Este parámetro está asociado con el reabastecimiento histórico. Si estableces este parámetro en un diccionario vacío (`{}`), Datastream reabastecerá lo siguiente: Datos históricos, además de cambios continuos en los datos, de la base de datos de origen al destino Esquemas y tablas, de la fuente al destino.

Valida la transmisión para asegurarte de que se ejecute correctamente y de que se aprueben todas las verificaciones de validación. En la solicitud, ingresa el siguiente comando:
```
curl -X POST -d $STREAM -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" "https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams?stream_id=STREAM_ID&validate_only=true"
```
Reemplaza el valor del parámetro STREAM_ID por un identificador único reservado para esta transmisión (por ejemplo, stream-1).

El valor &validate_only=true indica que solo estás validando el flujo, no lo estás creando. Para esta solicitud, escribe toda la URL entre comillas. Esto garantiza que Datastream detecte el valor &validate_only=true para validar el flujo.
Verifica que veas la línea de código {}. Esto indica que la transmisión pasó todas las verificaciones de validación y que no hay errores asociados con ella.

En el caso de las verificaciones de validación que no se aprueben, aparecerá información sobre por qué fallaron y qué hacer para rectificar el problema.

Después de hacer las correcciones apropiadas, vuelve a realizar la solicitud para asegurarte de que todas las verificaciones de validación se aprueben.

Envía la transmisión para que se pueda crear. En la solicitud, ingresa el siguiente comando:

curl -X POST -d $STREAM -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams?stream_id=STREAM_ID

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-STREAM_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/streams/STREAM_ID",
    "verb": "create",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Confirma que se creó la transmisión. En el mensaje, ingresa el siguiente comando:
```
curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams
```
Nota: La cadena streams al final del comando indica que deseas recuperar información sobre el flujo para confirmar que se creó.

Verifica que recibas un resultado para la transmisión que creaste.

{
  "streams": [
    {
      "name": "PROJECT_PATH/streams/STREAM_ID",
      "createTime": "DATE_AND_TIME_STAMP",
      "updateTime": "DATE_AND_TIME_STAMP",
      "displayName": "DISPLAY_NAME",
      "sourceConfig": {
        "sourceConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
        "oracleSourceConfig": {
          "allowlist": {
            "oracleSchemas": [
              {
                "schema": "ROOT"
              }
            ]
          },
          "rejectlist": {}
        }
      },
      "destinationConfig": {
        "destinationConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
      "gcsDestinationConfig": {
          "fileRotationMb": 5,
          "fileRotationInterval": "15s"
          "avroFileFormat": {}
        }
      },
      "state": "CREATED",
      "backfillAll": {}
    }
  ]
}

Administra la transmisión

En este procedimiento, usarás la transmisión que creaste para transferir datos de una base de datos de Oracle de origen a una carpeta en un bucket de destino de Cloud Storage. Incluye lo siguiente:

Recuperar información sobre la transmisión
Modificar la transmisión
Iniciar la transmisión
Usar la API de recuperación de errores para detectar cualquier error asociado con la transmisión
Pausar y reanudar la transmisión

Recupera información sobre la transmisión. En la solicitud, ingresa el siguiente comando:

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID

Verifica que veas información sobre esta transmisión.

{
  "name": "PROJECT_PATH/streams/STREAM_ID",
  "createTime": "DATE_AND_TIME_STAMP",
  "updateTime": "DATE_AND_TIME_STAMP",
  "displayName": "DISPLAY_NAME",
  "sourceConfig": {
    "sourceConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "oracleSourceConfig": {
      "allowlist": {
        "oracleSchemas": [
          {
            "schema": "ROOT"
          }
        ]
      },
      "rejectlist": {}
     }
    },
    "destinationConfig": {
      "destinationConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
      "gcsDestinationConfig": {
        "fileRotationMb": 5,
        "fileRotationInterval": "15s"
        "avroFileFormat": {}
      }
    },
    "state": "CREATED",
    "backfillAll": {}
  }

Modificar estas Novedades. Para ello, primero, establece una variable UPDATE. Esta variable contiene los valores del flujo que deseas cambiar. En este instructivo, cambia el tamaño (en MBytes) de los archivos que contienen los datos que se transfieren desde la base de datos de origen hacia una carpeta en el bucket de destino de Cloud Storage (de 5 a 100 MBytes). A medida que se recuperan los datos de la base de datos de origen, ahora se escriben en archivos de 100 MB. Si algún dato supera este tamaño, se segmentará en varios archivos de 100 MB.

Para configurar la variable, ingresa el siguiente comando en la solicitud:
```
UPDATE="{\"destination_config\":{\"gcs_destination_config\":{\"file_rotation_mb\":100}}}"
```

En el mensaje, ingresa el siguiente comando:

curl -X PATCH -d $UPDATE -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID/?update_mask=destination_config.gcs_destination_config.file_rotation_mb

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-STREAM_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/streams/STREAM_ID",
    "verb": "update",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Confirma que la transmisión se haya modificado. En el mensaje, ingresa el siguiente comando:

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID

Verifica que el valor del parámetro fileRotationMb para el perfil de conexión de Cloud Storage ahora sea 100.

{
  "name": "PROJECT_PATH/streams/STREAM_ID",
  "createTime": "DATE_AND_TIME_STAMP",
  "updateTime": "DATE_AND_TIME_STAMP",
  "displayName": "DISPLAY_NAME",
  "sourceConfig": {
    "sourceConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "oracleSourceConfig": {
      "allowlist": {
        "oracleSchemas": [
          {
            "schema": "ROOT"
          }
        ]
      },
      "rejectlist": {}
     }
    },
    "destinationConfig": {
      "destinationConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
      "gcsDestinationConfig": {
        "fileRotationMb": 100,
        "fileRotationInterval": "15s"
        "avroFileFormat": {}
      }
    },
    "state": "CREATED",
    "backfillAll": {}
  }

Inicia la transmisión Para ello, deberás hacer lo siguiente:
1. Cambia la variable UPDATE. En la solicitud, ingresa el siguiente comando:
```
UPDATE="{\"state\":\"RUNNING\"}"
```
2. Luego, ingresa el siguiente comando:
```
curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID?updateMask=state
```
  Usar el parámetro updateMask en la solicitud hace que solo los campos que especifiques deban incluirse en el cuerpo de la solicitud.
  
  En este ejemplo, el campo especificado es el campo state, que representa el estado de la transmisión. Cuando inicies la transmisión, cambiarás su estado de CREATED a RUNNING.

Verifica que veas las siguientes líneas de código.

{
  "name": "PROJECT_PATH/operations/operation-STREAM_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/streams/STREAM_ID",
    "verb": "start",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Después de unos minutos, recupera información sobre la transmisión para confirmar que se inició:
```
curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID
```
Nota: La transmisión tarda unos minutos en comenzar a ejecutarse. Se deben iniciar los recursos en segundo plano para que pueda comenzar la transmisión.

Verifica que el estado de la transmisión haya cambiado de CREATED a RUNNING.

{
  "name": "PROJECT_PATH/streams/STREAM_ID",
  "createTime": "DATE_AND_TIME_STAMP",
  "updateTime": "DATE_AND_TIME_STAMP",
  "displayName": "DISPLAY_NAME",
  "sourceConfig": {
    "sourceConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "oracleSourceConfig": {
      "allowlist": {
        "oracleSchemas": [
          {
            "schema": "ROOT"
          }
        ]
      },
      "rejectlist": {}
    }
  },
  "destinationConfig": {
    "destinationConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
    "gcsDestinationConfig": {
      "fileRotationMb": 100,
      "fileRotationInterval": "15s"
      "avroFileFormat": {}
    }
  },
  "state": "RUNNING",
  "backfillAll": {}
}

Cuando se inicia una transmisión, el estado primero cambia a STARTING. Esto significa que la transmisión está en proceso de inicio y validación.

Si la transmisión es válida, su estado cambia de STARTING a RUNNING.
Si la transmisión no es válida, su estado vuelve a cambiar de STARTING a CREATED. Corrige los errores relacionados con la transmisión. Por ejemplo, si hay errores asociados con la información de conectividad de la transmisión, modifica la definición de la transmisión. Después de resolver todos los problemas de la transmisión, vuelve a iniciarla. El estado cambiará a STARTING y, luego, a RUNNING.

Si el estado de la transmisión sigue siendo STARTING, espera unos segundos y, luego, ingresa el comando para volver a recuperar información sobre la transmisión. El estado de la transmisión debería cambiar a RUNNING.

Usar la API de Fetch Errors para recuperar cualquier error asociado con la transmisión

En el mensaje, ingresa el siguiente comando:

curl -X POST -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID:fetchErrors

Verifica que veas las siguientes líneas de código:

  {
    "name": "PROJECT_PATH/operations/operation-FETCH_ERRORS_OPERATION_ID",
    "metadata": {
      "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
      "createTime": "DATE_AND_TIME_STAMP",
      "target": "PROJECT_PATH/streams/STREAM_ID",
      "verb": "fetchErrors",
      "requestedCancellation": false,
      "apiVersion": "DATASTREAM_API_VERSION"
    },
    "done": false
  }

En la solicitud, ingresa el siguiente comando:

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/operations/operation-FETCH_ERRORS_OPERATION_ID

Verifica que veas las siguientes líneas de código:
```
  {
    "name": "PROJECT_PATH/operations/operation-FETCH_ERRORS_OPERATION_ID",
    "metadata": {
      "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
      "createTime": "DATE_AND_TIME_STAMP",
      "endTime": "DATE_AND_TIME_STAMP",
      "target": "PROJECT_PATH/streams/STREAM_ID",
      "verb": "fetchErrors",
      "requestedCancellation": false,
      "apiVersion": "DATASTREAM_API_VERSION"
    },
    "done": true,
    "response": {
      "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.FetchErrorsResponse"
    }
  }
  
```
Nota: No aparecen errores después de la línea de código "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.FetchErrorsResponse. Esto indica que Datastream no detectó ningún error en la transmisión. Puedes usar la transmisión para transferir datos de la base de datos de origen de Oracle a la carpeta /root/tutorial en el bucket de destino de Cloud Storage. Un ejemplo de un error que se podría recuperar con la API de Fetch Errors es BAD_CREDENTIALS. Este error ocurre cuando hay un valor no válido en los perfiles de conexión de origen o de destino, y Datastream no puede usar los perfiles para conectarse a la base de datos de origen o al bucket de destino en Cloud Storage.

Pausa la transmisión Para ello, deberás hacer lo siguiente:
1. Cambia la variable UPDATE. En la solicitud, ingresa el siguiente comando:
```
UPDATE="{\"state\":\"PAUSED\"}"
```
2. Luego, ingresa el siguiente comando:
```
curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID?updateMask=state
```
  Si pausas la transmisión, cambias su estado de RUNNING a PAUSED.

Verifica que veas las siguientes líneas de código.

{
  "name": "PROJECT_PATH/operations/operation-STREAM_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/streams/STREAM_ID",
    "verb": "start",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Recupera información sobre la transmisión para confirmar que está pausada.

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID

Verifica que el estado de la transmisión haya cambiado de RUNNING a PAUSED.

{
  "name": "PROJECT_PATH/streams/STREAM_ID",
  "createTime": "DATE_AND_TIME_STAMP",
  "updateTime": "DATE_AND_TIME_STAMP",
  "displayName": "DISPLAY_NAME",
  "sourceConfig": {
    "sourceConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "oracleSourceConfig": {
      "allowlist": {
        "oracleSchemas": [
          {
            "schema": "ROOT"
          }
        ]
      },
      "rejectlist": {}
    }
  },
  "destinationConfig": {
    "destinationConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
    "gcsDestinationConfig": {
      "fileRotationMb": 100,
      "fileRotationInterval": "15s"
      "avroFileFormat": {}
    }
  },
  "state": "PAUSED",
  "backfillAll": {}
}

Reanuda la transmisión pausada. Para ello, deberás hacer lo siguiente:
1. Cambia la variable UPDATE. En la solicitud, ingresa el siguiente comando:
```
UPDATE="{\"state\":\"RUNNING\"}"
```
2. Luego, ingresa el siguiente comando:
```
curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID?updateMask=state
```
  Cuando reanudas la transmisión, cambias su estado de PAUSED a RUNNING.

Verifica que veas las siguientes líneas de código.

{
  "name": "PROJECT_PATH/operations/operation-STREAM_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/streams/STREAM_ID",
    "verb": "start",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Después de unos segundos, recupera información sobre la transmisión para confirmar que se está ejecutando nuevamente.

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID

Verifica que el estado de la transmisión haya cambiado de PAUSED a RUNNING.

{
  "name": "PROJECT_PATH/streams/STREAM_ID",
  "createTime": "DATE_AND_TIME_STAMP",
  "updateTime": "DATE_AND_TIME_STAMP",
  "displayName": "DISPLAY_NAME",
  "sourceConfig": {
    "sourceConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "oracleSourceConfig": {
      "allowlist": {
        "oracleSchemas": [
          {
            "schema": "ROOT"
          }
        ]
      },
      "rejectlist": {}
    }
  },
  "destinationConfig": {
    "destinationConnectionProfileName": "projects/YOUR_PROJECT_NUMBER/locations/YOUR_PROJECT_LOCATION/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
    "gcsDestinationConfig": {
      "fileRotationMb": 100,
      "fileRotationInterval": "15s"
      "avroFileFormat": {}
    }
  },
  "state": "RUNNING",
  "backfillAll": {}
}

Ahora que creó y administró una transmisión, confirmó que no hay errores asociados y que el estado de la transmisión es RUNNING, está listo para verificar que pueda transferir datos de la base de datos de origen a una en el bucket de destino de Cloud Storage.

Cómo verificar la transmisión

En este procedimiento, confirmas que Datastream hizo lo siguiente:

Transfiere los datos de todas las tablas asociadas con el esquema ROOT de la base de datos fuente de Oracle a la carpeta /root/tutorial en el bucket de destino de Cloud Storage.
Traduce los datos al formato de archivo Avro.

Ve a la página Navegador de Storage en Cloud Storage.

Ir a la página del navegador de almacenamiento
Haz clic en el vínculo que contiene tu bucket.
Si la pestaña OBJETOS no está activa, haz clic en ella.
Haz clic en la carpeta root y, luego, en la carpeta tutorial.

Nota: Datastream creó las carpetas root y tutorial después de que modificaste el perfil de conexión de destino cambiando la carpeta del bucket de destino a /root/tutorial.
Verifica que veas carpetas que representen tablas del esquema ROOT de tu base de datos de Oracle de origen.
Haz clic en una de las carpetas de la tabla y desglósala hasta que vea los datos asociados con ella.
Haz clic en un archivo que represente los datos y, luego, en DESCARGAR.
Abre este archivo en una herramienta de Avro (por ejemplo, Avro Viewer) para asegurarte de que el contenido sea legible. Esto confirma que Datastream también tradujo los datos al formato de archivo Avro.

Limpia

Cuando termines con el instructivo, puedes limpiar los recursos que creaste en Datastream para que no consuman la cuota ni se te facture por ellos en el futuro. En las secciones siguientes, se describe cómo borrar o desactivar estos recursos.

Borra el proyecto

La manera más fácil de eliminar la facturación es borrar el proyecto que creaste para el instructivo.

Para borrar el proyecto, haz lo siguiente:

Precaución: Borrar un proyecto tiene las siguientes consecuencias:

Se borra todo en el proyecto. Si usaste un proyecto existente para las tareas de este documento, cuando lo borres, también se borrará cualquier otro trabajo que hayas realizado en el proyecto.
Se pierden los ID personalizados de proyectos. Cuando creaste este proyecto, es posible que hayas creado un ID del proyecto personalizado que desees utilizar en el futuro. Para conservar las URL que utilizan el ID del proyecto, como una URL appspot.com, borra los recursos seleccionados dentro del proyecto en lugar de borrar todo el proyecto.

Si planeas explorar varias infraestructuras, instructivos y guías de inicio rápido la reutilización de proyectos puede ayudarte a evitar exceder los límites de las cuotas del proyecto.

In the Google Cloud console, go to the Manage resources page.
Go to Manage resources
In the project list, select the project that you want to delete, and then click Delete.
In the dialog, type the project ID, and then click Shut down to delete the project.

Borra el bucket de destino de Cloud Storage

En el panel lateral de navegación izquierdo de Cloud Storage, haz clic en el elemento Navegador.
Selecciona la casilla de verificación a la izquierda de tu bucket y haz clic en BORRAR.
¿En el bucket Borrar? ingresa el nombre del bucket en el campo de texto y haz clic en CONFIRMAR.

Borra la transmisión

Asegúrate de que tu aplicación de Cloud Shell esté activa.

En la solicitud, ingresa el siguiente comando:

curl -X DELETE -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams/STREAM_ID

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-STREAM_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/streams/STREAM_ID",
    "verb": "delete",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Confirma que se haya borrado la transmisión. En el mensaje, ingresa el siguiente comando:

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/streams

Verifica que se muestre un valor {} nulo. Esto significa que ya no hay transmisiones en Datastream y que se borró la transmisión que creaste.

Borra los perfiles de conexión

Borra el perfil de conexión en la base de datos de origen de Oracle. En el mensaje, ingresa el siguiente comando:

curl -X DELETE -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-SOURCE_CONNECTION_PROFILE_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/connectionProfiles/SOURCE_CONNECTION_PROFILE_ID",
    "verb": "delete",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Borrar el perfil de conexión al bucket de destino en Cloud Storage En el mensaje, ingresa el siguiente comando:

curl -X DELETE -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID

Verifica que veas las siguientes líneas de código:

{
  "name": "PROJECT_PATH/operations/operation-DESTINATION_CONNECTION_PROFILE_OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.datastream.DATASTREAM_API_VERSION.OperationMetadata",
    "createTime": "DATE_AND_TIME_STAMP",
    "target": "PROJECT_PATH/connectionProfiles/DESTINATION_CONNECTION_PROFILE_ID",
    "verb": "delete",
    "requestedCancellation": false,
    "apiVersion": "DATASTREAM_API_VERSION"
  },
  "done": false
}

Confirma que se hayan borrado ambos perfiles de conexión. En la solicitud, ingresa el siguiente comando:

curl -H "Authorization: Bearer $TOKEN" -H "Content-Type: application/json" https://datastream.googleapis.com/DATASTREAM_API_VERSION/PROJECT_PATH/connectionProfiles

Verifica que se devuelva un valor {} nulo. Esto significa que ya no hay ningún perfil de conexión en Datastream y que se borran los perfiles que creaste.

¿Qué sigue?

Obtén más información sobre Datastream.
Prueba otras funciones de Google Cloud. Consulta nuestros instructivos.