DTS_BINLOG_PARSER用于SELECT语句中,表示对数据传输服务(Data Transmission Service,简称DTS)传输的数据库binlog数据进行解析。

背景信息

注意 当前只支持解析DTS同步的RDS binlog数据。
DTS_BINLOG_PARSER解析结果是一个STRUCT类型,包含字段如下:
struct
  : recordID long,              -- binlog的record ID
  | source string,              -- 数据源信息,包括数据库类型,版本等等
  | dbTable string,             -- 数据表名
  | recordType string,          -- 操作类型,包括INSERT,DELETE,UPDATE和INIT
  | recordTimestamp timestamp,  -- 记录的时间戳
  | extraTags string,           -- 记录的属性信息,例如pk,uk等
  | fields string,              -- 数据表的schema信息
  | beforeImages string,        -- 本记录生成前的记录数据
  | afterImages string          -- 本记录生成后的记录数据

语法

SELECT DTS_BINLOG_PARSER(column)
FROM table

示例

SELECT
recordID,
source,
dbTable,
recordType,
recordTimestamp,
extraTags,
fields,
beforeImages,
afterImages
FROM(
  SELECT DTS_BINLOG_PARSER(value) as (recordID, source, dbTable, recordType, recordTimestamp, extraTags, fields, beforeImages, afterImages)
  FROM dts_binlog_table
)