本文为您介绍如何将MaxCompute数据迁移至Table Store(OTS)。

前提条件

请提前开通MaxCompute和DataWorks服务。本例使用DataWorks简单模式。

操作步骤

  1. 在DataWorks控制台中创建表。
    1. 新建业务流程,并将业务流程命名为mc2ots。
      新建业务流程
    2. 新建表transs。
      新建表
    3. 输入表的基本属性。
      表基本属性
    4. 单击添加字段,创建表字段name、id、gender。

    5. 单击提交​到生产环境

    6. 导入表数据。
      导入表数据
      表数据如下。
      qwe,145,F
      asd,256,F
      xzc,345,M
      rgth,234,F
      ert,456,F
      dfg,12,M
      tyj,4,M
      bfg,245,M
      nrtjeryj,15,F
      rwh,2344,M
      trh,387,F
      srjeyj,67,M
      saerh,567,M
  2. 在表格存储Table Store控制台中创建表。
    1. 登录表格存储Table Store控制台,单击创建实例

    2. 创建实例mctoots。

    3. 单击创建数据表

    4. 创建数据表Trans。

  3. 新增数据源。
    1. 单击新增数据源

    2. 新增MaxCompute(ODPS)数据源,并将数据源命名为odps_first。

    3. 新增Table Store(OTS)数据源,并将数据源命名为Transs。

  4. 配置MaxCompute(ODPS)Reader和Table Store(OTS)Writer。
    1. 新建数据同步节点mc2ots。

    2. 在脚本模式中,导入模板。

    3. 修改JSON代码后,单击运行按钮。

      代码如下。
      {
          "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": "INT"
                          }
                      ]
                  },
                  "name": "Writer",
                  "category": "writer"
              }
          ],
          "version": "2.0",
          "order": {
              "hops": [
                  {
                      "from": "Reader",
                      "to": "Writer"
                  }
              ]
          },
          "setting": {
              "errorLimit": {
                  "record": "0"
              },
              "speed": {
                  "throttle": false,
                  "concurrent": 1,
                  "dmu": 1
              }
          }
      }
  5. 在表格存储Table Store(OTS)控制台中查看新增的表数据。