Data Transmission Service:Crear una tarea de Change Tracking para RDS PostgreSQL

Requisitos previos

• Cree una instancia de origen de RDS PostgreSQL. Para obtener más información, consulte Crear una instancia de RDS PostgreSQL.

  Nota

  Para obtener información sobre las versiones compatibles, consulte Overview of change tracking solutions.

• El parámetro wal_level de la instancia de origen de RDS PostgreSQL debe estar configurado como logical. Para obtener más información, consulte Set instance parameters.

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

Consideraciones

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 change tracking.

   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 change tracking.

   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, pase el puntero sobre Data + AI > DTS (DTS) > Change Tracking.

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

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

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

   Aviso

   Después de especificar la instancia de la 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 podrán consumirse.

   Categoría	Parámetro	Descripción
   N/A	Task Name	Nombre de la tarea de change tracking. 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 necesita utilizar una instancia de base de datos que ya ha sido Manage database connections (creada o guardada), seleccione la instancia deseada en la lista desplegable. La información de la base de datos siguiente se configura automáticamente. Nota En la consola de DMS, este parámetro aparece etiquetado como Select a DMS database instance. Si la instancia no está registrada, o prefiere no utilizar una registrada, configure manualmente la información de la base de datos a continuación.
   	Database Type	Seleccione PostgreSQL.
   	Access Method	Seleccione Alibaba Cloud Instance.
   	Instance Region	Seleccione la región donde se encuentra la instancia de RDS PostgreSQL.
   	Replicate Data Across Alibaba Cloud Accounts	Para este tutorial, seleccione No. Importante Si necesita acceder a recursos de la base de datos de origen entre cuentas (seleccionando Yes), debe configurar la autorización de RAM para la cuenta de Alibaba Cloud utilizada para crear la tarea de DTS. También deberá introducir la Alibaba Cloud Account y el RAM Role Name. Para obtener instrucciones, consulte Configure RAM authorization for cross-account tasks.
   	Instance ID	Seleccione el ID de la instancia de RDS PostgreSQL.
   	Database Name	Introduzca el nombre de la base de datos cuyos cambios de datos desea rastrear.
   	Database Account	Introduzca una cuenta con privilegios para la instancia de RDS PostgreSQL. La cuenta debe ser propietaria de la base de datos seleccionada. Para obtener más información sobre cómo crear una cuenta y otorgar permisos, consulte Create an account y Create a database.
   	Database Password	Contraseña utilizada para acceder a la instancia de la base de datos.
   	Encryption	Especifica si se debe cifrar la conexión a la base de datos de origen. Puede configurar este parámetro según sus necesidades empresariales. En este ejemplo, se selecciona Non-encrypted. Si desea establecer una conexión cifrada con SSL a la base de datos de origen, realice los siguientes pasos: Seleccione SSL-encrypted, cargue el CA Certificate, el Client Certificate y la Private Key of Client Certificate según sea necesario, y luego especifique la Private Key Password of Client Certificate. Nota Si configura Encryption como SSL-encrypted para una base de datos PostgreSQL autogestionada, debe cargar el CA Certificate. Si desea utilizar el certificado de cliente, debe cargar el Client Certificate y la Private Key of Client Certificate, y especificar la Private Key Password of Client Certificate. Para obtener información sobre cómo configurar el cifrado SSL para una instancia de ApsaraDB RDS for PostgreSQL, consulte SSL encryption.
   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 change tracking, no puede modificar los ajustes en la sección Consumer Network Type. Si su cliente de change tracking 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.

4. En la parte inferior de la página, haga clic en Test Connectivity and Proceed.

   Nota

   • Asegúrese de que los bloques CIDR de los servidores de DTS puedan agregarse automática o manualmente a la configuración de seguridad de las bases de datos de origen y destino para permitir el acceso desde los servidores de DTS. Para obtener más información, consulte Whitelist DTS server IP addresses.

   • Si la base de datos de origen es autogestionada y su Access Method no está configurado como Alibaba Cloud Instance, haga clic en Test Connectivity en el cuadro de diálogo CIDR Blocks of DTS Servers.

5. Configure los objetos para el change tracking.

   1. En la página Configure Objects, configure los objetos para el change tracking.

      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 change tracking para filtrar los datos que se van a rastrear. Nota Si desea rastrear operaciones de Schema Update, puede crear triggers y funciones en la base de datos de origen para capturar información DDL. Para obtener más información, consulte Implement incremental DDL migration for PostgreSQL by using triggers and functions.
      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 change tracking. 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 change tracking de DTS. Para obtener más información, consulte What is a DTS dedicated cluster?.
      Retry Time for Failed Connections	Intervalo de tiempo para reintentos de conexiones fallidas. Si la tarea de change tracking 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 superior a 30. Si DTS logra reconectarse a la instancia de la base de datos de origen dentro del intervalo especificado, reanudará la tarea de change tracking. De lo contrario, la tarea fallará. Nota Si hay varias tareas de change tracking 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, en este caso 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 de DTS lo antes posible después de liberar la instancia de la base de datos de origen.
      Retry Time for Other Issues	Intervalo de tiempo para reintentos por otros problemas. Por ejemplo, si las operaciones DDL o DML no se ejecutan correctamente después de iniciar la tarea de change tracking, 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 superior a 10. Si las operaciones fallidas se ejecutan correctamente dentro del intervalo de reintento especificado, DTS reanudará la tarea de change tracking. 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	Puede seleccionar una etiqueta para identificar el entorno de la instancia según sus necesidades empresariales. En este ejemplo no se selecciona ninguna etiqueta.
      Monitoring and Alerting	Especifica si se deben habilitar las alertas para la tarea de change tracking. Si se configuran las 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 de API correspondiente para configurar la tarea de DTS, pase 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 ha revisado, 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 change tracking, DTS realiza una comprobación previa. Solo podrá iniciar la tarea después de que esta supere dicha comprobación.

   • Si la tarea no supera la comprobación previa, haga clic en View Details junto a cada elemento fallido. Una vez resueltos los problemas según 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 change tracking. 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 seleccione los Data Transmission Service (Pay-as-you-go) Service Terms.

   4. Haga clic en Buy and Start para iniciar la tarea de change tracking. 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