All Products
Search
Document Center

:Message Queue for Apache RocketMQ events

Last Updated:Sep 04, 2024

This topic describes the types of ApsaraMQ for RocketMQ events that ActionTrail records or Cloud Config monitors and can be published to EventBridge as event sources.

Event types

The following table describes the types of ApsaraMQ for RocketMQ events that can be published to EventBridge.

Event

Value of the type parameter

Overrun QPS in an instance

ons:Instance:InstanceQpsThresholdExceeded

An instance is updated

ons:Instance:InstanceMinerVersionUpgradeScheduled

An instance update starts to be executed

ons:Instance:InstanceMinerVersionUpgradeExecuting

An instance update is completed

ons:Instance:InstanceMinerVersionUpgradeExecuted

An instance update is canceled

ons:Instance:InstanceMinerVersionUpgradeCanceled

An operation is performed on a resource

ons:ActionTrail:AliyunServiceEvent

An API operation is called

ons:ActionTrail:ApiCall

An operation is performed in the console

ons:ActionTrail:ConsoleOperation

A resource change log is delivered

ons:Config:ConfigurationItemChangeNotification

A notification that indicates a resource is evaluated as non-compliant is sent

ons:Config:NonCompliantNotification

For more information about the parameters defined in the CloudEvents specification, see Overview.

Overrun QPS in an instance

The following example shows the event that the EventBridge receives when the queries per second (QPS) of the instance exceeds the throttling threshold:

{
    "id": "45ef4dewdwe1-7c35-447a-bd93-fab****",
    "source": "acs.ons",
    "specversion": "1.0",
    "subject": "acs.ons:cn-hangzhou:123456789098****:215672",
    "time": "2020-11-19T21:04:41+08:00",
    "type": "ons:Instance:InstanceQpsThresholdExceeded",
    "aliyunaccountid": "123456789098****",
    "aliyunpublishtime": "2020-11-19T21:04:42.179PRC",
    "aliyuneventbusname": "default",
    "aliyunregionid": "cn-hangzhou",
    "aliyunpublishaddr": "172.25.XX.XX",
    "data": {
        "instanceId":"MQ_INST_gg****",
        "totalThrottleTimes":1300,
        "threshold":1000,
        "timestamp":1000000000000,
        "details":{
            "produceDetails":[
                {
                    "topic":"TRADE01",
                    "messageType":"normal|fifo|transaction|delay",
                    "throttleTimes":9999
                }
            ],
            "consumeDetails":[
                {
                    "topic":"TRADE01",
                    "consumerGroup":"GID-test",
                    "throttleTimes":100
                }
            ]
        }
    }
}
            

The following table describes the parameters contained in data.

Parameter

Type

Example

Description

instanceId

String

MQ_INST_gg****

The ID of the ApsaraMQ for RocketMQ instance.

totalThrottleTimes

Number

1300

The total number of throttling times.

threshold

Number

1000

The throttling threshold.

timestamp

Number

1000000000000

The timestamp.

details

Object

The throttling details.

produceDetails

Array

The throttling details of message sending.

topic

String

TRADE01

The topic that is throttled.

messageType

String

normal|fifo|transaction|delay

The type of the messages.

throttleTimes

Number

9999

The number of throttling times.

consumeDetails

Array

The throttling details of message consumption.

consumerGroup

String

GID-test

The ID of the consumer group.

An instance is updated

The following example shows the event data that is received by EventBridge when an instance is updated:

{
    "data":{
        "instanceId":"rmq-xxxxxxxx",
        "category":"maintenance",
        "level":"info",
        "details":{
          "destVersion":"5.0-rmq-20230324-1",
          "scheduleTime":"1678675586000",
          "scheduleLatestTime":"1678675586000",
          "upgradeType":"0",
          "taskId":"355****"
        }    
    },
    "id":"45ef4dewdwe1-7c35-447a-bd93-fab****",
    "source":"acs.ons",
    "specversion":"1.0",
    "subject":"acs:rocketmq:cn-hangzhou:138015630679******:instance/rmq-******",
    "time":"2020-11-19T21:04:41",
    "type":"ons:Instance:InstanceMinerVersionUpgradeScheduled",
    "aliyunaccountid":"138015630679****",
    "aliyunpublishtime":"2020-11-19T21:04:42.179",
    "aliyuneventbusname":"default",
    "aliyunregionid":"cn-hangzhou",
    "aliyunpublishaddr":"172.25.XX.XX"
}

The following table describes parameters contained in data.

Parameter

Type

Example

Description

instanceId

String

rmq-xxxxxxxx

The instance ID.

category

String

maintenance

The scenario. Valid values:

  • maintenance

  • client-status

level

String

info

The event level. Valid values:

  • critical

  • warning

  • info

details

Object

The event details.

destVersion

String

5.0-rmq-20230324-1

The desired version.

scheduleTime

String

1678675586000

The scheduled update time. Unit: milliseconds.

scheduleLatestTime

String

1678675586000

The latest update time. Unit: milliseconds.

upgradeType

String

0

The update type. Valid values:

  • 0: OPS update

  • 1: immediate update

  • 2: scheduled update

  • 3: update triggered by version expiration

taskId

String

355****

The ID of the update task.

An instance update starts to be executed

The following example shows the event data that is received by EventBridge when an instance update starts to be executed:

{
    "data":{
        "instanceId":"rmq-xxxxxxxx",
        "category":"maintenance",
        "level":"info",
        "details":{
          "originVersion":"5.0-rmq-20230324-1",
          "destVersion":"5.1-rmq-20230324-1",
          "scheduleTime":"1678675586000",
          "scheduleLatestTime":"1678675586000",
          "upgradeType":"0",
          "taskId":"355****"
        }    
    },
    "id":"45ef4dewdwe1-7c35-447a-bd93-fab****",
    "source":"acs.ons",
    "specversion":"1.0",
    "subject":"acs:rocketmq:cn-hangzhou:138015630679****:instance/rmq-cn-*****",
    "time":"2020-11-19T21:04:41",
    "type":"ons:Instance:InstanceMinerVersionUpgradeExecuting",
    "aliyunaccountid":"138015630679****",
    "aliyunpublishtime":"2020-11-19T21:04:42.179",
    "aliyuneventbusname":"default",
    "aliyunregionid":"cn-hangzhou",
    "aliyunpublishaddr":"172.25.XX.XX"
}

The following table describes parameters contained in data.

Parameter

Type

Example

Description

instanceId

String

rmq-xxxxxxxx

The instance ID.

category

String

maintenance

The scenario. Valid values:

  • maintenance

  • client-status

level

String

info

The event level. Valid values:

  • critical

  • warning

  • info

details

Object

The event details.

originVersion

String

5.0-rmq-20230324-1

The current version.

destVersion

String

5.1-rmq-20230324-1

The desired version.

scheduleTime

String

1678675586000

The scheduled execution time.

scheduleLatestTime

String

1678675586000

The latest execution time.

upgradeType

String

0

The update type. Valid values:

  • 0: OPS update

  • 1: immediate update

  • 2: scheduled update

  • 3: update triggered by version expiration

taskId

String

355****

The ID of the update task.

An instance update is completed

The following example shows the event that EventBridge receives when an instance update is completed:

{
    "data":{
        "instanceId":"rmq-xxxxxxxx",
        "category":"maintenance",
        "level":"info",
        "details":{
          "destVersion":"5.1.1-update1111",
          "scheduleTime":"1678675586000",
          "scheduleLatestTime":"1678675586000",
          "upgradeType":"",
          "taskId":""
        }    
    },
    "id":"45ef4dewdwe1-7c35-447a-bd93-fab****",
    "source":"acs.ons",
    "specversion":"1.0",
    "subject":"acs:rocketmq:cn-hangzhou:138015630679****:instance/rmq-******",
    "time":"2020-11-19T21:04:41",
    "type":"ons:Instance:InstanceMinerVersionUpgradeExecuted",
    "aliyunaccountid":"138015630679****",
    "aliyunpublishtime":"2020-11-19T21:04:42.179",
    "aliyuneventbusname":"default",
    "aliyunregionid":"cn-hangzhou",
    "aliyunpublishaddr":"172.25.XX.XX"
}

For information about the parameters contained in data, see the field description table.

An instance update is canceled

The following example shows the event that EventBridge receives when an instance update is canceled:

{
    "data":{
        "instanceId":"rmq-xxxxxxxx",
        "category":"maintenance",
        "level":"info",
        "details":{
          "destVersion":"5.1.1-update1111",
          "scheduleTime":"1111",
          "scheduleLatestTime":"22222",
          "upgradeType":"",
          "taskId":"",
          "cancelReason":""
        }    
    },
    "id":"45ef4dewdwe1-7c35-447a-bd93-fab****",
    "source":"acs.ons",
    "specversion":"1.0",
    "subject":"acs:rocketmq:cn-hangzhou:138015630679*****:instance/rmq-cn-wwo3******",
    "time":"2020-11-19T21:04:41",
    "type":"ons:Instance:InstanceMinerVersionUpgradeCanceled",
    "aliyunaccountid":"138015630679****",
    "aliyunpublishtime":"2020-11-19T21:04:42.179",
    "aliyuneventbusname":"default",
    "aliyunregionid":"cn-hangzhou",
    "aliyunpublishaddr":"172.25.XX.XX"
}

For information about the parameters contained in data, see the field description table.