开发者社区 问答 正文

处理Flink任务的时候,如何获取到MYSQL日志记录的BINLOG时间?

已解决

处理Flink任务的时候,如何获取到MYSQL日志记录的BINLOG时间?

展开
收起
阿里云服务支持 2022-12-20 15:12:45 225 分享 版权
1 条回答
写回答
取消 提交回答
  • 官方回答

    获取记录的BINLOG时间,如下读取变更时间的方式获取。

    CREATE TABLE mysql_orders (

    db_name STRING METADATA FROM 'database_name' VIRTUAL, -- 读取库名。

    table_name STRING METADATA FROM 'table_name' VIRTUAL, -- 读取表名。

    operation_ts TIMESTAMP_LTZ(3) METADATA FROM 'op_ts' VIRTUAL, -- 读取变更时间。

    order_id INT,

    order_date TIMESTAMP(0),

    customer_name STRING,

    price DECIMAL(10, 5),

    product_id INT,

    order_status BOOLEAN,

    PRIMARY KEY(order_id) NOT ENFORCED

    )

    详情参见MySQL的CDC源表

    2022-12-20 15:20:38
    赞同 展开评论