策略授权参考
本章节介绍DMS for Kafka策略授权场景下支持的策略授权项。
支持的授权项
策略包含系统策略和自定义策略,如果系统策略不满足授权要求,管理员可以创建自定义策略,并通过给用户组授予自定义策略来进行精细的访问控制。策略支持的操作与API相对应,授权项列表说明如下:
- 权限:允许或拒绝对指定资源在特定条件下进行某项操作。
- 对应API接口:自定义策略实际调用的API接口。
- 授权项:自定义策略中支持的Action,在自定义策略中的Action中写入授权项,可以实现授权项对应的权限功能。
- 依赖的授权项:部分Action存在对其他Action的依赖,需要将依赖的Action同时写入授权项,才能实现对应的权限功能。
- IAM项目(Project)/企业项目(Enterprise Project):自定义策略的授权范围,包括IAM项目与企业项目。授权范围如果同时支持IAM项目和企业项目,表示此授权项对应的自定义策略,可以在IAM和企业管理两个服务中给用户组授权并生效。如果仅支持IAM项目,不支持企业项目,表示仅能在IAM中给用户组授权并生效,如果在企业管理中授权,则该自定义策略不生效。管理员可以在授权项列表中查看授权项是否支持IAM项目或企业项目,“√”表示支持,“×”表示暂不支持。关于IAM项目与企业项目的区别,详情请参见:IAM与企业管理的区别。
DMS for Kafka的支持自定义策略授权项如下所示:
- 生命周期管理,包含Kafka实例所有生命周期接口对应的授权项,如创建实例、查询实例列表、修改实例信息、批量重启或删除实例等接口。
- 实例管理,包括Kafka实例管理接口对应的授权项,如重置密码、开启或关闭实例自动创建Topic功能等接口。
- Smart Connect,包括Smart Connect接口对应的授权项,如开启Smart Connect、关闭Smart Connect、创建Smart Connect任务等接口。
- 规格变更管理,包括实例规格变更管理接口对应的授权项,如实例规格变更接口。
- 主题管理,包括Topic管理接口对应的授权项,如创建Topic、查询Topic、修改Topic等接口。
- 用户管理,包括用户管理接口对应的授权项,如创建用户、查询用户列表、设置用户权限等接口。
- 消息查询,包括消息查询接口对应的授权项,如查询消息接口。
- 后台任务管理,包括实例的后台任务管理接口对应的授权项,如查询实例的后台任务列表、查询后台任务管理中的指定记录等接口。
- 标签管理,包括实例的标签管理接口对应的授权项,如查询实例标签、查询项目标签等接口。
生命周期管理
权限 | 对应API接口 | 授权项(Action) | IAM项目 (Project) | 企业项目 (Enterprise Project) |
|---|---|---|---|---|
创建实例 | POST /v2/{project_id}/kafka/instances | dms:instance:create | √ | √ |
查询所有实例列表 | GET /v2/{project_id}/instances | dms:instance:list | √ | √ |
查询指定实例 | GET /v2/{project_id}/instances/{instance_id} | dms:instance:get | √ | √ |
删除指定的实例 | DELETE /v2/{project_id}/instances/{instance_id} | dms:instance:delete | √ | √ |
修改实例信息 | PUT /v2/{project_id}/instances/{instance_id} | dms:instance:modify | √ | √ |
批量重启或删除实例 | POST /v2/{project_id}/instances/action | 重启:dms:instance:modifyStatus 删除:dms:instance:delete | √ | √ |
实例管理
权限 | 对应API接口 | 授权项(Action) | IAM项目 (Project) | 企业项目 (Enterprise Project) |
|---|---|---|---|---|
重置密码 | POST /v2/{project_id}/instances/{instance_id}/password | dms:instance:resetAuthInfo | √ | √ |
重置Manager密码 | PUT /v2/{project_id}/instances/{instance_id}/kafka-manager-password | dms:instance:resetAuthInfo | √ | √ |
重启Manager | PUT /v2/{project_id}/instances/{instance_id}/restart-kafka-manager | dms:instance:modifyStatus | √ | √ |
开启或关闭实例自动创建topic功能 | POST /v2/{project_id}/instances/{instance_id}/autotopic | dms:instance:modify | √ | √ |
修改实例跨VPC访问的内网IP | POST /v2/{project_id}/instances/{instance_id}/crossvpc/modify | dms:instance:modify | √ | √ |
重置消费组消费进度到指定位置 | POST /v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset | dms:instance:modify | √ | √ |
Smart Connect
权限 | 对应API接口 | 授权项 | IAM项目(Project) | 企业项目(Enterprise Project) |
|---|---|---|---|---|
开启Smart Connect | POST /v2/{project_id}/instances/{instance_id}/connector | dms:instance:connector | √ | √ |
关闭Smart Connect | POST /v2/{project_id}/kafka/instances/{instance_id}/delete-connector | dms:instance:connector | √ | √ |
创建Smart Connect任务 | POST /v2/{project_id}/instances/{instance_id}/connector/tasks | dms:instance:createConnectorSinkTask | √ | √ |
查询Smart Connect任务列表 | GET /v2/{project_id}/instances/{instance_id}/connector/tasks | dms:instance:listConnectorSinkTask | √ | √ |
查询Smart Connector任务详情 | GET /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} | dms:instance:getConnectorSinkTask | √ | √ |
删除Smart Connector任务 | DELETE /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} | dms:instance:deleteConnectorSinkTask | √ | √ |
暂停Smart Connect任务 | PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause | dms:instance:updateConnectorTask | √ | √ |
启动已暂停的Smart Connect任务 | PUT /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume | dms:instance:updateConnectorTask | √ | √ |
启动未启动的Smart Connect任务/重启已暂停或者运行中的Smart Connect任务 | PUT /v2/{project_id}/kafka/instances/{instance_id}/connector/tasks/{task_id}/restart | dms:instance:updateConnectorTask | √ | √ |
规格变更管理
权限 | 对应API接口 | 授权项 | IAM项目(Project) | 企业项目(Enterprise Project) |
|---|---|---|---|---|
实例规格变更 | POST /v2/{project_id}/kafka/instances/{instance_id}/extend | dms:instance:scale | √ | √ |
主题管理
权限 | 对应API接口 | 授权项 | IAM项目(Project) | 企业项目(Enterprise Project) |
|---|---|---|---|---|
Kafka实例创建Topic | POST /v2/{project_id}/instances/{instance_id}/topics | dms:instance:modify | √ | √ |
Kafka实例查询Topic | GET /v2/{project_id}/instances/{instance_id}/topics | dms:instance:get | √ | √ |
修改Kafka实例Topic | PUT /v2/{project_id}/instances/{instance_id}/topics | dms:instance:modify | √ | √ |
Kafka实例批量删除Topic | POST /v2/{project_id}/instances/{instance_id}/topics/delete | dms:instance:modify | √ | √ |
用户管理
权限 | 对应API接口 | 授权项 | IAM项目(Project) | 企业项目(Enterprise Project) |
|---|---|---|---|---|
查询用户列表 | GET /v2/{project_id}/instances/{instance_id}/users | dms:instance:get | √ | √ |
创建用户 | POST /v2/{project_id}/instances/{instance_id}/users | dms:instance:modify | √ | √ |
批量删除用户 | PUT /v2/{project_id}/instances/{instance_id}/users | dms:instance:modify | √ | √ |
重置用户密码 | PUT /v2/{project_id}/instances/{instance_id}/users/{user_name} | dms:instance:get | √ | √ |
查询用户权限 | GET /v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy | dms:instance:get | √ | √ |
设置用户权限 | POST /v1/{project_id}/instances/{instance_id}/topics/accesspolicy | dms:instance:modify | √ | √ |
消息查询
权限 | 对应API接口 | 授权项 | IAM项目(Project) | 企业项目(Enterprise Project) |
|---|---|---|---|---|
查询消息 | GET /v2/{project_id}/instances/{instance_id}/messages | dms:instance:get | √ | √ |
后台任务管理
权限 | 对应API接口 | 授权项 | IAM项目(Project) | 企业项目(Enterprise Project) |
|---|---|---|---|---|
查询实例的后台任务列表 | GET /v2/{project_id}/instances/{instance_id}/tasks | dms:instance:getBackgroundTask | √ | √ |
查询后台任务管理中的指定记录 | GET /v2/{project_id}/instances/{instance_id}/tasks/{task_id} | dms:instance:getBackgroundTask | √ | √ |
删除后台任务管理中的指定记录 | DELETE /v2/{project_id}/instances/{instance_id}/tasks/{task_id} | dms:instance:deleteBackgroundTask | √ | √ |
标签管理
权限 | 对应API接口 | 授权项 | IAM项目(Project) | 企业项目(Enterprise Project) |
|---|---|---|---|---|
批量添加或删除实例标签 | POST /v2/{project_id}/kafka/{instance_id}/tags/action | dms:instance:modify | √ | √ |
查询实例标签 | GET /v2/{project_id}/kafka/{instance_id}/tags | dms:instance:get | √ | √ |
查询项目标签 | GET /v2/{project_id}/kafka/tags | dms:instance:get | √ | √ |
表10展示了DMS for Kafka细粒度权限的相关依赖。
权限名称 | 权限描述 | 权限依赖 |
|---|---|---|
dms:instance:list | 查看实例列表 | 无 |
dms:instance:get | 查看实例详情信息 | 无 |
dms:instance:create | 创建实例 |
|
dms:instance:getBackgroundTask | 查看实例后台任务详情 | 无 |
dms:instance:deleteBackgroundTask | 删除实例后台任务 | 无 |
dms:instance:modifyStatus | 重启实例 | 无 |
dms:instance:resetAuthInfo | 重置实例访问密码 | 无 |
dms:instance:modifyAuthInfo | 修改实例访问密码 | 无 |
dms:instance:modify | 修改实例 |
|
dms:instance:scale | 实例开启扩容功能 |
|
dms:instance:delete | 删除实例 | 无 |
dms:instance:connector | 实例开启转储功能 |
|
dms:instance:createConnectorSinkTask | 创建转储任务 | 无 |
dms:instance:getConnectorSinkTask | 查看转储任务详情 | 无 |
dms:instance:listConnectorSinkTask | 查看转储任务列表 | 无 |
dms:instance:deleteConnectorSinkTask | 删除转储任务 | 无 |

