分布式消息服务kafka版 kafka-j9九游会登录
云服务在iam预置了常用的权限，称为系统身份策略。如果iam系统身份策略无法满足授权要求，管理员可以根据各j9九游会登录的服务支持的授权项，创建iam自定义身份策略来进行精细的访问控制，iam自定义身份策略是对系统身份策略的扩展和补充。
除iam服务外，organizations服务中的服务控制策略（service control policy，以下简称scp）也可以使用这些授权项元素设置访问控制策略。
scp不直接进行授权，只划定权限边界。将scp绑定到组织单元或者成员账号时，并没有直接对组织单元或成员账号授予操作权限，而是规定了成员账号或组织单元包含的成员账号的授权范围。iam身份策略授予权限的有效性受scp限制，只有在scp允许范围内的权限才能生效。
iam服务与organizations服务在使用这些元素进行访问控制时，存在着一些区别，详情请参见：iam服务与organizations服务权限访问控制的区别。
本章节介绍iam服务身份策略授权场景中自定义身份策略和组织服务中scp使用的元素，这些元素包含了操作（action）、资源（resource）和条件（condition）。
操作（action）
操作（action）即为身份策略中支持的授权项。
- “访问级别”列描述如何对操作进行分类（list、read和write等）。此分类可帮助您了解在身份策略中相应操作对应的访问级别。
- “资源类型”列指每个操作是否支持资源级权限。
- 资源类型支持通配符号*表示所有。如果此列没有值（-），则必须在身份策略语句的resource元素中指定所有资源类型（“*”）。
- 如果该列包含资源类型，则必须在具有该操作的语句中指定该资源的urn。
- 资源类型列中必需资源在表中用星号（*）标识，表示使用此操作必须指定该资源类型。
关于dms for kafka定义的资源类型的详细信息请参见资源类型（resource）。
- “条件键”列包括了可以在身份策略语句的condition元素中支持指定的键值。
- 如果该授权项资源类型列存在值，则表示条件键仅对列举的资源类型生效。
- 如果该授权项资源类型列没有值（-），则表示条件键对整个授权项生效。
- 如果此列条件键没有值（-），表示此操作不支持指定条件键。
关于dms for kafka定义的条件键的详细信息请参见条件（condition）。
- “别名”列包括了可以在身份策略中配置的策略授权项。通过这些授权项，可以控制支持策略授权的api访问。详细信息请参见身份策略兼容性说明。
您可以在身份策略语句的action元素中指定以下dms for kafka的相关操作。
|
授权项 |
描述 |
访问级别 |
资源类型（*为必须） |
条件键 |
别名 |
|---|---|---|---|---|---|
|
dms:instance:connector |
授予开启实例smart connect功能的权限。 |
write |
kafka * |
- |
|
|
dms:instance:list |
授予查看实例列表的权限。 |
list |
kafka * |
- |
|
|
dms:instance:scale |
授予实例扩容权限。 |
write |
kafka * |
- |
|
|
dms:instance:listconnectorsinktask |
授予查看smart connect任务列表的权限。 |
list |
kafka * |
- |
|
|
dms:instance:getbackgroundtask |
授予查看实例后台任务详情权限。 |
read |
kafka |
- |
|
|
dms:instance:deletebackgroundtask |
授予删除实例后台任务的权限。 |
write |
kafka |
- |
|
|
dms:instance:create |
授予创建实例的权限。 |
write |
kafka * |
- |
|
|
dms:instance:update |
授予修改实例的权限。 |
write |
kafka * |
dms:instance:modify |
|
|
dms:instance:upgrade |
授予升级实例的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:instance:getdetail |
授予查看实例详情的权限。 |
read |
kafka * |
dms:instance:get |
|
|
dms:instance:closemanager |
授予关闭kafka manager的权限。 |
write |
kafka * |
- |
|
|
dms:instance:deleteconnectorsinktask |
授予删除smart connect任务的权限。 |
write |
kafka |
- |
|
|
dms:instance:modifyauthinfo |
授予修改实例访问密码的权限。 |
write |
kafka |
- |
|
|
dms:instance:modifystatus |
授予重启实例的权限。 |
write |
kafka |
- |
|
|
dms:instance:delete |
授予删除实例的权限。 |
write |
kafka * |
- |
|
|
dms:instance:getconnectorsinktask |
授予查看smart connect任务详情的权限。 |
read |
kafka |
- |
|
|
dms:instance:createconnectorsinktask |
授予创建smart connect任务的权限。 |
write |
kafka |
- |
|
|
dms:instance:updateconnectorsinktask |
授予更新smart connect任务的权限。 |
write |
kafka |
dms:instance:createconnectorsinktask |
|
|
dms:instance:resetauthinfo |
授予重置实例访问密码的权限。 |
write |
kafka |
- |
|
|
dms:message:get |
授予查询消息详情的权限。 |
read |
kafka |
dms:instance:get |
|
|
topic |
- |
||||
|
dms:message:send |
授予发送消息的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:topic:list |
授予获取主题列表的权限。 |
list |
kafka |
dms:instance:get |
|
|
topic * |
- |
||||
|
dms:topic:modify |
授予修改主题的权限。 |
write |
kafka |
dms:instance:modify |
|
|
topic * |
- |
||||
|
dms:topic:create |
授予创建主题的权限。 |
write |
kafka |
dms:instance:modify |
|
|
topic |
- |
||||
|
dms:instance:gettopicdiskusage |
授予查询主题磁盘使用率的权限。 |
read |
kafka |
- |
|
|
dms:topic:delete |
授予删除主题的权限。 |
write |
kafka |
dms:instance:modify |
|
|
topic * |
- |
||||
|
dms:topic:getaccesspolicy |
授予获取主题授权策略的权限。 |
read |
kafka |
dms:instance:get |
|
|
topic * |
- |
||||
|
dms:topic:autocreate |
授予开启或关闭自动创建主题的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:topic:get |
授予查询主题信息的权限。 |
read |
kafka |
dms:instance:get |
|
|
topic * |
- |
||||
|
dms:topic:updatereplica |
授予修改主题分区的副本的权限。 |
write |
kafka |
- |
|
|
topic * |
- |
||||
|
dms:topic:setaccesspolicy |
授予为主题设置访问策略的权限。 |
write |
kafka |
dms:instance:modify |
|
|
topic * |
- |
||||
|
dms:user:list |
授予获取实例用户列表的权限。 |
list |
kafka |
dms:instance:get |
|
|
dms:user:modify |
授予修改实例用户信息的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:user:delete |
授予删除实例用户的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:user:create |
授予新增实例用户的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:group:get |
授予获取消费组的详情的权限。 |
read |
kafka |
dms:instance:get |
|
|
consumergroup * |
- |
||||
|
dms:group:list |
授予获取消费组列表的权限。 |
list |
kafka |
dms:instance:get |
|
|
consumergroup * |
- |
||||
|
dms:group:modify |
授予修改消费组的权限。 |
write |
kafka |
dms:instance:modify |
|
|
consumergroup * |
- |
||||
|
dms:group:create |
授予创建消费组的权限。 |
write |
kafka |
dms:instance:modify |
|
|
consumergroup * |
- |
||||
|
dms:group:delete |
授予删除消费组的权限。 |
write |
kafka |
dms:instance:modify |
|
|
consumergroup * |
- |
||||
|
dms:coordinator:list |
授予获取实例的协调器列表的权限。 |
list |
kafka |
- |
|
|
dms:instance:reassigntopic |
授予topic分区平衡的权限。 |
write |
kafka * |
- |
|
|
dms::updaterecyclepolicy |
授予更新回收站策略的权限。 |
write |
- |
- |
dms:instance:modify |
|
dms:instance:restore |
授予恢复实例的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:instance:deletescheduledtask |
授予删除实例定时任务的权限。 |
write |
kafka |
dms:instance:modify |
|
|
rabbitmq |
|||||
|
rocketmq |
|||||
|
dms:instance:modifyscheduledtask |
授予修改实例定时任务的权限。 |
write |
kafka |
dms:instance:modify |
|
|
rabbitmq |
|||||
|
rocketmq |
|||||
|
dms:instance:listscheduledtasks |
授予获取实例定时任务列表的权限。 |
list |
kafka |
dms:instance:get |
|
|
rabbitmq |
|||||
|
rocketmq |
|||||
|
dms:instance:updateconnectortask |
授予更新smart connect任务的权限。 |
write |
kafka |
dms:instance:createconnectorsinktask |
|
|
dms:instance:modifysslswitch |
授予修改实例ssl开关的权限。 |
write |
kafka |
dms:instance:modify |
|
|
rabbitmq |
|||||
|
rocketmq |
|||||
|
dms:instance:listdiagnosisreport |
授予查询实例诊断报告列表的权限。 |
list |
rocketmq * |
dms:instance:get |
|
|
dms:topic:deletequota |
授予删除topic限流配额的权限。 |
write |
kafka |
dms:instance:modify |
|
|
topic * |
- |
||||
|
dms:topic:setquota |
授予设置topic限流配额的权限。 |
write |
kafka |
dms:instance:modify |
|
|
topic * |
- |
||||
|
dms:topic:modifyquota |
授予修改topic限流配额的权限。 |
write |
kafka |
dms:instance:modify |
|
|
topic * |
- |
||||
|
dms:instance:gettopicquotas |
授予获取实例topic限流配额的权限。 |
read |
kafka |
dms:instance:get |
|
|
dms:instance:getdiagnosisreport |
授予查询实例诊断报告的权限。 |
read |
rocketmq * |
dms:instance:get |
|
|
dms:instance:disablelog |
授予停用实例日志收集功能的权限。 |
write |
kafka |
dms:instance:modify |
|
|
rabbitmq |
|||||
|
dms:instance:getloginfo |
授予查询实例日志收集信息的权限。 |
read |
kafka |
dms:instance:get |
|
|
rabbitmq |
|||||
|
dms:instance:enablelog |
授予启用实例日志收集功能的权限。 |
write |
kafka |
dms:instance:modify |
|
|
rabbitmq |
|||||
|
dms:instance:deletediagnosisreport |
授予删除实例诊断报告的权限。 |
write |
rocketmq * |
dms:instance:get |
|
|
dms:instance:getclientquota |
授予获取客户端限流配额的权限。 |
read |
kafka |
dms:instance:get |
|
|
dms:instance:setclientquota |
授予设置客户端限流配额的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:instance:modifyclientquota |
授予修改客户端限流配额的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:instance:deleteclientquota |
授予删除客户端限流配额的权限。 |
write |
kafka |
dms:instance:modify |
|
|
dms:instance:creatediagnosistask |
授予创建实例诊断任务的权限。 |
write |
rocketmq * |
dms:instance:get |
|
|
dms:group:deleteconsumeoffset |
授予删除消费者组的消费进度的权限。 |
write |
kafka |
dms:instance:modify |
|
|
consumergroup * |
- |
||||
|
dms:connector:validate |
授予校验connector连通性的权限。 |
write |
kafka * |
dms:instance:connector |
dms for kafka的api通常对应着一个或多个授权项。表2展示了api与授权项的关系，以及该api需要依赖的授权项。
|
api |
对应的授权项 |
依赖的授权项 |
|---|---|---|
|
get /v2/{project_id}/instances/{instance_id}/messages |
dms:message:get |
- |
|
post /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/messages/delete |
dms:message:delete |
- |
|
put /v2/{project_id}/instances/{instance_id}/kafka-manager-password |
dms:instance:modifyauthinfo |
- |
|
put /v2/{project_id}/instances/{instance_id}/restart-kafka-manager |
dms:instance:modifystatus |
- |
|
delete /v2/{project_id}/kafka/instances/{instance_id}/management |
dms:instance:closemanager |
- |
|
post /v2/{project_id}/instances/action |
dms:instance:delete |
- |
|
get /v2/{project_id}/instances |
dms:instance:list |
- |
|
post /v2/{project_id}/kafka/instances/{instance_id}/extend |
dms:instance:scale |
- |
|
get /v2/{project_id}/kafka/instances/{instance_id}/extend |
dms:instance:getdetail |
- |
|
post /v2/{project_id}/instances/{instance_id}/connector |
dms:instance:connector |
|
|
get /v2/{project_id}/instances/{instance_id} |
dms:instance:getdetail |
|
|
put /v2/{project_id}/instances/{instance_id} |
dms:instance:update |
|
|
post /v2/{project_id}/kafka/instances/{instance_id}/upgrade |
dms:instance:upgrade |
- |
|
delete /v2/{project_id}/instances/{instance_id} |
dms:instance:delete |
- |
|
post /v2/{project_id}/instances/{instance_id}/connector/tasks |
dms:instance:createconnectorsinktask |
dms:instance:createconnectortask |
|
get /v2/{project_id}/instances/{instance_id}/connector/tasks |
dms:instance:listconnectorsinktask |
dms:instance:listconnectortasks |
|
put /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/pause |
dms:instance:updateconnectorsinktask |
- |
|
put /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}/resume |
dms:instance:updateconnectorsinktask |
- |
|
get /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} |
dms:instance:getconnectorsinktask |
dms:instance:getconnectortask |
|
delete /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} |
dms:instance:deleteconnectorsinktask |
dms:instance:deleteconnectortask |
|
post /v2/{project_id}/instances/{instance_id}/password |
dms:instance:resetauthinfo |
- |
|
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 |
- |
|
get /v2/{project_id}/instances/{instance_id}/topics |
dms:topic:list |
- |
|
put /v2/{project_id}/instances/{instance_id}/topics |
dms:topic:modify |
- |
|
post /v2/{project_id}/instances/{instance_id}/topics |
dms:topic:create |
- |
|
get /v2/{project_id}/instances/{instance_id}/topics/diskusage |
dms:instance:gettopicdiskusage |
- |
|
post /v2/{project_id}/instances/{instance_id}/topics/delete |
dms:topic:delete |
- |
|
post /v2/{project_id}/instances/{instance_id}/crossvpc/modify |
dms:instance:update |
- |
|
get /v2/{project_id}/instances/{instance_id}/users |
dms:user:list |
- |
|
put /v2/{project_id}/instances/{instance_id}/users |
dms:user:delete |
- |
|
post /v2/{project_id}/instances/{instance_id}/users |
dms:user:create |
- |
|
put /v2/{project_id}/instances/{instance_id}/users/{user_name} |
dms:user:modify |
- |
|
post /v2/{project_id}/instances/{instance_id}/autotopic |
dms:topic:autocreate |
- |
|
get /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions/{partition}/beginning-message |
dms:message:get |
- |
|
get /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions/{partition}/end-message |
dms:message:get |
- |
|
get /v2/{project_id}/instances/{instance_id}/management/cluster |
dms:instance:getdetail |
- |
|
get /v2/{project_id}/instances/{instance_id}/management/groups/{group} |
dms:group:get |
- |
|
get /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/partitions/{partition}/message |
dms:message:get |
- |
|
get /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/messages |
dms:message:get |
- |
|
get /v2/{project_id}/instances/{instance_id}/management/coordinators |
dms:coordinator:list |
- |
|
get /v2/{project_id}/instances/{instance_id}/groups |
dms:group:list |
- |
|
post /v2/{project_id}/kafka/instances |
dms:instance:create |
|
|
get /v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy |
dms:topic:getaccesspolicy |
- |
|
post /v1/{project_id}/instances/{instance_id}/topics/accesspolicy |
dms:topic:setaccesspolicy |
- |
|
get /v2/{project_id}/instances/{instance_id}/ces-hierarchy |
dms:instance:getdetail |
- |
|
get /v2/{project_id}/kafka/{instance_id}/tags |
dms::listprojecttags |
- |
|
get /v2/{project_id}/kafka/tags |
dms::listprojecttags |
- |
|
post /v2/{project_id}/kafka/{instance_id}/tags/action |
dms:instance:update |
- |
|
post /v2/{project_id}/kafka/instances/{instance_id}/reassign |
dms:instance:reassigntopic |
- |
|
post /v2/{project_id}/instances/{instance_id}/groups/batch-delete |
dms:group:delete |
- |
|
post /v2/{project_id}/kafka/instances/{instance_id}/group |
dms:group:create |
- |
|
put /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group} |
dms:group:modify |
- |
|
post /v2/{project_id}/kafka/instances/{instance_id}/delete-connector |
dms:instance:connector |
- |
|
post /v2/{project_id}/instances/{instance_id}/messages/action |
dms:message:send |
- |
|
get /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/partitions |
dms:topic:get |
- |
|
get /v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers |
dms:topic:get |
- |
|
put /v2/{engine}/{project_id}/instances/{instance_id}/users/{user_name} |
dms:user:modify |
- |
|
post /v2/{project_id}/recycle |
dms:instance:restore |
- |
|
put /v2/{project_id}/recycle |
dms::updaterecyclepolicy |
- |
|
post /v2/{project_id}/instances/{instance_id}/connector/validate |
dms:connector:validate |
- |
|
post /v2/kafka/{project_id}/instances/{instance_id}/groups/{group}/delete-offset |
dms:group:deleteconsumeoffset |
- |
|
post /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks |
dms:instance:creatediagnosistask |
- |
|
delete /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota |
dms:instance:deleteclientquota |
- |
|
post /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota |
dms:instance:setclientquota |
- |
|
put /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota |
dms:instance:modifyclientquota |
- |
|
get /v2/kafka/{project_id}/instances/{instance_id}/kafka-user-client-quota |
dms:instance:getclientquota |
- |
|
delete /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks |
dms:instance:deletediagnosisreport |
- |
|
get /v2/{project_id}/instances/{instance_id}/scheduled-tasks |
dms:instance:listscheduledtasks |
- |
|
put /v2/{project_id}/instances/{instance_id}/scheduled-tasks/{task_id} |
dms:instance:modifyscheduledtask |
- |
|
delete /v2/{project_id}/instances/{instance_id}/scheduled-tasks/{task_id} |
dms:instance:deletescheduledtask |
- |
|
get /v2/kafka/{project_id}/instances/{instance_id}/log/rebalance-log |
dms:instance:getloginfo |
- |
|
post /v2/kafka/{project_id}/instances/{instance_id}/log/rebalance-log |
dms:instance:enablelog |
- |
|
delete /v2/kafka/{project_id}/instances/{instance_id}/log/rebalance-log |
dms:instance:disablelog |
- |
|
get /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis/{report_id} |
dms:instance:getdiagnosisreport |
- |
|
get /v2/kafka/{project_id}/instances/{instance_id}/kafka-topic-quota |
dms:instance:gettopicquotas |
- |
|
put /v2/kafka/{project_id}/instances/{instance_id}/kafka-topic-quota |
dms:topic:modifyquota |
- |
|
post /v2/kafka/{project_id}/instances/{instance_id}/kafka-topic-quota |
dms:topic:setquota |
- |
|
delete /v2/kafka/{project_id}/instances/{instance_id}/kafka-topic-quota |
dms:topic:deletequota |
- |
|
get /v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks |
dms:instance:listdiagnosisreport |
- |
|
get /v2/{project_id}/instances/{instance_id}/configs |
dms:instance:getdetail |
- |
|
post /v2/{project_id}/{engine}/instances/{instance_id}/plain-ssl-switch |
dms:instance:modifysslswitch |
- |
|
put /v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id} |
dms:instance:updateconnectortask |
- |
资源类型（resource）
资源类型（resource）表示身份策略所作用的资源。如表3中的某些操作指定了可以在该操作指定的资源类型，则必须在具有该操作的身份策略语句中指定该资源的urn，身份策略仅作用于此资源；如未指定，resource默认为“*”，则身份策略将应用到所有资源。您也可以在身份策略中设置条件，从而指定资源类型。
dms for kafka定义了以下可以在自定义身份策略的resource元素中使用的资源类型。
|
资源类型 |
urn |
|---|---|
|
kafka |
dms: |
|
topic |
dms: |
|
rabbitmq |
dms: |
|
consumergroup |
dms: |
|
rocketmq |
dms: |
条件（condition）
条件键概述
条件（condition）是身份策略生效的特定条件，包括条件键和运算符。
- 条件键表示身份策略语句的condition元素中的键值。根据适用范围，分为全局级条件键和服务级条件键。
- 全局级条件键（前缀为g:）适用于所有操作，在鉴权过程中，云服务不需要提供用户身份信息，系统将自动获取并鉴权。详情请参见：全局条件键。
- 服务级条件键（前缀通常为服务缩写，如dms:）仅适用于对应服务的操作，详情请参见表4。
- 单值/多值表示api调用时请求中与条件关联的值数。单值条件键在api调用时的请求中最多包含一个值，多值条件键在api调用时请求可以包含多个值。例如：g:sourcevpce是单值条件键，表示仅允许通过某个vpc终端节点发起请求访问某资源，一个请求最多包含一个vpc终端节点id值。g:tagkeys是多值条件键，表示请求中携带的所有标签的key组成的列表，当用户在调用api请求时传入标签可以传入多个值。
- 运算符与条件键、条件值一起构成完整的条件判断语句，当请求信息满足该条件时，身份策略才能生效。支持的运算符请参见：运算符。
dms for kafka支持的服务级条件键
dms for kafka定义了以下可以在自定义身份策略的condition元素中使用的条件键，您可以使用这些条件键进一步细化身份策略语句应用的条件。
|
服务级条件键 |
类型 |
单值/多值 |
说明 |
|---|---|---|---|
|
dms:ssl |
boolean |
单值 |
根据实例是否开启ssl筛选访问权限。 |
|
dms:publicip |
boolean |
单值 |
根据实例是否开启公网访问筛选访问权限。 |
|
dms:connector |
boolean |
单值 |
根据实例是否开启smart connect功能筛选访问权限。 |
相关文档
意见反馈
文档内容是否对您有帮助？
如您有其它疑问，您也可以通过华为云社区问答频道来与我们联系探讨
