Alibaba Cloud RocketMQ4¶
The displayed metrics of Alibaba Cloud RocketMQ 4.0 include message throughput, latency, reliability, and horizontal scalability.
Configuration¶
Install Func¶
It is recommended to activate the TrueWatch integration - extension - DataFlux Func (Automata)
If you want to deploy Func yourself, refer to Deploy Func Yourself
Activate Script¶
Note: Please prepare the Alibaba Cloud AK that meets the requirements in advance (for simplicity, you can directly grant the global read-only permission
ReadOnlyAccess
)
Activate Script for Automata¶
- Log in to the TrueWatch console
- Click the 【Integration】 menu, and select 【Cloud Account Management】
- Click 【Add Cloud Account】, select 【Alibaba Cloud】, and fill in the required information on the interface. If you have already configured the cloud account information before, ignore this step
- Click 【Test】, and click 【Save】 after the test is successful. If the test fails, please check whether the relevant configuration information is correct and test again
- Click 【Cloud Account Management】 list to see the added cloud account, click the corresponding cloud account to enter the details page
- Click the 【Integration】 button on the cloud account details page, find
Alibaba Cloud RocketMQ4
under theNot Installed
list, and click the 【Install】 button to pop up the installation interface for installation.
Manually Activate Script¶
-
Log in to the Func console, click 【Script Market】, enter the TrueWatch script market, and search:
integration_alibabacloud_rocketmq4
-
Click 【Install】, then enter the corresponding parameters: Alibaba Cloud AK ID, AK Secret, and account name.
-
Click 【Deploy Startup Script】, the system will automatically create the
Startup
script set and automatically configure the corresponding startup script. -
After enabling, you can see the corresponding automatic trigger configuration in 「Management / Automatic Trigger Configuration」. Click 【Execute】 to execute it immediately without waiting for the scheduled time. After a while, you can check the execution task records and corresponding logs.
Verification¶
- Confirm whether the corresponding task has the corresponding automatic trigger configuration in 「Management / Automatic Trigger Configuration」, and check the corresponding task records and logs to see if there are any exceptions
- In TrueWatch, check whether there is asset information in 「Infrastructure / Custom」
- In TrueWatch, check whether there is corresponding monitoring data in 「Metrics」
Metrics¶
Metric Id | Metric Name | Dimensions | Statistics | Uni |
---|---|---|---|---|
ReadyMessages | Ready Messages (Group) | account_name,InstanceName | Average,Maximum | count |
ReadyMessagesPerGidTopic | Ready Messages (Group&Topic) | account_name,InstanceName | Average,Maximum | count |
ReceiveMessageCountPerGid | Messages Received per Minute by Consumer (Group) | account_name,InstanceName | Average,Maximum | count/min |
ReceiveMessageCountPerGidTopic | Messages Received per Minute by Consumer (Group&Topic) | account_name,InstanceName | Average,Maximum | count/min |
ReceiveMessageCountPerInstance | Messages Received per Minute by Consumer (Instance) | account_name,InstanceName | Average,Maximum | count/min |
ReceiveMessageCountPerTopic | Messages Received per Minute by Consumer (Topic) | account_name,InstanceName | Average,Maximum | count/min |
SendDLQMessageCountPerGid | Dead Letter Messages Generated per Minute (Group) | account_name,InstanceName | Average,Maximum | count/min |
SendDLQMessageCountPerGidTopic | Dead Letter Messages Generated per Minute (Group&Topic) | account_name,InstanceName | Average,Maximum | count/min |
SendMessageCountPerInstance | Messages Sent per Minute by Producer (Instance) | account_name,InstanceName | Average,Maximum | count/min |
SendMessageCountPerTopic | Messages Sent per Minute by Producer (Topic) | account_name,InstanceName | Average,Maximum | count/min |
ThrottledReceiveRequestsPerGid | Throttled Receive Requests per Minute (GroupId) | account_name,InstanceName | Average,Maximum | counts/min |
ThrottledReceiveRequestsPerGidTopic | Throttled Receive Requests per Minute (GroupId&Topic) | account_name,InstanceName | Average,Maximum | counts/min |
ThrottledReceiveRequestsPerInstance | Throttled Receive Requests per Minute (Instance) | account_name,InstanceName | Average,Maximum | counts/min |
ThrottledSendRequestsPerInstance | Throttled Send Requests per Minute (Instance) | account_name,InstanceName | Average,Maximum | counts/min |
ThrottledSendRequestsPerTopic | Throttled Send Requests per Minute (Topic) | account_name,InstanceName | Average,Maximum | counts/min |
Object¶
The collected object data structure of Alibaba Cloud RocketMQ4 can be seen in 「Infrastructure - Custom」
{
"Endpoints": "{\"HttpInternalEndpoint\": \"http://xxx.mqrest.cn-hangzhou-internal.aliyuncs.com\", \"HttpInternetEndpoint\": \"http://xxx.mqrest.cn-hangzhou.aliyuncs.com\", \"HttpInternetSecureEndpoint\": \"\", \"TcpEndpoint\": \"http://MQ_INST_xxx.cn-hangzhou.mq-vpc.aliyuncs.com:8080\", \"TcpInternetEndpoint\": \"http://MQ_INST_xxx.cn-hangzhou.mq.aliyuncs.com:80\"}",
"Remark": "xxx",
"time": 1692250532822,
"IndependentNaming": "True",
"InstanceId": "MQ_INST_xxx",
"InstanceName": "xxx",
"InstanceStatus": "5",
"__namespace": "custom_object",
"account_name": "Aliyun",
"cloud_provider": "aliyun",
"date_ns": 0,
"name": "MQ_INST_xxx",
"spInstanceType": "1",
"CreateTime": "1692163416000",
"class": "aliyun_rocketmq",
"create_time": 1692250533041,
"date": 1692250532000,
"message": "{\"CreateTime\": 1692163416000, \"Endpoints\": {\"HttpInternalEndpoint\": \"http://xxx.mqrest.cn-hangzhou-internal.aliyuncs.com\", \"HttpInternetEndpoint\": \"http://xxx.mqrest.cn-hangzhou.aliyuncs.com\", \"HttpInternetSecureEndpoint\": \"\", \"TcpEndpoint\": \"http://MQ_INST_xxx.cn-hangzhou.mq-vpc.aliyuncs.com:8080\", \"TcpInternetEndpoint\": \"http://MQ_INST_xxx.cn-hangzhou.mq.aliyuncs.com:80\"}, \"IndependentNaming\": true, \"InstanceId\": \"MQ_INST_xxx\", \"InstanceName\": \"xxx\", \"InstanceStatus\": 5, \"InstanceType\": 1, \"Remark\": \"xxx\", \"spInstanceId\": \"\", \"spInstanceType\": 1}",
"InstanceType": "1",
"__docid": "CO_54a991d1b5a86d2dc82d796110ee3476"
}