コンテンツにスキップ

Alibaba Cloud RocketMQ5

Alibaba Cloud RocketMQ 5.0 の表示メトリクスには、メッセージスループット、遅延、信頼性、水平スケーリング能力などが含まれます。

設定

Func のインストール

Guance の統合 - 拡張 - マネージド版 Func の利用を推奨します

Func を自前でデプロイする場合はFunc の自前デプロイを参照してください

スクリプトの有効化

ヒント: 要件を満たす Alibaba Cloud AK を事前に用意してください(簡便のため、グローバル読み取り専用権限 ReadOnlyAccess をそのまま付与してもかまいません)

マネージド版でスクリプトを有効化

  1. Guance コンソールにログインします
  2. [統合]メニューをクリックし、[クラウドアカウント管理]を選択します
  3. [クラウドアカウントを追加]をクリックし、[Alibaba Cloud]を選択して画面に必要な情報を入力します。すでにクラウドアカウント情報を設定済みの場合は、この手順を省略します
  4. [テスト]をクリックし、成功したら[保存]をクリックします。テストに失敗した場合は、関連する設定が正しいか確認してから再度テストしてください
  5. [クラウドアカウント管理]の一覧で追加済みのクラウドアカウントを確認できます。該当するクラウドアカウントをクリックして詳細ページに入ります
  6. クラウドアカウント詳細ページの[統合]ボタンをクリックし、未インストール リストから Alibaba Cloud RocketMQ5 を見つけて[インストール]ボタンをクリックすると、インストール画面が表示されます。あとはそのままインストールしてください

手動でスクリプトを有効化

  1. Func コンソールにログインし、[スクリプトマーケット]をクリックして Guance スクリプトマーケットに入り、integration_alibabacloud_rocketmq5 を検索します

  2. [インストール]をクリックし、対応するパラメーターとして Alibaba Cloud AK ID、AK Secret、およびアカウント名を入力します。

  3. [起動スクリプトをデプロイ]をクリックすると、システムが自動的に Startup スクリプトセットを作成し、対応する起動スクリプトを自動で設定します。

  4. 有効化後は、「管理 / 自動トリガー設定」で対応する自動トリガー設定を確認できます。[実行]をクリックすると、定期実行を待たずにただちに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}"
}

フィードバック

このページは役に立ちましたか?