如何启用聚合表功能
聚合表功能(v5.6.0+)使用了
Flink
的 MongoDB CDC
连接器作为功能依赖组件,需要满足以下条件方可正常使用- 部署数据集成服务,参考:如何启用数据集成功能
- MongoDB 需要升级到 4.4+,参考:单机模式 MongoDB 升级到 4.4 或 集群模式 MongoDB 升级到 4.4
- MongoDB 需要调整为副本集模式(已是副本集可忽略),参考:MongoDB 单节点转换为副本集
- 使用内置 MongoDB 未开启认证
- 使用内置 MongoDB 开启认证
- 使用外置 MongoDB 未开启认证
- 使用外置 MongoDB 开启认证
内置 MongoDB 指 mingdaoyun-sc:3.0.0 镜像包含的 MongoDB 组件
满足基础条件后,不需要其他配置即可使用聚合表功能。👏 👏 👏
内置 MongoDB 指 mingdaoyun-sc:3.0.0 镜像包含的 MongoDB 组件
-
使用 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' }
]
}); -
配置文件增加环境变量:
ENV_MONGODB_URI_AGGREGATIONWSROWS
(如果存在更多 options 参数,需拼接),重启服务即可,以单机模式 yaml 为例:services:
app:
image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-community:5.7.0
environment: &app-environment
ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://agguser:******@sc:27017/mdaggregationwsrows?authSource=admin"
配置文件增加环境变量:ENV_MONGODB_URI_AGGREGATIONWSROWS
,重启服务即可,以单机模式 yaml 为例:
services:
app:
image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-community:5.7.0
environment: &app-environment
ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://服务名或IP:27017/mdaggregationwsrows"
#多节点
#ENV_MONGODB_URI_AGGREGATIONWSROWS: "mongodb://服务名或IP1:27017,服务名或IP2:27017,服务名或IP3:27017/mdaggregationwsrows"
-
使用 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' }
]
}); -
配置文件增加环境变量:
ENV_MONGODB_URI_AGGREGATIONWSROWS
(如果存在更多 options 参数,需拼接),重启服务即可,以单机模式 yaml 为例:services:
app:
image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-community:5.7.0
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"