前提条件
操作步骤
① 在分析型数据库上创建目标表,数据更新类型为实时写入,字段名称和MySQL中的建议均相同;
(见: ),
所有配置均保存在app.conf中,运行前请保证配置正确;修改配置后,请重启writer
基本配置:
{
"dtsAccessId":?"",?//?拥有数据订阅通道的云账号的accessId,?必须配置
"dtsAccessKey":?"",?//?拥有数据订阅通道的云账号的accessKey,?必须配置
"dtsTunnelId":?"",?//?数据订阅通道的id,?必须配置;?注意是id,不是通道名称
"adsUserName":?"",?//?访问您的分析型数据库的用户名(accessId),?必须配置
"adsPassword":?"",?//?访问您的分析型数据库的密码(accessKey),?必须配置
"adsJdbcUrl":?"",?//?访问分析型数据库的jdbc连接串,?必须配置(格式jdbc:mysql://ip:port/dbname)
"tables":?[
"source":?{
"primaryKeys":?[""]?//?主键定义,?必须配置;?注意RDS和分析型数据库中的主键定义必须一致
"db":?"",??//?源头RDS的db名称,?必须配置
"table":?"",?//?源头RDS的table名称,?必须配置
"skipColumns":?["col1"]?//?可选,若在此配置了RDS表某列名,则该列不会同步
},
"target":?{??
"table":?""?//?分析型数据库表的table名称,?必须配置
"columnMapping":?{
"":?""?//?rds表和ads表的列对应关系:key为rds的列名,?value为分析型数据库的列名,选填,不填则按照列名一一对应
}?
}
]
tables节点的配置示例,?
表示rds_db库下的rds_table表对应ads_table表,并且rds_table表的col1列对应ads_table表的col1_ads列,
"primaryKeys":?[
"col1",
],
"db":?"rds_db",
"table":?"rds_table"
"target":?{
"table":?"ads_table"
"col1":?"col1_ads",
注意事项:
①.)RDS for MySQL表和分析型数据库中表的主键定义必须完全一致;如果不一致会出现数据不一致问题.如果需要调整RDS/分析型数据库表的主键,建议先停止writer进程;
logs目录下的日志中的异常信息均以ErrorCode=XXXX ErrorMessage=XXXX形式给出,可以进行监控
new mydao().insertmysql(sql);
呵呵?想知道方法~~~~~~~~?加精~~~~~~~~~~
①.、首先打开MYSQL的管理工具,新建一个test表,并且在表中插入两个字段.
以上就是土嘎嘎小编为大家整理的实时数据怎么写mysql相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用,就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦!!