Updated on 2025-08-05 GMT+08:00

Distributed Message Service for RocketMQ

The Organizations service provides Service Control Policies (SCPs) to set access control policies.

SCPs do not actually grant any permissions to a principal. They only set the permissions boundary for the principal. When SCPs are attached to a member account or an organizational unit (OU), they do not directly grant permissions to that member account or OU. Instead, the SCPs just determine what permissions are available for that member account or the member accounts under that OU.

This section describes the elements used by Organizations SCPs. The elements include actions, resources, and conditions.

For details about how to use these elements to create a custom SCP, see Creating an SCP.

Actions

Actions are specific operations that are allowed or denied in an SCP.

  • The Access Level column describes how the action is classified (List, Read, or Write). This classification helps you understand the level of access that an action grants when you use it in an SCP.
  • The Resource Type column indicates whether the action supports resource-level permissions.
    • You can use a wildcard (*) to indicate all resource types. If this column is empty (-), the action does not support resource-level permissions, and you must specify all resources ("*") in your SCP statements.
    • If this column includes a resource type, you must specify the URN in the Resource element of your statements.
    • Required resources are marked with asterisks (*) in the table. If you specify a resource in a statement using this action, then it must be of this type.

    For details about the resource types defined by DMS for RocketMQ, see Resources.

  • The Condition Key column includes keys that you can specify in the Condition element of an SCP statement.
    • If the Resource Type column has values for an action, the condition key takes effect only for the listed resource types.
    • If the Resource Type column is empty (-) for an action, the condition key takes effect for all resources that action supports.
    • If the Condition Key column is empty (-) for an action, the action does not support any condition keys.

    For details about the condition keys defined by DMS for RocketMQ, see Conditions.

The following table lists the actions that you can define in SCP statements for DMS for RocketMQ.

Table 1 Actions supported by DMS for RocketMQ

Action

Description

Access Level

Resource Type (*: required)

Condition Key

dms:instance:list

View the instance list.

list

rocketmq *

g:EnterpriseProjectId

dms:instance:create

Create an instance.

write

rocketmq *

  • g:RequestTag/<tag-key>
  • g:TagKeys
  • g:EnterpriseProjectId
  • dms:ssl
  • dms:publicIp

dms:instance:update

Modify an instance.

write

rocketmq *

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId
  • g:RequestTag/<tag-key>
  • g:TagKeys

dms:instance:getDetail

View the instance details.

read

rocketmq *

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:instance:modifyConfig

Modify instance configurations.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:instance:delete

Delete an instance.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:message:export

Export the message list.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic

-

dms:message:get

Query message details.

read

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic

-

dms:message:getTrace

Query the message trace.

read

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:message:send

Send messages.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:topic:list

Obtain the topic list.

list

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic *

-

dms:topic:modify

Modify a topic.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic *

-

dms:topic:create

Create a topic.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic

-

dms:topic:delete

Delete a topic.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic *

-

dms:topic:getAccessPolicy

Obtain topic permissions.

read

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic *

-

dms:topic:get

Query topic details.

read

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

topic *

-

dms:user:list

Obtain the instance user list.

list

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:user:get

Obtain instance user details.

read

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:user:modify

Modify instance user details.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:user:delete

Delete instance users.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:user:create

Create instance users.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:group:get

Obtain consumer group details.

read

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

consumerGroup *

-

dms:group:getAccessPolicy

Obtain consumer group access policies.

read

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

consumerGroup *

-

dms:group:resetConsumeOffset

Reset the consumer group offset.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

consumerGroup *

-

dms:group:list

Obtain the consumer group list.

list

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

consumerGroup *

-

dms:group:modify

Modify a consumer group.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

consumerGroup *

-

dms:group:create

Create a consumer group.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

consumerGroup *

-

dms:group:delete

Delete a consumer group.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

consumerGroup *

-

dms:broker:list

Obtain the instance broker list.

list

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:instance:createMetadataMigrationTask

Create an instance metadata migration task.

write

rocketmq *

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:instance:listMetadataMigrationTasks

Query the list of instance metadata migration tasks.

write

rocketmq *

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:instance:deleteMetadataMigrationTask

Delete an instance metadata migration task.

write

rocketmq *

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

dms:instance:resendDlqMsg

Resend dead letter messages.

write

rocketmq

  • g:ResourceTag/<tag-key>
  • g:EnterpriseProjectId

Each API of DMS for RocketMQ usually supports one or more actions. Table 2 lists the supported actions and dependencies.

Table 2 Actions and dependencies supported by DMS for RocketMQ APIs

API

Action

Dependencies

GET /v2/{engine}/{project_id}/instances/{instance_id}/messages

dms:message:get

-

POST /v2/{project_id}/instances/{instance_id}/messages/export

dms:message:export

-

POST /v2/{project_id}/instances/action

dms:instance:delete

-

GET /v2/{project_id}/instances

dms:instance:list

-

GET /v2/{project_id}/instances/{instance_id}

dms:instance:getDetail

  • vpc:vpcs:get
  • vpc:ports:get
  • vpc:securityGroups:get
  • vpc:subnets:get
  • eip:publicIps:get

PUT /v2/{project_id}/instances/{instance_id}

dms:instance:update

  • vpc:vpcs:get
  • vpc:subnets:get
  • eip:publicIps:get
  • eip:publicIps:update
  • vpc:ports:get
  • vpc:securityGroups:get
  • vpc:securityGroups:update

DELETE /v2/{project_id}/instances/{instance_id}

dms:instance:delete

-

GET /v2/{engine}/{project_id}/instances/{instance_id}/trace

dms:message:getTrace

-

GET /v2/{project_id}/instances/{instance_id}/topics

dms:topic:list

-

POST /v2/{project_id}/instances/{instance_id}/topics

dms:topic:create

dms:topic:delete

GET /v2/{project_id}/instances/{instance_id}/users

dms:user:list

-

POST /v2/{project_id}/instances/{instance_id}/users

dms:user:create

-

GET /v2/{project_id}/instances/{instance_id}/users/{user_name}

dms:user:get

-

DELETE /v2/{project_id}/instances/{instance_id}/users/{user_name}

dms:user:delete

-

PUT /v2/{project_id}/instances/{instance_id}/users/{user_name}

dms:user:modify

-

GET /v2/{project_id}/instances/{instance_id}/topics/{topic}/accesspolicy

dms:topic:getAccessPolicy

-

GET /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group_id}/accesspolicy

dms:group:getAccessPolicy

-

GET /v2/{project_id}/instances/{instance_id}/topics/{topic}/status

dms:topic:get

-

GET /v2/{project_id}/instances/{instance_id}/topics/{topic}/groups

dms:topic:get

-

GET /v2/{project_id}/instances/{instance_id}/groups/{group}/topics

dms:group:get

-

POST /v2/{engine}/{project_id}/instances/{instance_id}/groups/{group_id}/reset-message-offset

dms:group:resetConsumeOffset

-

GET /v2/{project_id}/instances/{instance_id}/brokers

dms:broker:list

-

GET /v2/{project_id}/instances/{instance_id}/groups

dms:group:list

-

PUT /v2/{project_id}/instances/{instance_id}/groups

dms:group:modify

-

POST /v2/{project_id}/instances/{instance_id}/groups

dms:group:create

dms:group:delete

GET /v2/{project_id}/instances/{instance_id}/groups/{group}

dms:group:get

-

PUT /v2/{project_id}/instances/{instance_id}/groups/{group}

dms:group:modify

-

DELETE /v2/{project_id}/instances/{instance_id}/groups/{group}

dms:group:delete

-

GET /v2/{project_id}/instances/{instance_id}/topics/{topic}

dms:topic:get

-

PUT /v2/{project_id}/instances/{instance_id}/topics/{topic}

dms:topic:modify

-

DELETE /v2/{project_id}/instances/{instance_id}/topics/{topic}

dms:topic:delete

-

POST /v2/{engine}/{project_id}/instances

dms:instance:create

  • vpc:vpcs:get
  • vpc:vpcs:list
  • vpc:ports:get
  • vpc:ports:create
  • vpc:ports:update
  • vpc:ports:delete
  • vpc:securityGroups:get
  • vpc:subnets:get
  • eip:publicIps:get
  • eip:publicIps:list
  • eip:publicIps:update

POST /v2/{project_id}/rocketmq/{instance_id}/tags/action

dms:instance:update

-

GET /v2/{project_id}/rocketmq/{instance_id}/tags

dms:instance:getDetail

-

GET /v2/{project_id}/rocketmq/tags

dms:instance:getDetail

-

GET /v2/rocketmq/{project_id}/instances/{instance_id}/groups/{group}/clients

dms:group:get

-

POST /v2/{engine}/{project_id}/instances/{instance_id}/messages/deadletter-resend

dms:instance:resendDlqMsg

-

POST /v2/{engine}/{project_id}/instances/{instance_id}/messages/resend

dms:message:send

-

POST /v2/{project_id}/instances/{instance_id}/metadata

dms:instance:createMetadataMigrationTask

-

GET /v2/{project_id}/instances/{instance_id}/metadata

dms:instance:listMetadataMigrationTasks

-

DELETE /v2/{project_id}/instances/{instance_id}/metadata

dms:instance:deleteMetadataMigrationTask

-

GET /v2/{project_id}/rocketmq/instances/{instance_id}/configs

dms:instance:getDetail

-

PUT /v2/{project_id}/rocketmq/instances/{instance_id}/configs

dms:instance:modifyConfig

-

Resources

A resource type indicates the resources that an SCP applies to. If you specify a resource type for any action in Table 3, the resource URN must be specified in the SCP statements using that action, and the SCP applies only to resources of this type. If no resource type is specified, the Resource element is marked with an asterisk (*) and the SCP applies to all resources. You can also set condition keys in an SCP to define resource types.

The following table lists the resource types that you can define in SCP statements for DMS for RocketMQ.

Table 3 Resource types supported by DMS for RocketMQ

Resource Type

URN

topic

dms:<region>:<account-id>:topic:<instance-id>/<topic-name>

consumerGroup

dms:<region>:<account-id>:consumerGroup:<instance-id>/<consumerGroup-name>

rocketmq

dms:<region>:<account-id>:rocketmq:<instance-id>

Conditions

A Condition element lets you specify conditions for when an SCP is in effect. It contains condition keys and operators.

  • The condition key that you specify can be a global condition key or a service-specific condition key.
    • Global condition keys (with the g: prefix) apply to all actions. Cloud services do not need to provide user identity information. Instead, the system automatically obtains such information and authenticates users. For details, see Global Condition Keys.
    • Service-specific condition keys (with the abbreviation of a service name plus a colon as the prefix, for example, dms:) apply only to operations of the service. For details, see Table 4.
    • The number of values associated with a condition key in the request context of an API call makes the condition key single-valued or multivalued. Single-valued condition keys have at most one value in the request context of an API call. Multivalued condition keys can have multiple values in the request context of an API call. For example, a request can originate from at most one VPC endpoint, so g:SourceVpce is a single-valued condition key. You can tag resources and include multiple tag key-value pairs in a request, so g:TagKeys is a multivalued condition key.
  • A condition operator, condition key, and a condition value together constitute a complete condition statement. An SCP can be applied only when its request conditions are met. For supported condition operators, see Condition operators.

The following table lists the condition keys that you can define in custom SCPs for DMS for RocketMQ. You can include these condition keys to specify conditions for when your SCP is in effect.

Table 4 Service-specific condition keys supported by DMS for RocketMQ

Service-specific Condition Key

Type

Single-valued/Multivalued

Description

dms:ssl

boolean

Single-valued

Filter instance permissions by SSL enablement.

dms:publicIp

boolean

Single-valued

Filter instance permissions by public access enablement.