Data Transmission Service:Crear una tarea de suscripción de datos de Oracle

Requisitos previos

• La base de datos Oracle autogestionada debe ser versión 9i, 10g u 11g. No se admiten instancias de Real Application Clusters (RAC) ni de Pluggable Database (PDB).

• El registro suplementario debe estar habilitado para la base de datos Oracle de origen, y los parámetros supplemental_log_data_pk y supplemental_log_data_ui deben estar activados. Para obtener más información, consulte Supplemental Logging.

• La base de datos Oracle de origen debe estar en modo ARCHIVELOG. Los registros archivados deben tener un período de retención adecuado y ser accesibles. Para obtener más información, consulte ARCHIVELOG.

• Debe haber creado un Virtual Private Cloud (VPC) and a vSwitch para la instancia de suscripción de datos.

Límites

Antes de empezar

Inicie sesión en la base de datos Oracle de origen, cree una cuenta de base de datos para la tarea de Data Subscription y otórguele permisos DBA. Para obtener más información, consulte CREATE USER y GRANT USER.

1. Habilite el registro de archivado y el registro suplementario.

   Tipo	Procedimiento
   Registro de archivado	Ejecute las siguientes sentencias para habilitar el registro de archivado: shutdown immediate; startup mount; alter database archivelog; alter database open; archive log list;
   Registro suplementario	Habilite el registro suplementario a nivel de base de datos o de tabla: Nota Puede habilitar el registro suplementario a nivel de base de datos para garantizar la estabilidad de las tareas de DTS. También puede habilitar el registro suplementario a nivel de tabla para reducir el uso de disco de la base de datos Oracle de origen. Habilitar el registro suplementario a nivel de base de datos Habilite el registro suplementario mínimo: alter database add supplemental log data; Habilite el registro suplementario de clave primaria y clave única a nivel de base de datos: alter database add supplemental log data (primary key,unique index) columns; Habilitar el registro suplementario a nivel de tabla Habilite el registro suplementario mínimo: alter database add supplemental log data; Habilite el registro suplementario a nivel de tabla mediante uno de los siguientes métodos: Habilite el registro suplementario de clave primaria a nivel de tabla: alter table table_name add supplemental log data (primary key) columns; Habilite el registro suplementario a nivel de tabla para todas las columnas: alter table tb_name add supplemental log data (all) columns ;

2. Otorgue permisos detallados a una cuenta de base de datos Oracle.

   Versiones de Oracle 9i a 11g

   # Create a database account, for example, rdsdt_dtsacct, and grant permissions to the account.
   create user rdsdt_dtsacct IDENTIFIED BY rdsdt_dtsacct;
   grant create session to rdsdt_dtsacct;
   grant connect to rdsdt_dtsacct;
   grant resource to rdsdt_dtsacct;
   grant execute on sys.dbms_logmnr to rdsdt_dtsacct;
   grant select on V_$LOGMNR_LOGS to rdsdt_dtsacct;
   grant select on all_objects to rdsdt_dtsacct;
   grant select on all_tab_cols to rdsdt_dtsacct;
   grant select on dba_registry to rdsdt_dtsacct;
   grant select any table to rdsdt_dtsacct;
   grant select any transaction to rdsdt_dtsacct;
   -- v$log privileges
   grant select on v_$log to rdsdt_dtsacct;
   -- v$logfile privileges
   grant select on v_$logfile to rdsdt_dtsacct;
   -- v$archived_log privileges
   grant select on v_$archived_log to rdsdt_dtsacct;
   -- v$parameter privileges
   grant select on v_$parameter to rdsdt_dtsacct;
   -- v$database privileges
   grant select on v_$database to rdsdt_dtsacct;
   -- v$active_instances privileges
   grant select on v_$active_instances to rdsdt_dtsacct;
   -- v$instance privileges
   grant select on v_$instance to rdsdt_dtsacct;
   -- v$logmnr_contents privileges
   grant select on v_$logmnr_contents to rdsdt_dtsacct;
   -- system tables
   grant select on sys.USER$ to rdsdt_dtsacct;
   grant select on SYS.OBJ$ to rdsdt_dtsacct;
   grant select on SYS.COL$ to rdsdt_dtsacct;
   grant select on SYS.IND$ to rdsdt_dtsacct;
   grant select on SYS.ICOL$ to rdsdt_dtsacct;
   grant select on SYS.CDEF$ to rdsdt_dtsacct;
   grant select on SYS.CCOL$ to rdsdt_dtsacct;
   grant select on SYS.TABPART$ to rdsdt_dtsacct;
   grant select on SYS.TABSUBPART$ to rdsdt_dtsacct;
   grant select on SYS.TABCOMPART$ to rdsdt_dtsacct;

Procedimiento

1. Utilice uno de los siguientes métodos para ir a la página Change Tracking Tasks y seleccione la región donde reside la instancia de seguimiento de cambios.

   Consola de DTS

   1. Inicie sesión en la consola de DTS.

   2. En el panel de navegación izquierdo, haga clic en Change Tracking.

   3. En la esquina superior izquierda de la página, seleccione la región donde reside la instancia de seguimiento de cambios.

   Consola de DMS

   Nota

   Las operaciones reales pueden variar según el modo y el diseño de la consola de DMS. Para obtener más información, consulte Simple mode console y Customize DMS console layout and style.

   1. Inicie sesión en la consola de DMS.

   2. En la barra de navegación superior, mueva el puntero sobre Data + AI > DTS (DTS) > Change Tracking.

   3. En la lista desplegable a la derecha de Change Tracking Tasks, seleccione la región donde reside la instancia de seguimiento de cambios.

2. Haga clic en Create Task para ir a la página de configuración de tareas.

3. Configure los parámetros en las secciones Source Database y Consumer Network Type.

   Aviso

   Después de especificar la instancia de base de datos de origen, se recomienda leer los Limits que se muestran en la parte superior de la página. De lo contrario, la tarea podría fallar o los datos rastreados no se podrán consumir.

   Categoría	Parámetro	Descripción
   N/A	Task Name	Nombre de la tarea de seguimiento de cambios. DTS asigna automáticamente un nombre a la tarea. Se recomienda especificar un nombre descriptivo que facilite la identificación de la tarea. No es necesario utilizar un nombre único.
   Source Database	Select Existing Connection	Si desea utilizar una instancia de base de datos que esté Manage database connections al sistema (ya sea recién creada o guardada previamente), selecciónela de la lista desplegable. La información de la base de datos se completará automáticamente. Nota En la consola de DMS, esta configuración tiene la etiqueta Select a DMS database instance. Si su instancia de base de datos no está en el sistema, o si no desea utilizar una existente, configure manualmente la información de la base de datos.
   	Database Type	Seleccione Oracle.
   	Access Method	Seleccione el método de acceso según el tipo de instancia de origen. Este ejemplo utiliza Self-managed Database on ECS. Nota Si su base de datos de origen es una base de datos autogestionada, debe completar la preparación correspondiente. Para obtener más información, consulte Preparation overview.
   	Instance Region	Seleccione la región donde se encuentra la base de datos Oracle autogestionada.
   	ECS Instance ID	Seleccione el ID de la instancia ECS que aloja la base de datos Oracle autogestionada.
   	Port	Introduzca el puerto de servicio de la base de datos Oracle autogestionada. El valor predeterminado es 1521.
   	Oracle Type	Non-RAC Instance: Si selecciona esta opción, también debe especificar el SID. RAC or PDB Instance: Si selecciona esta opción, también debe introducir el Service Name. Importante No se admiten instancias RAC ni PDB. Este ejemplo utiliza una Non-RAC Instance.
   	Database Account	Introduzca la cuenta para la base de datos Oracle autogestionada. Para conocer los requisitos de permisos, consulte Before you begin.
   	Database Password	Contraseña utilizada para acceder a la instancia de base de datos.
   Consumer Network Type	Network Type	El valor del parámetro Network Type está fijado en VPC. Debe seleccionar una VPC y un vSwitch. Para obtener más información, consulte VPCs. Nota Una vez configurada una tarea de seguimiento de cambios, no puede modificar la configuración en la sección Consumer Network Type. Si su cliente de seguimiento de cambios está desplegado en una VPC, se recomienda seleccionar la misma VPC y el mismo vSwitch al que está conectado el cliente. Si rastrea cambios de datos a través de redes internas, la latencia de red es mínima.

5. Configure los objetos para el seguimiento de cambios.

   1. En la página Configure Objects, configure los objetos para el seguimiento de cambios.

      Parámetro	Descripción
      Data Change Types	Los Data Change Types están seleccionados de forma predeterminada y no se pueden modificar. Data Update DTS rastrea las actualizaciones de datos de los objetos seleccionados, incluidas las operaciones INSERT, DELETE y UPDATE. Schema Update DTS rastrea las operaciones de creación, eliminación y modificación realizadas en todos los esquemas de objetos de la instancia de origen. Debe utilizar el cliente de seguimiento de cambios para filtrar los datos que se van a rastrear.
      Source Objects	Seleccione uno o varios objetos en la sección Source Objects y haga clic en el icono para agregarlos a la sección Selected Objects. Nota Puede seleccionar tablas o bases de datos como objetos para el seguimiento de cambios. Si selecciona una base de datos como objeto, DTS rastrea los datos incrementales de todos los objetos, incluidos los nuevos objetos creados en la base de datos. Si selecciona una tabla como objeto, DTS rastrea únicamente los datos incrementales de dicha tabla. En este caso, si desea rastrear cambios de datos en otra tabla, debe agregarla a la lista de objetos. Para obtener más información, consulte Modify the objects for change tracking.

   2. Haga clic en Next: Advanced Settings para configurar los ajustes avanzados.

      Parámetro	Descripción
      Dedicated Cluster for Task Scheduling	De forma predeterminada, DTS programa la tarea en un clúster compartido. No es necesario configurar este parámetro. Puede adquirir clústeres dedicados con especificaciones concretas para ejecutar tareas de seguimiento de cambios de DTS. Para obtener más información, consulte What is a DTS dedicated cluster?.
      Retry Time for Failed Connections	Intervalo de tiempo para reintentar conexiones fallidas. Si la tarea de seguimiento de cambios falla, DTS reintenta inmediatamente la conexión dentro de este intervalo. Valores válidos: de 10 a 1440. Unidad: minutos. Valor predeterminado: 720. Se recomienda establecer este parámetro en un valor mayor a 30. Si DTS logra reconectarse a la instancia de base de datos de origen dentro del intervalo especificado, reanudará la tarea de seguimiento de cambios. De lo contrario, la tarea fallará. Nota Si hay varias tareas de seguimiento de cambios configuradas para una misma instancia de base de datos, prevalecerá el intervalo de reintento más corto. Por ejemplo, si la Tarea A y la Tarea B están configuradas para la misma instancia, y la Tarea A tiene un intervalo de 30 minutos mientras que la Tarea B tiene uno de 60 minutos, prevalecerá el intervalo de 30 minutos. Cuando DTS reintenta una conexión, se generan cargos. Se recomienda especificar el intervalo de reintento según sus necesidades empresariales, o liberar la instancia DTS lo antes posible tras liberar la instancia de base de datos de origen.
      Retry Time for Other Issues	Intervalo de tiempo para reintentar ante otros problemas. Por ejemplo, si las operaciones DDL o DML no se ejecutan correctamente después de iniciar la tarea de seguimiento de cambios, DTS reintentará dichas operaciones inmediatamente dentro de este intervalo. Valores válidos: de 1 a 1440. Unidad: minutos. Valor predeterminado: 10. Se recomienda establecer este parámetro en un valor mayor a 10. Si las operaciones fallidas se ejecutan correctamente dentro del intervalo especificado, DTS reanudará la tarea de seguimiento de cambios. De lo contrario, la tarea fallará. Importante El valor del parámetro Retry Time for Other Issues debe ser menor que el valor del parámetro Retry Time for Failed Connections.
      Environment Tag	Opcional. Seleccione una etiqueta de entorno para identificar la instancia.
      Monitoring and Alerting	Especifica si se habilitan las alertas para la tarea de seguimiento de cambios. Si se configuran alertas y la tarea falla o la latencia supera el umbral, se enviarán notificaciones de alerta. Valores válidos: No: no habilita las alertas. Yes: habilita las alertas. En este caso, también debe configurar el umbral de alerta y alert notification settings. Para obtener más información, consulte Configure alerts during instance configuration.

6. En la parte inferior de la página, haga clic en Next: Save Task Settings and Precheck.

   • Para ver los parámetros que debe especificar al llamar a la operación API correspondiente para configurar la tarea DTS, mueva el puntero sobre Next: Save Task Settings and Precheck y haga clic en Preview OpenAPI parameters.

   • Si no necesita ver los parámetros o ya los revisó, haga clic en Next: Save Task Settings and Precheck en la parte inferior de la página.

   Nota

   • Antes de poder iniciar la tarea de seguimiento de cambios, DTS realiza una comprobación previa. Solo podrá iniciar la tarea una vez que haya superado dicha comprobación.

   • Si la tarea no supera la comprobación previa, haga clic en View Details junto a cada elemento fallido. Tras solucionar los problemas basándose en el mensaje de error, puede volver a ejecutar la comprobación previa.

   • Si se genera una alerta para algún elemento durante la comprobación previa, realice las siguientes operaciones según el escenario:

     • Si un elemento de alerta no se puede ignorar, haga clic en View Details junto al elemento fallido y solucione los problemas. Luego, vuelva a ejecutar la comprobación previa.

     • Si el elemento de alerta se puede ignorar, haga clic en Confirm Alert Details. En el cuadro de diálogo View Details, haga clic en Ignore. En el mensaje que aparece, haga clic en OK. A continuación, haga clic en Precheck Again para volver a ejecutar la comprobación previa. Si ignora el elemento de alerta, podría producirse una inconsistencia de datos y su negocio podría exponerse a riesgos potenciales.

7. Adquiera la instancia.

   1. Espere hasta que Success Rate alcance el 100%. Luego, haga clic en Next: Purchase Instance.

   2. En la página Purchase, especifique el método de facturación de la instancia de seguimiento de cambios. La siguiente tabla describe los parámetros.

      Parámetro	Descripción
      Método de facturación	Subscription: Paga por su suscripción al crear una instancia. El método de facturación por suscripción es más rentable que el método pay-as-you-go para uso a largo plazo. Se ofrecen precios más bajos para duraciones de suscripción más largas. Pay-as-you-go: Una instancia pay-as-you-go se factura por hora. Se recomienda seleccionar el método de facturación pay-as-you-go para uso a corto plazo. Si ya no necesita una instancia pay-as-you-go, puede liberarla para reducir costos.
      Resource Group Settings	Grupo de recursos al que pertenece la instancia. Valor predeterminado: default resource group. Para obtener más información, consulte What is resource management?
      Subscription Duration	Si selecciona el método de facturación por suscripción, establezca la duración de la suscripción y el número de instancias que desea crear. La duración de la suscripción puede ser de uno a nueve meses, un año, dos años, tres años o cinco años. Nota Este parámetro solo está disponible si selecciona el método de facturación Subscription.

   3. Lea y acepte los Data Transmission Service (Pay-as-you-go) Service Terms.

   4. Haga clic en Buy and Start para iniciar la tarea de seguimiento de cambios. Puede ver el progreso de la tarea en la lista de tareas.

Pasos siguientes

Una vez que la tarea esté en ejecución, cree grupos de consumidores y conecte sus clientes posteriores para consumir los datos rastreados.

1. Create consumer groups

2. Conecte un cliente para consumir los datos rastreados:

   • Use the SDK demo to consume tracked data

   • Use flink-dts-connector to consume tracked data

   • Use a Kafka client to consume tracked data