La función de suscripción de datos le permite suscribirse en tiempo real a los cambios incrementales de una base de datos de origen. Admite escenarios como actualizaciones ligeras de caché, desacoplamiento asíncrono de negocios y sincronización de datos en tiempo real con lógica ETL. En este tema se describe cómo crear una tarea de suscripción de datos para una RDS for MySQL instancia.
Requisitos previos
-
Ya created an RDS for MySQL instance.
NotaPara obtener información sobre las versiones compatibles, consulte Subscription solutions overview.
Ya creó un Virtual Private Cloud (VPC) and a vSwitch para la instancia de suscripción de datos.
Límites
Tipo | Descripción |
Límites de la base de datos de origen |
|
Otros límites |
|
Procedimiento
-
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
Inicie sesión en la consola de DTS.
En el panel de navegación izquierdo, haga clic en Change Tracking.
En la esquina superior izquierda de la página, seleccione la región donde reside la instancia de seguimiento de cambios.
Consola de DMS
NotaLas 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.
Inicie sesión en la consola de DMS.
En la barra de navegación superior, mueva el puntero sobre .
En la lista desplegable situada a la derecha de Change Tracking Tasks, seleccione la región donde reside la instancia de seguimiento de cambios.
Haga clic en Create Task para ir a la página de configuración de la tarea.
-
Configure los parámetros en las secciones Source Database y Consumer Network Type.
AvisoDespué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 se podrán consumir.
Sección
Parámetro
Descripción
N/A
Task Name
El 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 identificar la tarea. No es necesario que el nombre de la tarea sea único.
Source Database
Select Existing Connection
Si utiliza una instancia de base de datos registrada en DTS, selecciónela en la lista desplegable. DTS completará automáticamente los siguientes parámetros de la base de datos para dicha instancia. Para obtener más información, consulte Manage database connections.
NotaEn la consola de DMS, puede seleccionar la instancia de base de datos en la lista desplegable Select a DMS database instance.
Si no logra registrar la instancia en DTS, o si no necesita utilizar la instancia registrada en DTS, debe configurar la siguiente información de la base de datos.
Database Type
Seleccione MySQL.
Access Method
Seleccione Alibaba Cloud Instance.
Instance Region
Seleccione la región donde se encuentra la instancia de RDS for MySQL.
Replicate Data Across Alibaba Cloud Accounts
Para este tutorial, seleccione No.
ImportanteSi necesita acceder a recursos de la base de datos de origen entre cuentas (al seleccionar 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 el valor de Alibaba Cloud Account y de RAM Role Name. Para consultar las instrucciones, vea Configure RAM authorization for cross-account tasks.
RDS Instance ID
Seleccione el ID de la instancia de RDS for MySQL.
Database Account
Introduzca una read-only account para la base de datos de RDS for MySQL, o bien una cuenta personalizada con los permisos REPLICATION CLIENT, REPLICATION SLAVE, SHOW VIEW y SELECT.
Database Password
La contraseña utilizada para acceder a la instancia de la base de datos.
Encryption
Especifica si se cifra la conexión a la instancia de la base de datos. Seleccione Non-encrypted o SSL-encrypted según sus necesidades. Si selecciona SSL-encrypted, debe habilitar el cifrado SSL para la instancia de ApsaraDB RDS for MySQL antes de configurar la tarea de seguimiento de cambios. Para obtener más información, consulte Configure the SSL encryption feature.
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.
NotaUna vez configurada la tarea de seguimiento de cambios, no es posible modificar los ajustes de 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 los cambios de datos a través de redes internas, la latencia de red es mínima.
-
En la parte inferior de la página, haga clic en Test Connectivity and Proceed.
NotaAsegúrese de que los bloques CIDR de los servidores de DTS se puedan agregar automática o manualmente a la configuración de seguridad de las bases de datos de origen y de destino, para permitir el acceso desde dichos servidores. 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.
-
Configure los objetos para el seguimiento de cambios.
-
En la página Configure Objects, configure los objetos para el seguimiento de cambios.
Parámetro
Descripción
Data Change Types
Los valores de 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. NotaPuede 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 de la base de datos.
Si selecciona una tabla como objeto, DTS rastrea únicamente los datos incrementales de esa tabla. En este caso, si desea rastrear los cambios de datos de otra tabla, debe agregarla a la lista de objetos. Para obtener más información, consulte Modify the objects for change tracking.
-
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
El intervalo de tiempo de reintento para conexiones fallidas. Si la tarea de seguimiento de cambios falla, DTS reintenta la conexión de inmediato dentro de este intervalo. Valores válidos: de 10 a 1440. Unidad: minutos. Valor predeterminado: 720. Se recomienda establecer el parámetro en un valor mayor a 30. Si DTS se vuelve a conectar a la instancia de la base de datos de origen dentro del intervalo especificado, reanudará la tarea de seguimiento de cambios. De lo contrario, la tarea fallará.
NotaSi se configuran varias tareas de seguimiento de cambios 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 reintento 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 los requisitos de su negocio, 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
El intervalo de tiempo de reintento para 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 las reintenta de inmediato dentro de este intervalo. Valores válidos: de 1 a 1440. Unidad: minutos. Valor predeterminado: 10. Se recomienda establecer el parámetro en un valor mayor a 10. Si las operaciones fallidas se ejecutan correctamente dentro del intervalo de reintento especificado, DTS reanudará la tarea de seguimiento de cambios. De lo contrario, la tarea fallará.
ImportanteEl valor del parámetro Retry Time for Other Issues debe ser menor que el valor del parámetro Retry Time for Failed Connections.
Whether to delete SQL operations on heartbeat tables of forward and reverse tasks
Elija si desea escribir información SQL de latido en la base de datos de origen mientras la instancia de DTS se está ejecutando.
-
Yes: La información SQL de latido no se escribe en la base de datos de origen. Esto podría hacer que la instancia de DTS reporte un retraso.
-
No: Escribe la información SQL de latido en la base de datos de origen. Esto podría interferir con funciones como la copia de seguridad física y la clonación de la base de datos de origen.
Environment Tag
Puede seleccionar una etiqueta de entorno para identificar la instancia según sus necesidades. Para este tutorial, no es necesario seleccionar ninguna.
Monitoring and Alerting
Especifica si se habilitan las alertas para la tarea de seguimiento de cambios. 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 la configuración de notificaciones de alerta. Para obtener más información, consulte Configure alerts during instance configuration.
-
-
En la parte inferior de la página, haga clic en Next: Save Task Settings and Precheck.
Para consultar los parámetros que debe especificar al llamar a la operación de API correspondiente para configurar la tarea de DTS, mueva el puntero sobre Next: Save Task Settings and Precheck y haga clic en Preview OpenAPI parameters.
Si no necesita consultar los parámetros o ya los consultó, haga clic en Next: Save Task Settings and Precheck en la parte inferior de la página.
NotaAntes de iniciar la tarea de seguimiento de cambios, DTS realiza una comprobación previa. Solo podrá iniciar la tarea si esta pasa la comprobación.
Si la tarea no pasa la comprobación previa, haga clic en View Details junto a cada elemento que haya fallado. Después de solucionar los problemas basándose en el mensaje de error, podrá 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 con 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 con 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 con alerta, podría producirse una inconsistencia de datos y su negocio quedaría expuesto a riesgos potenciales.
-
Adquiera la instancia.
Espere a que Success Rate cambie a 100%. Luego, haga clic en Next: Purchase Instance.
-
En la página Purchase, especifique el método de facturación de la instancia de seguimiento de cambios. A continuación se describen los parámetros.
Parámetro
Descripción
Método de facturación
Suscripción: paga por la suscripción al crear la instancia. El método de facturación por suscripción es más rentable que 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
El resource group al que pertenece la instancia. Valor predeterminado: default resource group. Para obtener más información, consulte What is resource management?.
Billing Type of Change Tracking Instance
Si selecciona el método de facturación por suscripción, solo podrá elegir Full-price Configuration Fee (No Data Traffic Fee) para el parámetro Billing Type of Change Tracking Instance.
Subscription Duration
Si selecciona el método de facturación por suscripción, establezca la duración de la suscripción y la cantidad 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.
NotaEste parámetro solo está disponible si selecciona el método de facturación por Subscription.
Lea y seleccione los Data Transmission Service (Pay-as-you-go) Service Terms.
Haga clic en Buy and Start para iniciar la tarea de seguimiento de cambios. Puede consultar el progreso de la tarea en la lista de tareas.
Pasos siguientes
Una vez que la tarea de suscripción se esté ejecutando, cree un consumer group y elija un método de consumo de datos para su cliente.