MongoDB离线同步

本文提供MongoDB离线同步场景的实施思路、配置示例和验证方式，可作为实际项目配置参考。

实现在mongoDB中结果表向目标表中离线同步数据

案例

mongoDB中将t_source中的数据离线同步到t_target中

解决方案

创建Flink SQL作业类型，添加以下依赖

• mongodb-driver-core-5.2.1.jar下载
• flink-connector-mongodb-1.2.0-1.18.jar下载
• mongodb-driver-sync-5.2.1.jar下载

CREATE TABLE from_table(
    _id STRING,
    name STRING,
    age INT,
    city STRING,
    PRIMARY KEY (_id) NOT ENFORCED
) WITH (
    'connector'='mongodb',
    'uri'='mongodb://root:root123@localhost:27017',
    'collection'='t_source',
    'database'='isxcode_db'
);

CREATE TABLE target_table(
    _id STRING,
    name STRING,
    age INT,
    city STRING,
    PRIMARY KEY (_id) NOT ENFORCED
) WITH (
    'connector'='mongodb',
    'uri'='mongodb://root:root123@localhost:27017',
    'collection'='t_sink',
    'database'='isxcode_db'
); 

INSERT INTO target_table select * from from_table;