访问控制(RAM)是阿里云提供的管理用户身份与资源访问权限的服务。使用 RAM 可以让您避免与其他用户共享阿里云账号密钥,并可按需为用户授予最小权限。RAM 中使用权限策略描述授权的具体内容。
本文为您介绍 云消息队列 Kafka 版 为 RAM 权限策略定义的操作(Action)、资源(Resource)和条件(Condition)。 云消息队列 Kafka 版 的 RAM 代码(RamCode)为 alikafka ,支持的授权粒度为 资源级 。
权限策略通用结构
权限策略支持 JSON 格式,其通用结构如下:
{
"Version": "1",
"Statement": [
{
"Effect": "<Effect>",
"Action": "<Action>",
"Resource": "<Resource>",
"Condition": {
"<Condition_operator>": {
"<Condition_key>": [
"<Condition_value>"
]
}
}
}
]
}
各字段含义如下:
Effect:权限策略效果。取值:Allow(允许)、Deny(拒绝)。
Action:授予允许或拒绝权限的具体操作。具体信息,请参见操作(Action)。
Resource:受操作影响的具体对象,您可以使用资源 ARN 来描述指定资源。具体信息,请参见资源(Resource)。
Condition:指授权生效的条件。可选字段。具体信息,请参见条件(Condition)。
Condition_operator:条件运算符,不同类型的条件对应不同的条件运算符。具体信息,请参见权限策略基本元素。
Condition_key:条件关键字。
Condition_value:条件关键字对应的值。
操作(Action)
下表是云消息队列 Kafka 版定义的操作,这些操作可以在 RAM 权限策略语句的Action
元素中使用,用来授予执行该操作的权限。下面对表中的具体项提供说明:
操作:是指具体的权限点。
API:是指操作对应的 API 接口。
访问级别:是指每个操作的访问级别,取值为写入(Write)、读取(Read)或列出(List)。
资源类型:是指操作中支持授权的资源类型。具体说明如下:
对于必选的资源类型,用前面加 * 表示。
对于不支持资源级授权的操作,用
全部资源
表示。
条件关键字:是指云产品自身定义的条件关键字。该列不体现适用于任何操作的通用条件关键字。
关联操作:是指成功执行操作所需要的其他权限。操作者必须同时具备关联操作的权限,操作才能成功。
操作 |
API |
访问级别 |
资源类型 |
条件关键字 |
关联操作 |
alikafka:DeleteAcl | DeleteAcl | delete |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:CreateTopic | CreateTopic | create |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListTopic | GetTopicOffset | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:CreatePostPayInstance | CreatePostPayInstance | create |
*全部资源
* |
alikafka:DeployModule
alikafka:SpecType
|
无 |
alikafka:DeleteTopic | DeleteTopic | delete |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateInstance | UpgradeInstanceVersion | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListTopic | GetTopicStatus | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ReportMigrationProcess | CheckInstanceQuota |
*全部资源
* |
无 | 无 | |
alikafka:CreateDeployment | CreateConnectorTask | create |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateInstance | DeleteScheduledScalingRule | delete |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ConvertPostPayOrder | ConvertPostPayOrder | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ReportMigrationProcess | SendMigrationHeartbeat | none |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListRisk | RiskList | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:QueryMessage | GetLastMessage | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListTagResources | ListTagResources | get |
*全部资源
* |
无 | 无 |
alikafka:UpdateInstance | UpdateAllowedIp | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateInstanceReopen | ReopenInstance | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateGroup | UpdateConsumerOffset | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ReleaseInstance | DeleteInstance | delete |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListTopic | GetQuotaTip | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListGroup | GetConsumerProgress | get |
*全部资源
* |
无 | 无 |
alikafka:ListInstance | GetAllowedIpList | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:GetMeta | GetMetaProductList | get |
*全部资源
* |
无 | 无 |
alikafka:CreatePrePayOrder | CreatePrePayOrder | create |
*全部资源
* |
alikafka:SpecType
alikafka:DeployModule
|
无 |
alikafka:ListInstance | GetAllInstanceIdList | get |
*全部资源
* |
无 | 无 |
alikafka:CreateGroup | CreateConsumerGroup | create |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:QueryMessage | QueryMessage | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ReleaseInstance | StopInstance | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListSaslUser | DescribeSaslUsers | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListGroup | GetConsumerList | get |
*全部资源
* |
无 | 无 |
alikafka:CreateAcl | CreateAcl | create |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:TagResources | TagResources | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpgradePostPayOrder | UpgradePostPayOrder | update |
*全部资源
* |
alikafka:DeployModule
|
无 |
alikafka:UpdateTopic | ModifyTopicRemark | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:StartInstance | StartInstance | update |
*全部资源
* |
alikafka:DeployModule
alikafka:SpecType
alikafka:Acl
alikafka:DiskEncryption
|
无 |
alikafka:UpdateDeploymentRemark | UpdateConnectorTaskRemark | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateInstance | UpdateInstanceConfig | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateInstanceUpdateAutoCreateGroupStatus | EnableAutoGroupCreation | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListInstance | DescribeNodeStatus | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ReleaseInstance | ReleaseInstance | update |
*全部资源
* |
无 | 无 |
alikafka:DeleteGroup | DeleteConsumerGroup | delete |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateTopic | ModifyPartitionNum | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ChangeResourceGroup | ChangeResourceGroup | update |
*全部资源
* |
无 | 无 |
alikafka:UntagResources | UntagResources | update |
*全部资源
* |
无 | 无 |
alikafka:CreateDeployment | GenerateConnectorTaskSystemResource | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateInstance | EnableAutoTopicCreation | update |
*全部资源
* |
无 | 无 |
alikafka:ListTopic | GetTopicList | get |
*全部资源
* |
无 | 无 |
alikafka:UpdateInstance | ModifyScheduledScalingRule | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListDeployments | ListConnectorTask | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:DeleteDeployment | DeleteConnectorTask | delete |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:DeleteSaslUser | DeleteSaslUser | delete |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpgradePrePayOrder | UpgradePrePayOrder | update |
*全部资源
* |
alikafka:DeployModule
|
无 |
alikafka:ListGroup | ListRebalanceInfo | get |
*全部资源
* |
无 | 无 |
alikafka:ListTopic | GetTopicSubscribeStatus | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:CreateDeployment | DeployConnectorTask | create |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListKafkaClientIp | GetKafkaClientIp | get |
*全部资源
* |
无 | 无 |
alikafka:UpdateInstance | CreateScheduledScalingRule | create |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:CreatePrePayInstance | CreatePrePayInstance | create |
*全部资源
* |
alikafka:SpecType
alikafka:DeployModule
|
无 |
alikafka:ListAcl | DescribeAcls | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:CreateSaslUser | CreateSaslUser | create |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListRisk | GetRiskList | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:CreatePostPayOrder | CreatePostPayOrder | create |
*全部资源
* |
alikafka:DeployModule
alikafka:SpecType
|
无 |
alikafka:ListInstance | GetAutoScalingConfiguration | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateInstance | ModifyInstanceName | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListInstance | GetInstanceList | get |
*全部资源
* |
无 | 无 |
alikafka:ListSaslUser | DescribeAclResourceName | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:UpdateTopic | UpdateTopicConfig | update |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
alikafka:ListTopic | TopicSubscribeStatus | get |
*Instance
acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
无 | 无 |
资源(Resource)
下表是云消息队列 Kafka 版定义的资源,这些资源可以在 RAM 权限策略语句的Resource
元素中使用,用来授予对该资源执行具体操作的权限。 其中,资源 ARN 是资源在阿里云上的唯一标识。具体说明如下:
{#}
为变量标识,需要您替换为实际值。例如:{#ramcode}
需要您替换为实际的云服务RAM代码。*
表示全部。例如:{#resourceType}
为*
时:表示全部资源。{#regionId}
为*
时:表示全部地域。{#accountId}
为*
时:表示全部阿里云账号。
资源类型 |
资源 ARN |
Instance | acs:alikafka:{#regionId}:{#accountId}:{#InstanceId} |
Instance | acs:alikafka:{#regionId}:{#accountId}:instance/* |
Instance | acs:alikafka:{#regionId}:{#accountId}:* |
ConsumerGroup | acs:alikafka:{#regionId}:{#accountId}:instance/{#InstanceId}/consumergroup/{#ConsumerGroupId} |
Instance | acs:alikafka:{#regionId}:{#accountId}:instance/{#InstanceId} |
Topic | acs:alikafka:{#regionId}:{#accountId}:instance/{#InstanceId}/topic/{#Topic} |
条件(Condition)
下表是云消息队列 Kafka 版 定义的产品级条件关键字,这些条件关键字可以在 RAM 权限策略语句的Condition
元素中使用,用来描述授予权限的条件。以下仅列举产品级的条件关键字,阿里云定义的通用条件关键字也同样适用云消息队列 Kafka 版。
其中,数据类型决定了您可以使用哪些条件运算符将请求中的值与权限策略语句中的值进行比较。您必须使用与数据类型匹配的条件运算符,否则无法匹配策略语句,授权行为无效。数据类型与条件运算符的对应关系,请参见条件操作类型。
条件关键字 |
描述 |
类型 |
alikafka:DeployModule | 部署模式 | String |
alikafka:SpecType | 实例规格 | String |
alikafka:Acl | 是否开启ACL | Boolean |
alikafka:DiskEncryption | 磁盘是否加密 | Boolean |
相关操作
您可以创建自定义权限策略,并将权限策略授予 RAM 用户、RAM 用户组或 RAM 角色。具体操作如下: