如何启用聚合表功能
聚合表功能(v5.6.0+)使用了
Flink
的 MongoDB CDC
连接器作为功能依赖组件,需要满足以下条件方可正常使用- 部署数据 集成服务,参考:如何启用数据集成功能
- MongoDB 需要升级到 4.4+,参考:单机模式 MongoDB 升级到 4.4 或 集群模式 MongoDB 升级到 4.4
- MongoDB 需要调整为副本集模式(已是副本集可忽略),参考:MongoDB 单节点转换为副本集
- 使用内置 MongoDB 未开启认证
- 使用内置 MongoDB 开启认证
- 使用外置 MongoDB 未开启认证
- 使用外置 MongoDB 开启认证
内置 MongoDB 指 hap-sc:3.0.0 镜像包含的 MongoDB 组件
满足基础条件后,不需要其他配置即可使用聚合表功能。👏 👏 👏
内置 MongoDB 指 hap-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' }
]
});