Tablestore:Export all data to MaxCompute

Paso 1: Agregar origen de datos de Tablestore

Agregue un origen de datos de Tablestore en DataWorks para establecer una conexión con la tabla de origen.

1. Inicie sesión en la consola de DataWorks. Cambie a la región de destino. En el panel de navegación izquierdo, elija Data integration > Data integration. En la lista desplegable, seleccione el espacio de trabajo deseado y haga clic en Go to Data Integration.

2. En el panel de navegación izquierdo, haga clic en Data Source.

3. En la página Data Sources, haga clic en Add Data Source.

4. En el cuadro de diálogo Add Data Source, busque y seleccione Tablestore como tipo de origen de datos.

5. En el cuadro de diálogo Add OTS Data Source, configure los parámetros del origen de datos como se describe en la siguiente tabla.

   Parámetro	Descripción
   Data source name	Nombre del origen de datos. El nombre puede contener letras, dígitos y guiones bajos (_), pero no puede comenzar con un dígito ni con un guion bajo (_).
   Data source description	Breve descripción del origen de datos. La descripción puede tener hasta 80 caracteres de longitud.
   Region	Seleccione la región donde se encuentra la instancia de Tablestore.
   Tablestore Instance Name	Nombre de la instancia de Tablestore.
   Endpoint	Endpoint de la instancia de Tablestore. Se recomienda utilizar la VPC Address.
   AccessKey ID	AccessKey ID y AccessKey Secret de su cuenta de Alibaba Cloud o usuario de RAM.
   AccessKey Secret

6. Pruebe la conectividad del resource group.

   Debe probar la conectividad del resource group con el origen de datos. La tarea de sincronización no se puede ejecutar si el resource group no logra conectarse al origen de datos.

   1. En la sección Connection Configuration, haga clic en Test Network Connectivity en la columna Connection Status correspondiente al resource group.

   2. Una vez superada la prueba de conectividad, el Connection Status cambia a Connected. Haga clic en Complete. Puede consultar el nuevo origen de datos en la lista de orígenes de datos.

      Si el resultado de la prueba de conectividad es Failed, puede utilizar la Network Connectivity Diagnostic Tool para resolver el problema por su cuenta.

Paso 2: Agregar origen de datos de MaxCompute

Agregue y configure un origen de datos de MaxCompute como destino para la exportación de datos.

1. Haga clic nuevamente en Add data source. Seleccione MaxCompute como tipo de origen de datos y configure los parámetros.

   Parámetro	Descripción
   Data source name	El nombre debe consistir en letras, dígitos y guiones bajos (_). No puede comenzar con un dígito ni con un guion bajo (_).
   Data source description	Breve descripción del origen de datos, sin exceder los 80 caracteres.
   Authentication method	Este valor se establece en Alibaba Cloud account and Alibaba Cloud RAM role de forma predeterminada y no se puede cambiar.
   Alibaba Cloud Account	Current Alibaba Cloud Account: Seleccione el MaxCompute project name y la Default Access Identity para la cuenta actual en la región especificada. Another Alibaba Cloud Account: Introduzca el UID of Alibaba Cloud account, el MaxCompute project y el RAM role para la otra cuenta en la región especificada.
   Region	Región donde se encuentra el proyecto de MaxCompute.
   Endpoint	El valor predeterminado es Auto adapt. También puede seleccionar Custom configuration según sea necesario.

2. Después de configurar los parámetros y superar la prueba de conectividad, haga clic en Complete para agregar el origen de datos.

Paso 3: Configurar tarea de sincronización por lotes

Cree una tarea de sincronización de datos para definir las reglas de transferencia y las asignaciones de campos para exportar datos de Tablestore a MaxCompute.

{
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "ots",
            "parameter": {
                "datasource": "source_data",
                "column": [
                    {
                        "name": "id",
                        "type": "INTEGER"
                    },
                    {
                        "name": "name",
                        "type": "STRING"
                    },
                    {
                        "name": "age",
                        "type": "INTEGER"
                    }
                ],
                "range": {
                    "begin": [
                        {
                            "type": "inf_min"
                        },
                        {
                            "type": "inf_min"
                        }
                    ],
                    "end": [
                        {
                            "type": "inf_max"
                        },
                        {
                            "type": "inf_max"
                        }
                    ],
                    "split": []
                },
                "table": "source_table",
                "newVersion": "true"
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "odps",
            "parameter": {
                "partition": "pt=${bizdate}",
                "truncate": true,
                "datasource": "target_data",
                "tunnelQuota": "default",
                "column": [
                    "id",
                    "name",
                    "age"
                ],
                "emptyAsNull": false,
                "guid": null,
                "table": "source_table",
                "consistencyCommit": false
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "speed": {
            "concurrent": 2,
            "throttle": false
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}

Paso 4: Consultar resultados de la sincronización

Después de que se ejecute la tarea, consulte su estado de ejecución en los registros y compruebe los datos sincronizados en la consola de DataWorks.

1. Consulte el estado de ejecución de la tarea y el resultado en la parte inferior de la página. La siguiente información de registro indica que la tarea de sincronización se completó correctamente.

   2025-11-18 11:16:23 INFO Shell run successfully!
   2025-11-18 11:16:23 INFO Current task status: FINISH
   2025-11-18 11:16:23 INFO Cost time is: 77.208s

2. Consulte los resultados en la tabla de destino.

   Vaya a la consola de DataWorks. En el panel de navegación izquierdo, haga clic en . Luego, haga clic en Go to data map para consultar la tabla de destino y sus datos.