Message Queue for Apache RocketMQ events - - Alibaba Cloud Documentation Center

This topic describes the types of Message Queue for Apache 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 Message Queue for Apache 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 Message Queue for Apache 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.