Tablestore:Export full data to OSS

Paso 1: Agregar un origen de datos de Tablestore

Configure un origen de datos de Tablestore en DataWorks para conectarse a sus datos 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 tal como se describe en la siguiente tabla.

   Parámetro	Descripción
   Data source name	Nombre del origen de datos. Puede contener letras, dígitos y guiones bajos (_), pero no puede comenzar con un dígito ni con un guion bajo (_).
   Data source description	Descripción breve del origen de datos. 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 usar la VPC Address.
   AccessKey ID	AccessKey ID y AccessKey Secret de su cuenta de Alibaba Cloud o usuario de RAM.
   AccessKey Secret

6. Compruebe la conectividad del resource group.

   Debe comprobar 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 del resource group.

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

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

Paso 2: Agregar un origen de datos de OSS

Configure un origen de datos de OSS como destino de la exportación de datos.

1. Haga clic nuevamente en Add Data Source. En el cuadro de diálogo, busque y seleccione OSS como tipo de origen de datos, y luego configure los parámetros.

   Parámetro	Descripción
   Data source name	Solo puede contener letras, dígitos y guiones bajos (_), y no puede comenzar con un dígito ni con un guion bajo.
   Data source description	Introduzca una descripción breve del origen de datos, de no más de 80 caracteres.
   Access Mode	RAM Role Authorization Mode: la cuenta de servicio de DataWorks accede al origen de datos asumiendo un rol de RAM. Si es la primera vez que selecciona este modo, siga las instrucciones en pantalla para otorgar los permisos obligatorios. Access Key Mode: acceda al origen de datos mediante el AccessKey ID y el AccessKey Secret de una cuenta de Alibaba Cloud o un usuario de RAM.
   Select Role	Solo necesita seleccionar un rol de RAM cuando el Access Mode es RAM Role Authorization Mode.
   AccessKey ID	El AccessKey ID y el AccessKey Secret de una cuenta de Alibaba Cloud o un usuario de RAM solo son necesarios cuando el Access Mode se establece en AccessKey Mode.
   AccessKey secret
   Region	Región donde se encuentra el bucket.
   Endpoint	Para conocer los nombres de dominio de acceso de OSS, consulte Regions and Endpoints.
   Bucket	Nombre del bucket.

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

Paso 3: Configurar una tarea de sincronización por lotes

Cree y configure una tarea de sincronización por lotes para definir la transferencia de datos de Tablestore a OSS.

{
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "ots",
            "parameter": {
                "datasource": "source_data",
                "column": [
                    {
                        "name": "id",
                        "type": "int"
                    },
                    {
                        "name": "name",
                        "type": "string"
                    },
                    {
                        "name": "age",
                        "type": "int"
                    }
                ],
                "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": "oss",
            "parameter": {
                "dateFormat": "yyyy-MM-dd HH:mm:ss",
                "datasource": "target_data",
                "writeSingleObject": false,
                "column": [
                    {
                        "name": "id",
                        "type": "int"
                    },
                    {
                        "name": "name",
                        "type": "string"
                    },
                    {
                        "name": "age",
                        "type": "int"
                    }
                ],
                "writeMode": "truncate",
                "encoding": "UTF-8",
                "fieldDelimiter": ",",
                "fileFormat": "csv",
                "object": "tablestore/source_table.csv"
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "speed": {
            "concurrent": 2,
            "throttle": false
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}

Paso 4: Consultar los resultados de la sincronización

Una vez finalizada la tarea, puede comprobar su estado de ejecución en los registros y consultar el archivo resultante en su bucket de OSS.

1. Consulte el estado y el resultado de ejecución de la tarea 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 el archivo en el bucket de destino.

   Vaya a la lista de buckets, haga clic en el bucket de destino y luego consulte o descargue el archivo de resultados.