开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> Canal Client Adapter消息Dml格式说明 -> 正文阅读

[大数据]Canal Client Adapter消息Dml格式说明

在adapter配置中outerAdapters使用logger可以看到输出的dml内容
其中dml的数量与server发送的消息数量一致

canalAdapters:
    - instance: canal_15_test31 # canal 实例名或者 MQ topic 名
      groups: # 适配器组，支持多个不同入库数据源
        - groupId: lizz-test2 # 分组id, 如果是MQ模式将用到该值
          outerAdapters: # 分组内适配器列表
          - name: logger # 打印获取到的消息数据日志

?

DML内容

{
    # 变更后的数据
    "data": [
        {
            "phone": "19040805202",
            "adcode": "321",
            "id": "1"
        },
        {
            "phone": "15164175057",
            "adcode": "321",
            "id": "2"
        }
    ],
    # 源数据库
    "database": "erm",
    # 数据来源
    # tcp模式：canal的实例
    # mq模式：MQ的topic
    "destination": "canal_15_test31",
    # 源数据库的执行时间
    "es": 1650878140000,
    # 消费端id，mq的group_id
    "groupId": "lizz-test2",
    # 是否ddl语句
    "isDdl": false,
    # 变更前的原始数据，只取变动的
    "old": [
        {
            "adcode": "3"
        },
        {
            "adcode": "22"
        }
    ],
    # 数据主键字段
    "pkNames": [
        "id"
    ],
    # 执行的sql，dml模式没有sql
    "sql": "",
    # 数据表名
    "table": "user2adcode_tmp",
    # 本次同步数据时间
    "ts": 1650878142770,
    # 数据操作类型，INSERT UPDATE DELETE
    "type": "UPDATE"
}