OGG参数GETUPDATEBEFORES详解

IT那活儿 2022-11-11

2593

点击上方“IT那活儿”公众号，关注后了解更多内容，不管IT什么活儿，干就完了！！！

最近在整理生产OGG相关参数，想要系统的了解下每个参数存在的意义。

毕竟也运维过了一段时间，大部分参数根据官方文档和百度都能理解。但是看到参数GETUPDATEBEFORES，感觉自己看懂了，但是不理解有啥意义。

下图是官当文档的解释，大致含义就是这个参数可以使trail文件包含UPDATE操作之前的记录。

我们使用LOGDUMP工具对trail文件进行分析，如下，可以看到这里Before image，这就是update之前的值。

我们继续往下看看使用的场景，通过该参数，在MAP表的时候可以对列使用@GETENV函数进行转换，如下图，目标库的表就可以记录操作历史，比如DML的类型。

但是，根据我对现场运维场景的认识，根本没用过，我们都是对全表就行同步，不会对列进行处理。

在我一筹莫展的时候，请教了之前现场的OGG大神，涛老哥三言两语就解释清楚了。这个参数主要使用场景是KAFKA，使用该参数，消息队列里就可以记录update之前的值。查询ogg for bigdata官方文档，在 JSON Messages 使用范例中可以看到update语句解析出的语句中就包含了before和after的值。

至此终于理解该参数的含义。

本文作者：吕金臣(上海新炬王翦团队）

本文来源：“IT那活儿”公众号

update

文章转载自IT那活儿，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。

OGG参数GETUPDATEBEFORES详解

本文作者：吕金臣(上海新炬王翦团队）

本文来源：“IT那活儿”公众号

评论