Migrate data from MaxCompute to Tablestore

更新时间:
复制 MD 格式

This topic shows you how to migrate data from MaxCompute to Tablestore using the data integration and data development features of DataWorks.

Procedure

  1. Activate services

    1. Activate MaxCompute

    2. Activate DataWorks

  2. Create a table in DataWorks

    1. Log in to the DataWorks console and select a region in the upper-left corner.

    2. In the navigation pane on the left, choose Workspace.

    3. On the Workspaces page, in the Actions column of the target workspace, choose Shortcuts > DataStudio.

    4. On the DataStudio page, create a MaxCompute SQL node. Run the following statement to create a table named transs.

      CREATE TABLE transs
      (name    STRING,
      id    STRING,
      gender    STRING);
  3. Import data into the transs table

    1. Download the sample CSV file demo_data.csv to your computer.

    2. In the navigation pane on the left, choose Data Integration > Data Upload and Download.

    3. Click Go to Data Upload and Download.

    4. In the left navigation bar, click the upload icon image, and click Data Upload.

      Upload the data file to the MaxCompute table named transs.

  4. Create a table in the Tablestore console

    1. Log on to the Tablestore console and create an instance.

    2. Create a data table named trans. For more information, see Create a data table.

      Set the primary key to name and id.

  5. Add a MaxCompute data source in DataWorks

    1. Log in to the DataWorks console and select a region in the upper-left corner.

    2. In the navigation pane on the left, choose Workspace.

    3. On the Workspaces page, click the name of the target workspace.

    4. On the Workspace Details page, click Data Sources in the navigation pane on the left.

    5. On the Data Source tab, click Add Connection, and then select MaxCompute.

    6. On the Add MaxCompute Data Source page, fill in the Basic Information.

      For more information, see Configure a MaxCompute data source.

  6. Add a Tablestore data source. For more information, see Configure a Tablestore data source.

  7. Configure the MaxCompute (ODPS) Reader and Tablestore Writer

    1. Log in to the DataWorks console and select a region in the upper-left corner.

    2. In the navigation pane on the left, choose Data Development and O&M > Data Development.

    3. Select Workspace, and click Go to Data Studio.

    4. On the left side of DataStudio, click image, and select Create Node > Data Integration > Batch Synchronization.

      • For Data source, select Tablestore.

      • Select MaxCompute as the data destination.

    5. On the node configuration page, configure the following parameters.

      • Data Source-Source: Select the MaxCompute data source you added.

      • Data Source-Destination: Select the Tablestore data source you added.

      • Data Source-Table: Select the source table in MaxCompute.

      • Destination-Table: Select the destination table in Tablestore.

      • Runtime Resource: Select the exclusive resource group you created.

      • Keep the default values for other parameters.

      Alternatively, click the 切换代码 icon above the configuration area to switch to script mode.

      {
          "type": "job",
          "steps": [
              {
                  "stepType": "odps",
                  "parameter": {
                      "partition": [],
                      "datasource": "odps_first",
                      "column": [
                          "name",
                          "id",
                          "gender"
                      ],
                      "table": "transs"
                  },
                  "name": "Reader",
                  "category": "reader"
              },
              {
                  "stepType": "ots",
                  "parameter": {
                      "datasource": "transs",
                      "column": [
                          {
                              "name": "gender",
                              "type": "STRING"
                          }
                      ],
                      "writeMode": "UpdateRow",
                      "table": "trans",
                      "primaryKey": [
                          {
                              "name": "name",
                              "type": "STRING"
                          },
                          {
                              "name": "id",
                              "type": "STRING"
                          }
                      ]
                  },
                  "name": "Writer",
                  "category": "writer"
              }
          ],
          "version": "2.0",
          "order": {
              "hops": [
                  {
                      "from": "Reader",
                      "to": "Writer"
                  }
              ]
          },
          "setting": {
              "errorLimit": {
                  "record": "0"
              },
              "speed": {
                  "throttle": false,
                  "concurrent": 1,
                  "dmu": 1
              }
          }
      }
  8. Verify the migrated data in the Tablestore console.

    1. 登录表格存储控制台,在左上角选择地域。

    2. 在左侧导航栏选择All Instances

    3. All Instances页面下,单击实例名称,进入Instance Management页面。

    4. Instance Management页面,单击Instance Details页签。

    5. Instance Details页签下方Tables区域,单击要查看的数据表名称。

    6. 在数据表管理页面,单击Query Data页签,查看新增的表数据。