本文主要介绍通过dts数据迁移功能从mysql、oracle等迁移至elasticsearch。
适用于使用百度智能云数据传输服务dts（以下简称 dts），将dts已经支持的任意上游数据源（mysql/oracle等）中的数据迁移到目标端elasticsearch实例中。
已创建作为迁移源端的数据源实例，如：rds for mysql、自建mysql、自建oracle等。
已创建作为迁移目标端的elasticsearch实例，如：百度elasticsearch实例、自建elasticsearch实例。dts支持的elasticsearch版本为5.0及以上
源端：满足结构迁移、全量迁移、增量迁移、数据校验等各阶段对源端权限的最低要求即可，详见各类数据源迁移上云最佳实践
目标端：要求账号拥有在elasticsearch实例中创建索引、写入数据的权限
目前，dts暂不支持结构迁移。如果您选择全量/增量迁移，向下游写入数据时，elasticsearch会根据写入数据的格式自动建立索引，并指定相应的索引映射（mapping）。但有可能elasticsearch自行映射的字段类型并不符合实际的使用需求，因此不推荐这样做。
我们推荐在启动dts任务前，先建立目标端elasticsearch的相关索引，并按照实际的查询需求指定每一个字段的类型，然后启动dts数据迁移任务。
此外，为了避免大批量写入数据给下游的elasticsearch实例造成过高的负载，我们推荐将集群粒度属性refresh_interval配置为相对合理的值。如果您能接受新写入的数据在写入后1分钟可见，则可以考虑将refresh_interval取值设为1m。
put /indice/_settings
{
"index" : {
"refresh_interval" : "1m"
}
}
进入dts列表页，点击【创建数据传输实例】
配置实例基本信息后支付购买dts实例
回到dts列表页后，可以看到刚刚购买的dts实例，状态为【未配置】
点击【配置任务】
首先配置数据传输任务的上下游连接信息，您可以按需选择云数据库实例或自建实例
如上图所示。源端连接信息中，您可以按需选择不同的数据源作为任务的源端，包括：rds for mysql、自建mysql、自建oracle等。图中选择了华东-苏州地域的rds for mysql实例。
目标端应选择elasticsearch实例。目前dts的目标端支持云上托管产品百度elasticsearch和自建elasticsearch实例。图中选择了华北-保定地域的百度elasticsearch实例。elasticsearch目标端配置参数说明如下：
如果您的elasticsearch实例为自建集群，且集群中包含多个节点，配置任务时只需要填写集群中某一个节点连接信息即可，推荐使用主节点配置任务
完成配置后点击【授权白名单进入下一步】，进入对象映射配置页
如上图所示，数据流向为：云数据库 rds(mysql) -> 百度elasticsearch(elasticsearch)，迁移类型选择全量迁移 增量同步。传输对象可以选择迁移源端整个实例，也可以选择手动筛选迁移对象。图中选择将dtstest库下的multi_pk_tbl1、multi_pk_tbl2、multi_pk_tbl3三张表作为迁移对象。
选择好的迁移对象会出现在右边的已选择对象列表中。dts支持上下游库表名映射、行过滤、列过滤黑白名单等功能。可以点击【编辑】，对每一个迁移对象配置映射和过滤规则。
上图中，示例任务配置了multi_pk_tbl1和multi_pk_tbl2的表名映射规则，将其目标端表名改为tbl1和tbl2。您也可以按照自己需要配置行过滤规则和列过滤黑白名单。
dts数据迁移的映射规则为源端一张表对应elasticsearch中一个索引，索引名为：映射后库名_映射后表名。如dtstest.multi_pk_tbl1表，配置了表名映射规则multi_pk_tbl1->tbl1后，对应下游的索引名为：dtstest_tbl1。同理，dtstest.multi_pk_tbl2表对应的下游索引名为dtstest_tbl2。而图中dtstest.multi_pk_tbl3表并未配置表名映射，因此其映射后表名仍为multi_pk_tbl3，所以其对应的下游索引名为：dtstest_multi_pk_tbl3。
如果选择库级别迁移，则只能配置库名映射，无法配置表名映射。下游索引名：映射后库名_表名。如：test库下有tbl1一张表，任务选择迁移test库，并配置库名映射为：test->alpha。则下游elasticsearch实例中新建的索引名为：alpha_tbl1。
另外，elasticsearch要求索引名必须为全小写。因此dts会默认将上游库表名转为全小写的索引名。如：上游的dtstest.testtable表对应的下游elasticsearch索引名为：dtstest_testtable。
完成对象映射配置后，点击【保存并预检查】，启动任务的前置检查
可以在dts实例列表页查看前置检查的执行结果。如果检查失败，可以点击任务主状态旁的眼睛状标识查看前置检查的详情，并查阅未通过检查项的失败原因。
您可以根据dts推荐的方式修正问题后，重新执行预检查，直至前置检查通过。此时点击右侧【启动】即可启动任务
您可以在数据迁移过程中用elasticsearch提供的客户端或rest接口检查数据。如目标端elasticsearch版本为7.6时，查询twitter索引中_id为0的记录
get twitter/_doc/0
数据视图就是将源端数据源多张实体表的数据拼成一个视图，并保存到目标端elasticsearch实例的同一个索引中。
如上图所示，源端数据源中存在三张实体表：tbl_name、tbl_age、tbl_address。其中，三张表中主键相同且均为pk_id，但表中其他字段相异。dts支持建立源端多张实体表的数据同步到目标端某一个或某几个索引的数据迁移任务，同步任务以pk_id为索引指定主键，支持同步全量或增量数据。
回到任务配置中的连接配置页，数据视图功能与正常迁移任务的区别在于需要多配置两个字段
如上文中【5.1 业务场景】中的示例。tbl_name、tbl_age、tbl_address三张表组成的数据视图主键列为pk_id。源端数据视图对应的elasticsearch索引名为：dtstest_view，此时指定主键中就应当配置为dtstest_view[pk_id]。
此外，一个数据迁移任务中可以配置多个数据视图的同步规则。如：一个数据迁移任务内打算配置dtstest_view1（主键列为id）、dtstest_view2(主键列为user_id和name)两个数据视图的全量迁移 增量迁移，指定主键可以配置为：dtstest_view1[id];dtstest_view2[user_id,name]。不同视图间用分号（;）连接，同一视图的不同主键列间用逗号（,）连接。
在对象映射配置页中，数据视图功能与正常迁移任务的区别在于同一数据视图的实体表需要配置表名映射，以确保源端多张表的全量数据和增量变更记录能够写入目标端同一个elasticsearch索引中。
如下图所示，multipktbl1、multipktbl2、multipktbl3三张表同属同一个数据视图，因此三张表的目标端表名配置为view。配置后的目标端elasticsearch索引名为：映射后库名_映射后表名(dtstest_view)。索引名与上一步中指定主键配置（dtstest_view[pk_id]）中的索引名保持一致
其他配置与正常的数据迁移任务相同，不再赘述
云服务器bcc：高性能、高可靠、安全稳定的弹性计算服务
云数据库 scs：兼容 redis、memcached 协议的分布式缓存服务
云数据库 rds：专业、高性能、高可靠的关系型数据库