对苍穹DTS数据同步不了解？

想创建一条数据同步配置，却不知如何操作？

别担心！本期文章，小编为你一一解答！

1 什么是数据同步

苍穹DTS（Data Transmission Service）数据同步是苍穹数据混合存储的支撑系统。它是一种实时同步系统，可动态灵活配置，且支持多种业务，使得数据可以同时存储在关系型数据库和MongoDB、ElasticSearch等非关系型数据库，其设计保证了数据的一致性、高扩展、高可用等特性。

DTS可以对某些entity的数据进行同步，可配置同步哪些字段，同步到哪一目标地址等。默认平台映射，将entity的一条记录对应ES（Elasticsearch）中的一个文档（Documents），选择的同步字段对应ES文档中的字段（Fields）。

同时，DTS提供扩展映射规则，支持将ES中的结构调整为自己想要的结构；在映射规则中，DTS可扩展字段，过滤数据，甚至可以自行控制数据写入ES的方式，替代标准的写入方式。

DTS整体架构图

2 如何创建一条数据同步配置

步骤一：确认场景

根据具体的业务确定应用场景，目前系统中默认场景包括：AI搜索（aisearch）、快速搜索（quicksearch）、基础资料广播（basedatabroadcast）、系统日志（operatelog）。

开发人员可根据具体的应用场景自定义场景名称、场景内码、描述说明。

注：不同的业务需使用不同的场景，不可使用系统默认存在的场景。

那么，如何自定义场景呢？别着急，小编为你解答~

(1) 首先, 实现接口kd.bos.dts.business.spi.DtsBusinessType，代码示例如下：

package kd.bos.demo;
public class DtsDemoBusinessType implements DtsBusinessType {
@Override
public String getBusinessTypeCode() {
return "kd.bos.demo ";
}
@Override
public String getBusinessTypeName() {
return （"示例名称");
}
}

（2）然后，在所在工程中添加配置。

在/META-INF/services/下创建文件kd.bos.dts.business.spi.DtsBusinessType，在该文件中添加该接口的实现类全路径。

示例：在/META-INF/services/kd.bos.dts.business.spi.DtsBusinessType文件中添加文件：kd.bos.demo.DtsDemoBusinessType，这样，自定义场景的工作就完成啦。

步骤二：新增一条配置

我们提供了配置对象DtsConfigOperatorInfo, 通过kd.bos.dts.configoperator.DtsConfigOperatorFactory.getDefault()获取配置操作对象DtsConfigOperator，可对同步配置进行操作。代码示例如下：

private void saveDtsConfigInfo() {
     DtsConfigOperatorInfo info = new DtsConfigOperatorInfo();
     info.setRegion("aisearch"); //目标地址code
     info.setEntityFields(new String[]{"fid", "fname", "fcode"}); //同步字段数组
     info.setMappingRule("ai");
     info.setEnable("1"); //1--启用  0禁用
     info.setDtsDestType(DtsDestTypeEnum.FULLTEXT);
     info.setEntityNumber("bos_user");
     info.setBusinessType("aisearch");//业务场景code
     info.setTimingSequence("fid");//时序字段
     DtsConfigOperatorFactory.getDefault().saveDtsConfig(info);
}

好了，到这一步代码就码完了，接下来就是如何在MC中配置DTS相关的配置了~具体步骤如下：

① 登录MC，在【通用配置】→【prop】→【dts.properties】增加全局参数#DTS运行应用

dts.running.appid=dts

② 在【#dts监控配置】修改ip地址为Elasticsearch地址，port为Elasticsearch的http端口（默认9200），修改clustername=elasticsearch #的集群名称如下：

elasticsearch.server.dtsmonitor=ip=127.0.0.1\nport=9200\nclustername=elasticsearch\ntotalfields=8000\nshardsnumber=3\nreplicasnumber=1

③ 启用DTS。具体操作路径为：【MC】→【租户管理】→【数据中心（账套管理）】→【基本信息】→【启用数据传输】。

④ 配置DTS可选参数。#dts全局参数，默认开启，配置可整体关闭数据同步，默认为true，如下所示：

dts.sync.enable=true

完成以上一系列配置后，启动服务就会开始自动同步数据啦，以后数据增加、修改、删除都会自动同步，无需人工干预，是不是又简单又省心~

当然我们还有更高级的扩展方式等着您，欢迎咨询哦！

3 应用场景

目前，苍穹DTS数据同步应用广泛，常见的应用场景如下：

（1）AI智能搜索使用苍穹DTS数据同步，对应用菜单、应用等内容进行快速检索。

AI智能搜索

（2）F7/序时簿使用苍穹DTS数据同步，对内容快速搜索提供底层支撑。

F7/序时簿快速搜索

（3）某物流采购商城使用苍穹DTS数据同步对商品信息进行快速搜索。

采购商城

（4）某公司HR系统使用苍穹DTS的多实体同步作为底层支撑，对员工的信息进行快速检索。

HR员工档案查询

4 常见问题

问：数据同步配置没有生效，该怎么处理？

答：查看MC【租户管理】中，该租户是否启用了数据传输，并查看dts.sync.enable配置是否为true，配置是否处于启用状态，以及同步的目标地址是否配置正确。

问：数据同步某一条配置禁用或删除没有及时生效？

答：数据同步配置表中，设计了一张主表和快照表，配置的禁用和删除是对主表进行操作，而在同步服务中访问的是快照表，两张表的数据一致性会有一定的延迟，因此禁用或删除配置停止同步会有延迟性。

以上就是本期的全部内容啦~看完是不是对苍穹DTS数据同步了解更深入了呢？一起来复习下重点吧！

5 划重点

苍穹DTS数据同步是苍穹数据混合存储的支撑系统，可以对某些entity的数据进行同步，可配置同步哪些字段，同步到哪一目标地址等；
创建一条数据同步配置主要分为两步：一是确认业务场景；二是通过kd.bos.dts.configoperator.DtsConfigOperatorFactory.getDefault()获取配置操作对象DtsConfigOperator，并在MC中完成DTS的相关配置；
苍穹DTS数据同步通过非常简便的配置方式即可完成复杂的数据同步逻辑，可以满足多种业务场景下的需求，并具有高稳定性、高可靠性、高可用性等特征。

#往期推荐#

# 1分钟了解苍穹自定义文件存储服务

# 还在为大数据量搜索慢而烦恼？那就试试它吧！

# 什么？竟然还有人不知道苍穹Monitor

# 为了这份线程池使用指南，我鸽了隔壁女神的约会

# 看完这份攻略，“苍穹分布式锁”拿捏得稳稳的

# 苍穹分布式ID，你知多少？

更多精彩内容，“码”上了解！↓

搞不懂数据同步及其配置方法的看过来！

搞不懂数据同步及其配置方法的看过来！

恭喜您！