# 创建全实例只读账号use admindb.createUser({user: "username",pwd: "password",roles:[{role: "readAnyDatabase",db: "admin"}]})# 创建指定库只读账号use admindb.createUser({user: "username",pwd: "password",roles:[{role: "read",db: "指定库的库名"}]})
操作类型 | 支持的 SQL 操作 |
DML | INSERT、UPDATE、DELETE |
DDL | INDEX:createIndexes、createIndex、dropIndex、dropIndexes COLLECTION:createCollection、drop、collMod、renameCollection DATABASE:dropDatabase、copyDatabase |
参数名称 | 参数含义 | 配置方式 |
服务类型 | 选择数据传输服务的类型,本文介绍数据订阅服务。 | 选择数据订阅。 |
计费模式 | ||
地域 | 选择订阅服务所属的地域。 | 与待订阅的数据库实例所属地域保持一致。 |
数据库 | 选择数据订阅服务的数据库类型。 | 选择 MongoDB。 |
版本 | 支持通过 Kafka 客户端直接消费。 | 选择 Kafka 版。 |
标签 | 给数据订阅服务指定标签。 | 单击添加,在下拉列表选择标签键与标签值。 |
订阅实例名称 | 指定数据订阅服务名称设置的方式。 | 创建后命名:创建数据订阅服务之后,再设置名称。默认为 name-订阅 ID。订阅 ID 为系统随机分配。 立即命名:在下方输入框,直接设置数据订阅服务名称。 |
购买数量 | 选择购买服务的数量。 | 单次购买最多支持10个任务。 |
参数名称 | 参数含义 | 配置方式 |
订阅 ID / 名称 | 订阅任务的 ID 编号与名称。任务名称默认为 name-订阅 ID。 | 确认数据订阅的 ID 及名称即可。 |
实例类型 | 默认为 MongoDB。 | - |
所属地域 | 订阅服务所属的地域。 | 确认所属地域即可。 |
接入类型 | 选择源端数据库接入数据订阅服务的类型。 | 目前仅支持云数据库。指属于腾讯云数据库实例。 |
云数据库实例 | 选择数据订阅服务具体的 MongoDB 实例。 | 在下拉列表,选择具体的实例 ID。 |
账号 | 设置 MongoDB 实例的访问账号信息。 | 请在输入框输入准备的只读账号信息。 |
密码 | 设置 MongoDB 实例的访问账号对应的密码。 | 请在输入框输入只读账号对应的密码信息,不支持免密访问。 |
Kafka 分区数量 | 选择数据订阅任务对应的 Kafka 的分区数量。在 Kafka 中,消费者可以通过订阅一个或多个主题(Topic)来获取数据,然后从每个主题的一个或多个分区(Partition)中消费数据。 | 支持选择1、4、8。 单分区可以保障消息的顺序,多分区无法保障消息顺序,如果您对消费到消息的顺序有严格要求,请选择 kafka 分区数量为1。 增加分区数量可以提高 Kafka 集群的吞吐量和并行性,因为多个消费者可以同时消费不同的分区。但是,增加分区数量也会增加 Kafka 集群的管理和维护成本,并可能导致数据不均衡或延迟问题。 |
测试连通性 | 测试数据订阅服务与云数据库 MongoDB 实例的连通性。 | 单击测试连通性,等待测试连通性的结果。 如果测试未通过,请根据提示方法进行排查。可单击重新测试,重新进行连通性检查。测试通过才能进行下一步操作。 |
参数名称 | 参数含义 | 配置方式 |
订阅 ID / 名称 | 订阅任务的 ID 编号与名称。 | 确认订阅任务信息正确即可。 |
订阅实例 | 订阅的 MongoDB 数据库实例 ID。 | 确认实例信息正确即可。 |
订阅类型 | 指订阅者可以选择订阅的数据类型。 MongoDB 数据库,使用 Change Stream 特性监控变化的数据,实现数据订阅。 | 默认 Change Stream,不可修改。 |
订阅级别 | 订阅的数据级别,包括全实例、库和集合。 全实例:订阅全实例数据。 库:订阅库级别的数据,选择后,任务设置只允许选择一个库。 集合:订阅集合级别的数据,选择后,任务设置只允许选择一个集合。 | 可根据需要选择数据订阅的级别。不支持选择系统库:admin、local、config。 |
任务设置 | 当订阅级别为库或集合时,显示该参数,指定具体的库和集合。 | 在选择库表区域,勾选需要订阅的一个库或者一个集合。 在已选择区域,确认选择的库与集合是否正确。 |
输出聚合设置 | 该参数针对订阅的数据,配置是否开启聚合设置,再发送给订阅者。 | 开启:单击 ,开启聚合设置。单击添加,在聚合运算符的下拉列表中,选择运算符,然后在聚合表达式的输入框,输入表达式。单击添加,可以添加多条聚合表达式。聚合管道的执行顺序按照添加的聚合操作顺序执行。更多聚合管道信息及其使用示例,请参见 MongoDB 官网文档。 |
Kafka 分区策略 | 当上一步操作,Kafka 分区数量不为 1 时,需要设置分区策略。 按集合名分区:将源库的订阅数据按照集合名进行分区,相同集合名的数据会写入同一个 Kafka 分区中。 自定义分区策略:先通过正则表达式对订阅数据中的库名和集合名进行匹配,匹配到的数据再按照集合名分区、集合名 + objectid 分区。 | 选择自定义分区策略,单击下方自定义分区策略的添加,在库名匹配模式和表名匹配模式的输入框,以正则表达式的方式,分别设定需自定义分区策略的库名或表名的匹配方式,并在分区策略的下拉列表,选择按照集合名分区或按集合名 + objectid 分区。 开启自定义分区策略,将优先匹配自定义分区策略,其次匹配 Kafka 分区策略。 对于不满足上述自定义分区策略的库表,按照默认策略:“按集合名分区” 路由至 Kafka 分区。 |
自定义分区策略
| Kafka 分区策略选择自定义分区策略,显示该参数。设置自定义分区策略规则。 | |
策略组合结果 | Kafka 分区策略选择自定义分区策略,显示该参数。说明自定义分区策略的组合结果。 | |
本页内容是否解决了您的问题?