Alibaba Cloud KafKa¶
Alibaba Cloud KafKa には、インスタンスのディスク使用率、インスタンスおよび topic のメッセージ生産量、メッセージ生産回数、メッセージ消費量、メッセージ消費回数などが含まれ、これらのメトリクスは Kafka が大規模なメッセージ配信とリアルタイムデータストリームを処理する際の信頼性を示します。
設定¶
Func のインストール¶
Guance 統合 - 拡張 - ホスト型 Func の有効化を推奨します
Func を自前でデプロイする場合は Func を自前でデプロイ を参照してください
スクリプトの有効化¶
注意:要件を満たす Alibaba Cloud AK を事前に準備してください(簡単のため、グローバル読み取り専用権限
ReadOnlyAccessを直接付与してもかまいません)
ホスト型の有効化スクリプト¶
- Guance コンソールにログインします
- [統合] メニューをクリックし、[クラウドアカウント管理] を選択します
- [クラウドアカウントの追加] をクリックし、[Alibaba Cloud] を選択して、画面に必要な情報を入力します。すでにクラウドアカウント情報を設定済みの場合は、この手順はスキップできます
- [テスト] をクリックし、成功したら [保存] をクリックします。テストに失敗した場合は、関連する設定が正しいか確認して再度テストしてください
- [クラウドアカウント管理] の一覧で追加済みのクラウドアカウントを確認できます。該当するクラウドアカウントをクリックして詳細ページに入ります
- クラウドアカウント詳細ページの [統合] ボタンをクリックし、
未インストール一覧でAlibaba Cloud KafKaを見つけて [インストール] ボタンをクリックすると、インストール画面が表示されるのでそのままインストールします
手動有効化スクリプト¶
-
Func コンソールにログインし、[スクリプトマーケット] をクリックして Guance スクリプトマーケットに入り、
integration_alibabacloud_alikafkaを検索します -
[インストール] をクリックした後、対応するパラメータとして Alibaba Cloud AK ID、AK Secret、およびアカウント名を入力します
-
[デプロイして起動スクリプトを開始] をクリックすると、システムが自動的に
Startupスクリプトセットを作成し、対応する起動スクリプトを自動で設定します -
有効化後、「管理 / 自動トリガー設定」で対応する自動トリガー設定を確認できます。[実行] をクリックすると、定期実行を待たずにすぐに 1 回実行できます。しばらくすると、実行タスクの記録と対応するログを確認できます
検証¶
- 「管理 / 自動トリガー設定」で、対応するタスクに自動トリガー設定が存在するか確認し、あわせて対応するタスク記録とログを確認して異常がないかチェックします
- Guance の「インフラストラクチャ / カスタム」でアセット情報が存在するか確認します
- Guance の「メトリクス」で対応する監視データがあるか確認します
メトリクス¶
Alibaba Cloud - CloudMonitor を設定すると、デフォルトのメトリクスセットは次のとおりです。設定によりさらに多くのメトリクスを収集できます Alibaba Cloud CloudMonitor のメトリクス詳細
| Metric Id | メトリクス名 | Dimensions | Statistics | Unit |
|---|---|---|---|---|
| instance_disk_capacity_Maximum | V2 インスタンスのディスク使用率 | userId,instanceId | Maximum | % |
| instance_message_input | インスタンスメッセージ生産量 | userId,instanceId | Value | bytes/s |
| instance_message_num_input | インスタンスメッセージ生産件数 | userId,instanceId | Value | countSecond |
| instance_message_output | インスタンスメッセージ消費量 | userId,instanceId | Value | bytes/s |
| instance_reqs_input | インスタンスメッセージ送信回数 | userId,instanceId | Value | countSecond |
| instance_reqs_output | インスタンスメッセージ消費回数 | userId,instanceId | Value | countSecond |
| topic_message_input | topic メッセージ生産量 | userId,instanceId | Value | bytes/s |
| topic_message_num_input | topic メッセージ生産件数 | userId,instanceId | Value | countSecond |
| topic_message_output | topic メッセージ消費量 | userId,instanceId | Value | bytes/s |
| topic_reqs_input | topic メッセージ送信回数 | userId,instanceId | Value | countSecond |
| topic_reqs_output | topic メッセージ消費回数 | userId,instanceId | Value | countSecond |
オブジェクト¶
収集された Alibaba Cloud KafKa のオブジェクトデータ構造は、「インフラストラクチャ - カスタム」で確認できます
{
"measurement": "aliyun_kafka",
"tags": {
"InstanceId" : "alikafka_post-cn-zsk3cluq100d",
"InstanceName" : "alikafka_post-cn-zsk3cluq100d",
"RegionId" : "cn-hangzhou",
"ResourceGroupId" : "rg-acfmv3ro3xnfwaa",
"SpecType" : "normal",
"cloud_provider" : "aliyun",
"name" : "alikafka_post-cn-zsk3cluq100d"
},
"fields": {
"AllConfig" : "{}",
"CreateTime" : 1692080715000,
"DeployType" : 5,
"EipMax" : 0,
"ExpiredTime" : 2007699914000,
"IoMax" : 20,
"IoMaxSpec" : "alikafka.hw.2xlarge",
"PaidType" : 1,
"ServiceStatus" : 0,
"TopicNumLimit" : 1000,
"UsedGroupCount" : 0,
"UsedTopicCount" : 0,
}
}