Message Queue for Apache RocketMQ イベント - - Alibaba Cloud ドキュメントセンター

このトピックでは、ActionTrail が記録または Cloud Config が監視し、EventBridge にイベントソースとして発行できる RocketMQ for ApsaraMQ イベントのタイプについて説明します。

イベントタイプ

次の表に、ApsaraMQ for RocketMQEventBridge に発行できるイベントのタイプを示します。

イベント	値種類パラメーター
インスタンスの QPS オーバーラン	ons:Instance:InstanceQpsThresholdExceeded
インスタンスが更新される	ons:Instance:InstanceMinerVersionUpgradeScheduled
インスタンスの更新の実行が開始される	ons:Instance:InstanceMinerVersionUpgradeExecuting
インスタンスの更新が完了する	ons:Instance:InstanceMinerVersionUpgradeExecuted
インスタンスの更新がキャンセルされる	ons:Instance:InstanceMinerVersionUpgradeCanceled
リソースに対して操作が実行される	ons:ActionTrail:AliyunServiceEvent
API 操作が呼び出される	ons:ActionTrail:ApiCall
コンソールで操作が実行される	ons:ActionTrail:ConsoleOperation
リソース変更ログが配信される	ons:Config:ConfigurationItemChangeNotification
リソースが非準拠と評価されたことを示す通知が送信される	ons:Config:NonCompliantNotification

CloudEvents 仕様で定義されているパラメーターの詳細については、「概要」をご参照ください。

インスタンスの QPS オーバーラン

インスタンスのクエリ/秒 ( QPS ) が調整のしきい値を超えたときに EventBridge が受信するイベントの例を以下に示します。

{
    "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", // コンシューマーグループ ID
                    "throttleTimes":100
                }
            ]
        }
    }
}

次の表に、data に含まれるパラメーターを示します。

パラメーター	タイプ	例	説明
instanceId	String	MQ_INST_gg****	RocketMQ for ApsaraMQ インスタンスの ID。
totalThrottleTimes	Number	1300	スロットリングの合計回数。
threshold	Number	1000	スロットリングのしきい値。
timestamp	Number	1000000000000	タイムスタンプ。
details	Object		スロットリングの詳細。
produceDetails	Array		メッセージ送信のスロットリングの詳細。
topic	String	TRADE01	スロットリングされるトピック。
messageType	String	normal\|fifo\|transaction\|delay	メッセージのタイプ。
throttleTimes	Number	9999	スロットリングの回数。
consumeDetails	Array		メッセージ消費のスロットリングの詳細。
consumerGroup	String	GID-test	コンシューマーグループの ID。

インスタンスが更新される

インスタンスが更新されたときに EventBridge によって受信されるイベントデータの例を以下に示します。

{
    "data":{
        "instanceId":"rmq-xxxxxxxx",
        "category":"maintenance",
        "level":"info",
        "details":{
          "destVersion":"5.0-rmq-20230324-1", // 目的のバージョン
          "scheduleTime":"1678675586000", // 予定されている更新時刻。単位：ミリ秒。
          "scheduleLatestTime":"1678675586000", // 最新の更新時刻。単位：ミリ秒。
          "upgradeType":"0", // 更新タイプ。有効な値：0：OPS 更新、1：即時更新、2：スケジュール更新、3：バージョン有効期限によってトリガーされる更新
          "taskId":"355****" // 更新タスクの ID
        }    
    },
    "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"
}

次の表に、data に含まれるパラメーターを示します。

パラメーター	タイプ	例	説明
instanceId	String	rmq-xxxxxxxx	インスタンス ID。
category	String	maintenance	シナリオ。有効な値： maintenance client-status
level	String	info	イベントレベル。有効な値： critical warning info
details	Object		イベントの詳細。
destVersion	String	5.0-rmq-20230324-1	目的のバージョン。
scheduleTime	String	1678675586000	スケジュールされた更新時刻。単位：ミリ秒。
scheduleLatestTime	String	1678675586000	最新の更新時刻。単位：ミリ秒。
upgradeType	String	0	更新タイプ。有効な値： 0: OPS 更新 1: 即時更新 2: スケジュール更新 3: バージョン有効期限によってトリガーされる更新
taskId	String	355****	更新タスクの ID。

インスタンスの更新の実行が開始される

インスタンスの更新の実行が開始されたときに EventBridge によって受信されるイベントデータの例を以下に示します。

{
    "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", // 更新タイプ。有効な値：0：OPS 更新、1：即時更新、2：スケジュール更新、3：バージョン有効期限によってトリガーされる更新
          "taskId":"355****" // 更新タスクの ID
        }    
    },
    "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"
}

次の表に、data に含まれるパラメーターを示します。

パラメーター	タイプ	例	説明
instanceId	String	rmq-xxxxxxxx	インスタンス ID。
category	String	maintenance	シナリオ。有効な値： maintenance client-status
level	String	info	イベントレベル。有効な値： critical warning info
details	Object		イベントの詳細。
originVersion	String	5.0-rmq-20230324-1	現在のバージョン。
destVersion	String	5.1-rmq-20230324-1	目的のバージョン。
scheduleTime	String	1678675586000	スケジュールされた実行時刻。
scheduleLatestTime	String	1678675586000	最新の実行時刻。
upgradeType	String	0	更新タイプ。有効な値： 0: OPS 更新 1: 即時更新 2: スケジュール更新 3: バージョン有効期限によってトリガーされる更新
taskId	String	355****	更新タスクの ID。

インスタンスの更新が完了する

インスタンスの更新が完了したときに EventBridge が受信するイベントの例を以下に示します。

{
    "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"
}

data に含まれるパラメーターについては、フィールドの説明表をご参照ください。

インスタンスの更新がキャンセルされる

インスタンスの更新がキャンセルされたときに EventBridge が受信するイベントの例を以下に示します。

{
    "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"
}

data に含まれるパラメーターについては、フィールドの説明表をご参照ください。