本文为您介绍如何将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. 单击右上角的创建数据表
    5. 创建数据表Trans。
  3. 在DataWorks控制台中新增数据源。
    1. 进入数据集成页面,单击左侧导航栏上数据源,进入数据源管理页面。
    2. 单击右上角新增数据源,并选择数据类型为MaxCompute(ODPS)
    3. 新增MaxCompute(ODPS)数据源,并将数据源命名为odps_first。
    4. 新增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. 在表格存储控制台中查看新增的表数据。
    1. 登录表格存储控制台
    2. 单击实例名称进入实例详情页面。在数据表列表区域,单击要查看的数据表名称。
    3. 单击右侧航栏数据管理,查看新增的表数据。