如何启用聚合表功能

聚合表功能（v5.6.0+）使用了 Flink 的 MongoDB CDC 连接器作为功能依赖组件，需要满足以下基础条件方可正常使用

1. 部署 Flink 服务，参考：如何部署 Flink 服务

2. MongoDB 需要升级到 4.4+，参考：单机模式 MongoDB 升级到 4.4 或 集群模式 MongoDB 升级到 4.4

   • 若单机模式使用内置 MongoDB 且当前运行中的 mingdaoyun-sc 容器版本 ​​≥​ 3.0.0，则已满足要求

3. MongoDB 需要调整为副本集模式（已是副本集可忽略），参考：MongoDB 单节点转换为副本集

   • 单机模式的内置 MongoDB 默认非副本集模式

使用内置 MongoDB 未开启认证

内置 MongoDB 指 mingdaoyun-sc:3.2.0 镜像包含的 MongoDB 组件

满足基础条件后，不需要其他配置即可使用聚合表功能。👏 👏 👏

使用内置 MongoDB 开启认证

内置 MongoDB 指 mingdaoyun-sc:3.2.0 镜像包含的 MongoDB 组件

1. 使用 root 账号连接 admin 库，创建聚合表数据库角色和用户

   use admin;
   db.createRole({
     role: "aggrole",
     privileges: [
       {
         resource: { db: "", collection: "" },
         actions: [
           "splitVector",
           "listDatabases",
           "listCollections",
           "collStats",
           "find",
           "changeStream"
         ]
       }
     ],
     roles: [{ role: 'read', db: 'config' }]
   });

   db.createUser({
     user: 'agguser',
     pwd: '这里改为agguser用户的密码',
     roles: [
       { role: 'aggrole', db: 'admin' },
       { role: 'readWrite', db: 'mdaggregationwsrows' }
     ]
   });

2. 配置文件增加环境变量：ENV_MONGODB_URI_AGGREGATIONWSROWS（如果存在更多 options 参数，需拼接），重启服务即可，以单机模式 yaml 为例：

    services:
      app:
        image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-hap:7.3.4
        environment: &app-environment
          ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://agguser:******@sc:27017/mdaggregationwsrows?authSource=admin"

使用外置 MongoDB 未开启认证

配置文件增加环境变量：ENV_MONGODB_URI_AGGREGATIONWSROWS，重启服务即可，以单机模式 yaml 为例：

services:
  app:
  image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-hap:7.3.4
  environment: &app-environment
    ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://服务名或IP:27017/mdaggregationwsrows" 
    #多节点
    #ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://服务名或IP1:27017,服务名或IP2:27017,服务名或IP3:27017/mdaggregationwsrows" 

使用外置 MongoDB 开启认证

1. 使用 root 账号连接 admin 库，创建聚合表数据库角色和用户

   use admin;
   db.createRole({
     role: "aggrole",
     privileges: [
       {
         resource: { db: "", collection: "" },
         actions: [
           "splitVector",
           "listDatabases",
           "listCollections",
           "collStats",
           "find",
           "changeStream"
         ]
       }
     ],
     roles: [{ role: 'read', db: 'config' }]
   });

   db.createUser({
     user: 'agguser',
     pwd: '这里改为agguser用户的密码',
     roles: [
       { role: 'aggrole', db: 'admin' },
       { role: 'readWrite', db: 'mdaggregationwsrows' }
     ]
   });

2. 配置文件增加环境变量：ENV_MONGODB_URI_AGGREGATIONWSROWS（如果存在更多 options 参数，需拼接），重启服务即可，以单机模式 yaml 为例：

    services:
      app:
        image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-hap:7.3.4
        environment: &app-environment
          ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://agguser:******@服务名或IP:27017/mdaggregationwsrows?authSource=admin" 
          #多节点
          #ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://agguser:******@服务名或IP1:27017,服务名或IP2:27017,服务名或IP3:27017/mdaggregationwsrows?authSource=admin"