Tablestore:Export all data to MaxCompute

Étape 1 : Ajouter une source de données Tablestore

Ajoutez une source de données Tablestore dans DataWorks pour établir une connexion avec la table source.

1. Connectez-vous à la console DataWorks. Basculez vers la région cible. Dans le volet de navigation de gauche, accédez à Data integration > Data integration. Dans la liste déroulante, sélectionnez l'espace de travail souhaité et cliquez sur Go to Data Integration.

2. Dans le volet de navigation de gauche, cliquez sur Data Source.

3. Sur la page Data Sources, cliquez sur Add Data Source.

4. Dans la boîte de dialogue Add Data Source, recherchez et sélectionnez Tablestore comme type de source de données.

5. Dans la boîte de dialogue Add OTS Data Source, configurez les paramètres de la source de données comme décrit dans le tableau suivant.

   Paramètre	Description
   Nom de la source de données	Le nom de la source de données. Le nom peut contenir des lettres, des chiffres et des traits de soulignement (_), mais ne peut pas commencer par un chiffre ou un trait de soulignement (_).
   Description de la source de données	Une brève description de la source de données. La description peut comporter jusqu'à 80 caractères.
   Région	Sélectionnez la région où se trouve l'instance Tablestore.
   Tablestore Instance Name	Le nom de l'instance Tablestore.
   Endpoint	L'endpoint de l'instance Tablestore. Nous vous recommandons d'utiliser l'VPC Address.
   AccessKey ID	L'AccessKey ID et l'AccessKey Secret de votre compte Alibaba Cloud ou de votre utilisateur RAM.
   AccessKey Secret

6. Testez la connectivité du groupe de ressources.

   Vous devez tester la connectivité du groupe de ressources à la source de données. La tâche de synchronisation ne peut pas s'exécuter si le groupe de ressources ne peut pas se connecter à la source de données.

   1. Dans la section Connection Configuration, cliquez sur Test Network Connectivity dans la colonne Connection Status du groupe de ressources.

   2. Une fois le test de connectivité réussi, l'Connection Status passe à Connected. Cliquez sur Complete. Vous pouvez afficher la nouvelle source de données dans la liste des sources de données.

      Si le résultat du test de connectivité est Failed, vous pouvez utiliser l'Network Connectivity Diagnostic Tool pour résoudre le problème vous-même.

Étape 2 : Ajouter une source de données MaxCompute

Ajoutez et configurez une source de données MaxCompute en tant que destination pour l'exportation des données.

1. Cliquez à nouveau sur Add data source. Sélectionnez MaxCompute comme type de source de données et configurez les paramètres.

   Paramètre	Description
   Nom de la source de données	Le nom doit être composé de lettres, de chiffres et de traits de soulignement (_). Il ne peut pas commencer par un chiffre ou un trait de soulignement (_).
   Data source description	Une brève description de la source de données, ne dépassant pas 80 caractères.
   Méthode d'authentification	Cette valeur est définie par défaut sur Alibaba Cloud account and Alibaba Cloud RAM role et ne peut pas être modifiée.
   Alibaba Cloud Account	Current Alibaba Cloud Account : sélectionnez le MaxCompute project name et l'Default Access Identity pour le compte actuel dans la région spécifiée. Another Alibaba Cloud Account : saisissez l'UID of Alibaba Cloud account, le MaxCompute project et le RAM role pour l'autre compte dans la région spécifiée.
   Région	La région où se trouve le projet MaxCompute.
   Endpoint	La valeur par défaut est Auto adapt. Vous pouvez également sélectionner Custom configuration selon vos besoins.

2. Une fois les paramètres configurés et le test de connectivité réussi, cliquez sur Complete pour ajouter la source de données.

Étape 3 : Configurer la tâche de synchronisation par lots

Créez une tâche de synchronisation de données pour définir les règles de transfert et les mappages de champs afin d'exporter les données de Tablestore vers 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"
            }
        ]
    }
}

Étape 4 : Afficher les résultats de la synchronisation

Une fois la tâche exécutée, affichez son statut d'exécution dans les journaux et vérifiez les données synchronisées dans la console DataWorks.

1. Affichez le statut et le résultat de l'exécution de la tâche en bas de la page. Les informations de journal suivantes indiquent que la tâche de synchronisation a réussi.

   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. Affichez les résultats dans la table de destination.

   Accédez à la console DataWorks. Dans le volet de navigation de gauche, accédez à . Ensuite, cliquez sur Go to data map pour afficher la table de destination et ses données.