Alibaba Cloud RocketMQ5¶
Alibaba Cloud RocketMQ 5.0 の表示メトリクスには、メッセージスループット、遅延、信頼性、水平スケーリング能力などが含まれます。
設定¶
Func のインストール¶
Guance の統合 - 拡張 - マネージド版 Func の利用を推奨します
Func を自前でデプロイする場合はFunc の自前デプロイを参照してください
スクリプトの有効化¶
ヒント: 要件を満たす Alibaba Cloud AK を事前に用意してください(簡便のため、グローバル読み取り専用権限
ReadOnlyAccessをそのまま付与してもかまいません)
マネージド版でスクリプトを有効化¶
- Guance コンソールにログインします
- [統合]メニューをクリックし、[クラウドアカウント管理]を選択します
- [クラウドアカウントを追加]をクリックし、[Alibaba Cloud]を選択して画面に必要な情報を入力します。すでにクラウドアカウント情報を設定済みの場合は、この手順を省略します
- [テスト]をクリックし、成功したら[保存]をクリックします。テストに失敗した場合は、関連する設定が正しいか確認してから再度テストしてください
- [クラウドアカウント管理]の一覧で追加済みのクラウドアカウントを確認できます。該当するクラウドアカウントをクリックして詳細ページに入ります
- クラウドアカウント詳細ページの[統合]ボタンをクリックし、
未インストールリストからAlibaba Cloud RocketMQ5を見つけて[インストール]ボタンをクリックすると、インストール画面が表示されます。あとはそのままインストールしてください
手動でスクリプトを有効化¶
-
Func コンソールにログインし、[スクリプトマーケット]をクリックして Guance スクリプトマーケットに入り、
integration_alibabacloud_rocketmq5を検索します -
[インストール]をクリックし、対応するパラメーターとして Alibaba Cloud AK ID、AK Secret、およびアカウント名を入力します。
-
[起動スクリプトをデプロイ]をクリックすると、システムが自動的に
Startupスクリプトセットを作成し、対応する起動スクリプトを自動で設定します。 -
有効化後は、「管理 / 自動トリガー設定」で対応する自動トリガー設定を確認できます。[実行]をクリックすると、定期実行を待たずにただちに1回実行できます。しばらくすると、実行タスクの記録と対応するログを確認できます。
メトリクス¶
| メトリクス名 | メトリクスカテゴリ | 説明 | ディメンション | 統計 | 単位 | 最小周期 |
|---|---|---|---|---|---|---|
ConsumerLag |
rocketmq | メッセージの滞留量(Group) | userId,instanceId,groupId | Sum | count | 60 s |
ConsumerLagLatencyPerGid |
rocketmq | メッセージ処理遅延時間(GroupId) | userId,instanceId,groupId | Maximum | milliseconds | 60 s |
ConsumerLagLatencyPerGidTopic |
rocketmq | メッセージ処理遅延時間(GroupId&Topic) | userId,instanceId,topic,groupId | Maximum | milliseconds | 60 s |
ConsumerLagPerGidTopic |
rocketmq | メッセージの滞留量(Group&Topic) | userId,instanceId,groupId,topic | Sum | count | 60 s |
InstanceApiCallTps |
rocketmq | インスタンスの API 呼び出し頻度(Instance) | userId,instanceId | Sum | countSecond | 60 s |
InstanceInternetFlowoutBandwidth |
rocketmq | 5.0 系列インスタンスのパブリック下りトラフィック帯域 | userId,instanceId | Sum | bytes/Second | 60 s |
InstanceReceiveApiCallTps |
rocketmq | 5.0 系列インスタンスの受信 API 呼び出し TPS ピーク値 | userId,instanceId | Maximum | countSecond | 60 s |
InstanceSendApiCallTps |
rocketmq | 5.0 系列インスタンスの送信 API 呼び出し TPS ピーク値 | userId,instanceId | Maximum | countSecond | 60 s |
InstanceStorageSize |
rocketmq | 5.0 系列インスタンスのストレージサイズ | userId,instanceId | Sum | Bytes | 60 s |
ReadyMessageQueueTime |
rocketmq | 準備完了メッセージのキュー待ち時間(Group) | userId,instanceId,groupId | Maximum | milliseconds | 60 s |
ReadyMessageQueueTimePerGidTopic |
rocketmq | 準備完了メッセージのキュー待ち時間(Group&Topic) | userId,instanceId,groupId,topic | Maximum | milliseconds | 60 s |
ReadyMessages |
rocketmq | 準備完了メッセージ数(Group) | userId,instanceId,groupId | Sum | count | 60 s |
ReadyMessagesPerGidTopic |
rocketmq | 準備完了メッセージ数(Group&Topic) | userId,instanceId,groupId,topic | Sum | count | 60 s |
ReceiveMessageCountPerGid |
rocketmq | コンシューマーが 1 分あたりに受信するメッセージ数(Group) | userId,instanceId,groupId | Sum | count/min | 60 s |
ReceiveMessageCountPerGidTopic |
rocketmq | コンシューマーが 1 分あたりに受信するメッセージ数(Group&Topic) | userId,instanceId,topic,groupId | Sum | count/min | 60 s |
ReceiveMessageCountPerInstance |
rocketmq | コンシューマーが 1 分あたりに受信するメッセージ数(Instance) | userId,instanceId | Sum | count/min | 60 s |
ReceiveMessageCountPerTopic |
rocketmq | コンシューマーが 1 分あたりに受信するメッセージ数(Topic) | userId,instanceId,topic | Sum | count/min | 60 s |
SendDLQMessageCountPerGid |
rocketmq | 1 分あたりに生成されるデッドレターキュー・メッセージ数(Group) | userId,instanceId,groupId | Sum | count/min | 60 s |
SendDLQMessageCountPerGidTopic |
rocketmq | 1 分あたりに生成されるデッドレターキュー・メッセージ数(Group&Topic) | userId,instanceId,groupId,topic | Sum | count/min | 60 s |
SendMessageCountPerInstance |
rocketmq | プロデューサーが 1 分あたりに送信するメッセージ数(Instance) | userId,instanceId | Sum | count/min | 60 s |
SendMessageCountPerTopic |
rocketmq | プロデューサーが 1 分あたりに送信するメッセージ数(Topic) | userId,instanceId,topic | Sum | count/min | 60 s |
ThrottledReceiveRequestsPerGid |
rocketmq | 1 分あたりの(GroupId)受信レート制限回数 | userId,instanceId,groupId | Sum | counts/min | 60 s |
ThrottledReceiveRequestsPerGidTopic |
rocketmq | 1 分あたりの(GroupId&Topic)受信レート制限回数 | userId,instanceId,topic,groupId | Sum | counts/min | 60 s |
ThrottledReceiveRequestsPerInstance |
rocketmq | 1 分あたりの(Instance)受信レート制限回数 | userId,instanceId | Sum | counts/min | 60 s |
ThrottledSendRequestsPerInstance |
rocketmq | 1 分あたりの(Instance)送信レート制限回数 | userId,instanceId | Sum | counts/min | 60 s |
ThrottledSendRequestsPerTopic |
rocketmq | 1 分あたりの(Topic)送信レート制限回数 | userId,instanceId,topic | Sum | counts/min | 60 s |
オブジェクト¶
収集された Alibaba Cloud RocketMQ5 のオブジェクトデータ構造は、「インフラストラクチャー - カスタム」で確認できます
{
"serviceCode": "rmq",
"__namespace": "custom_object",
"createTime": "2023-08-21 10:54:25",
"expireTime": "2123-08-22 00:00:00",
"time": 1692600804692,
"topicCount": "1",
"userId": "1067807587588864",
"__docid": "CO_d3bed3ab447566645796455f37fcb66c",
"message": "{\"accountInfo\": {\"username\": \"If02i2f3f4nYtUsA\"}, \"aclInfo\": {\"aclType\": \"default\"}, \"bid\": \"26842\", \"commodityCode\": \"ons_rmqpost_public_cn\", \"createTime\": \"2023-08-21 10:54:25\", \"expireTime\": \"2123-08-22 00:00:00\", \"extConfig\": {\"aclType\": \"default\", \"autoScaling\": false, \"flowOutBandwidth\": 1, \"flowOutType\": \"payByBandwidth\", \"internetSpec\": \"enable\", \"messageRetentionTime\": 72, \"msgProcessSpec\": \"rmq.s1.micro\", \"sendReceiveRatio\": 0.5, \"supportAutoScaling\": false}, \"groupCount\": 1, \"instanceId\": \"rmq-cn-wwo3cwoyn0b\", \"instanceName\": \"rmq-cn-wwo3cwoyn0b\", \"instanceQuotas\": [{\"quotaName\": \"MAX_TPS\", \"totalCount\": 500}, {\"quotaName\": \"SCALING_TPS_MAX\", \"totalCount\": 0}, {\"quotaName\": \"STORAGE_SIZE\", \"usedCount\": 0.109}, {\"quotaName\": \"TOPIC_COUNT\", \"totalCount\": 100, \"usedCount\": 1}, {\"quotaName\": \"CONSUMER_GROUP_COUNT\", \"totalCount\": 1000, \"usedCount\": 1}], \"networkInfo\": {\"endpoints\": [{\"endpointType\": \"TCP_VPC\", \"endpointUrl\": \"rmq-cn-wwo3cwoyn0b-vpc.cn-hangzhou.rmq.aliyuncs.com:8080\"}, {\"endpointType\": \"TCP_INTERNET\", \"endpointUrl\": \"rmq-cn-wwo3cwoyn0b.cn-hangzhou.rmq.aliyuncs.com:8080\"}], \"internetInfo\": {\"flowOutBandwidth\": 1, \"flowOutType\": \"payByBandwidth\", \"internetSpec\": \"enable\"}, \"vpcInfo\": {\"vSwitchId\": \"vsw-bp1qzepqz845moheet831\", \"vpcId\": \"vpc-bp1pftfpllxna4t75e73v\"}}, \"paymentType\": \"PayAsYouGo\", \"productInfo\": {\"autoScaling\": false, \"messageRetentionTime\": 72, \"msgProcessSpec\": \"rmq.s1.micro\", \"sendReceiveRatio\": 0.5, \"supportAutoScaling\": false}, \"regionId\": \"cn-hangzhou\", \"releaseTime\": \"2123-08-29 00:00:00\", \"resourceGroupId\": \"rg-acfmv3ro3xnfwaa\", \"seriesCode\": \"standard\", \"serviceCode\": \"rmq\", \"software\": {\"maintainTime\": \"02:00-06:00\", \"softwareVersion\": \"5.0-rmq-20230818-2\"}, \"startTime\": \"2023-08-21 10:54:24\", \"status\": \"RUNNING\", \"subSeriesCode\": \"single_node\", \"tags\": [{\"key\": \"acs:rm:rgId\", \"value\": \"rg-acfmv3ro3xnfwaa\"}], \"topicCount\": 1, \"updateTime\": \"2023-08-21 10:57:31\", \"userId\": \"1067807587588864\"}",
"paymentType": "PayAsYouGo",
"regionId": "cn-hangzhou",
"startTime": "2023-08-21 10:54:24",
"accountInfo": "{\"username\": \"If02i2f3f4nYtUsA\"}",
"class": "aliyun_rocketmq",
"instanceQuotas": "[{\"quotaName\": \"MAX_TPS\", \"totalCount\": 500}, {\"quotaName\": \"SCALING_TPS_MAX\", \"totalCount\": 0}, {\"quotaName\": \"STORAGE_SIZE\", \"usedCount\": 0.109}, {\"quotaName\": \"TOPIC_COUNT\", \"totalCount\": 100, \"usedCount\": 1}, {\"quotaName\": \"CONSUMER_GROUP_COUNT\", \"totalCount\": 1000, \"usedCount\": 1}]",
"releaseTime": "2123-08-29 00:00:00",
"create_time": 1692600804719,
"groupCount": "1",
"networkInfo": "{\"endpoints\": [{\"endpointType\": \"TCP_VPC\", \"endpointUrl\": \"rmq-cn-wwo3cwoyn0b-vpc.cn-hangzhou.rmq.aliyuncs.com:8080\"}, {\"endpointType\": \"TCP_INTERNET\", \"endpointUrl\": \"rmq-cn-wwo3cwoyn0b.cn-hangzhou.rmq.aliyuncs.com:8080\"}], \"internetInfo\": {\"flowOutBandwidth\": 1, \"flowOutType\": \"payByBandwidth\", \"internetSpec\": \"enable\"}, \"vpcInfo\": {\"vSwitchId\": \"vsw-bp1qzepqz845moheet831\", \"vpcId\": \"vpc-bp1pftfpllxna4t75e73v\"}}",
"instanceName": "rmq-cn-wwo3cwoyn0b",
"resourceGroupId": "rg-acfmv3ro3xnfwaa",
"commodityCode": "ons_rmqpost_public_cn",
"seriesCode": "standard",
"subSeriesCode": "single_node",
"status": "RUNNING",
"updateTime": "2023-08-21 10:57:31",
"account_name": "xxxxx",
"bid": "26842",
"date": 1692600804000,
"name": "rmq-cn-wwo3cwoyn0b",
"cloud_provider": "aliyun",
"date_ns": 0,
"instanceId": "rmq-cn-wwo3cwoyn0b",
"productInfo": "{\"autoScaling\": false, \"messageRetentionTime\": 72, \"msgProcessSpec\": \"rmq.s1.micro\", \"sendReceiveRatio\": 0.5, \"supportAutoScaling\": false}"
}