Huawei Cloud ROMA
Huawei Cloud ROMA のメトリクスデータを収集
設定¶
Func のインストール¶
Guance の統合 - 拡張 - マネージド版 Func を有効化することを推奨します。前提条件はすべて自動でインストールされるため、続けてスクリプトをインストールしてください。
Func を自分でデプロイする場合は、Func を自分でデプロイ を参照してください。
スクリプトのインストール¶
ヒント:要件を満たす Huawei Cloud AK を事前に用意してください。簡単のため、グローバル読み取り専用権限
Tenant Guestを直接付与しても構いません。
マネージド版の有効化スクリプト¶
- Guance コンソールにログインします
- 【統合】メニューをクリックし、【クラウドアカウント管理】を選択します
- 【クラウドアカウントの追加】をクリックし、【Huawei Cloud】を選択して画面の案内に従って情報を入力します。以前にクラウドアカウント情報を設定済みの場合は、この手順は省略します
- 【テスト】をクリックし、成功したら【保存】をクリックします。失敗した場合は関連設定が正しいか確認してから再度テストしてください
- 【クラウドアカウント管理】の一覧で追加済みのクラウドアカウントを確認できます。該当するクラウドアカウントをクリックして詳細ページに進みます
- クラウドアカウント詳細ページの【統合】ボタンをクリックし、
未インストール一覧からHuawei Cloud ROMAを見つけて【インストール】をクリックすると、インストール画面が表示されるのでそのままインストールします
手動有効化スクリプト¶
-
Func コンソールにログインし、【スクリプトマーケット】をクリックして Guance スクリプトマーケットに入り、
integration_huaweicloud_romaを検索します -
【インストール】をクリックし、Huawei Cloud AK、SK、およびアカウント名を入力します
-
【起動スクリプトのデプロイ】をクリックすると、システムが自動的に
Startupスクリプトセットを作成し、対応する起動スクリプトを自動で設定します -
有効化後、「管理 / 自動トリガー設定」で対応する自動トリガー設定を確認できます。【実行】をクリックすると、定期実行時間を待たずに即時 1 回実行できます。しばらくしてから、実行タスクの記録と対応するログを確認できます
検証¶
- 「管理 / 自動トリガー設定」で、対応するタスクに自動トリガー設定が存在するか確認し、あわせて対応するタスク記録とログを確認して異常がないかチェックします
- Guance の「インフラストラクチャー - リソースディレクトリ」で資産情報が存在するか確認します
- Guance の「メトリクス」で対応する監視データがあるか確認します
メトリクス¶
Huawei Cloud ROMA のメトリクスデータを収集します。設定により、より多くのメトリクスを収集できます。Huawei Cloud ROMA メトリクス詳細
インスタンス監視メトリクス¶
| メトリクス名 | メトリクスの意味 | 単位 | 次元 |
|---|---|---|---|
| current_partitions | このメトリクスは、Kafka インスタンスで使用済みのパーティション数を集計します | Count | instance_id |
| current_topics | このメトリクスは、Kafka インスタンスで作成済みのトピック数を集計します | Count | instance_id |
| group_msgs | このメトリクスは、Kafka インスタンス内のすべてのコンシューマーグループにおける総滞留メッセージ数を集計します | Count | instance_id |
ノード監視メトリクス¶
| メトリクス名 | メトリクスの意味 | 単位 | 次元 |
|---|---|---|---|
| broker_data_size | このメトリクスは、ノードの現在のメッセージデータサイズを集計します | Byte | instance_id |
| broker_messages_in_rate | このメトリクスは、1 秒あたりに生成されるメッセージ数を集計します | Count/s | instance_id |
| broker_bytes_in_rate | このメトリクスは、1 秒あたりに生成されるバイト数を集計します | Byte/s | instance_id |
| broker_bytes_out_rate | このメトリクスは、1 秒あたりに消費されるバイト数を集計します | Byte/s | instance_id |
| broker_public_bytes_in_rate | Broker ノードの 1 秒あたりのパブリックネットワーク流入トラフィックを集計します | Byte/s | instance_id |
| broker_public_bytes_out_rate | Broker ノードの 1 秒あたりのパブリックネットワーク流出トラフィックを集計します | Byte/s | instance_id |
| broker_fetch_mean | Broker ノードがコンシューマー要求を処理する平均時間を集計します | ms | instance_id |
| broker_produce_mean | プロデューサー要求の平均処理時間 | ms | instance_id |
| broker_cpu_core_load | Kafka ノードの仮想マシン層で収集した CPU 各コアの平均負荷 | % | instance_id |
| broker_disk_usage | Kafka ノードの仮想マシン層で収集したディスク容量使用率 | % | instance_id |
| broker_memory_usage | Kafka ノードの仮想マシン層で収集したメモリ使用率 | % | instance_id |
| broker_heap_usage | Kafka ノードの Kafka プロセス JVM で収集したヒープメモリ使用率 | % | instance_id |
| broker_alive | Kafka ノードが稼働しているかを示します | 1:稼働 0:オフライン | instance_id |
| broker_connections | Kafka ノードの現在の TCP 接続数 | Count | instance_id |
| broker_cpu_usage | Kafka ノード仮想マシンの CPU 使用率 | % | instance_id |
| broker_total_bytes_in_rate | Broker ノードの 1 秒あたりのネットワーク流入トラフィック | Byte/s | instance_id |
| broker_total_bytes_out_rate | Broker ノードの 1 秒あたりのネットワーク流出トラフィック | Byte/s | instance_id |
| broker_disk_read_rate | ディスク読み取り操作のトラフィック | Byte/s | instance_id |
| broker_disk_write_rate | ディスク書き込み操作のトラフィック | Byte/s | instance_id |
| network_bandwidth_usage | ネットワーク帯域利用率 | % | instance_id |
コンシューマーグループ監視メトリクス¶
| メトリクス名 | メトリクスの意味 | 単位 | 次元 |
|---|---|---|---|
| messages_consumed | このメトリクスは、現在のコンシューマーグループが消費済みのメッセージ数を集計します | Count | instance_id |
| messages_remained | このメトリクスは、コンシューマーグループが消費可能なメッセージ数を集計します | Count | instance_id |
| topic_messages_remained | このメトリクスは、コンシューマーグループが指定したキューで消費可能なメッセージ数を集計します | Count | instance_id |
| topic_messages_consumed | このメトリクスは、コンシューマーグループが指定したキューで現在消費済みのメッセージ数を集計します | Count | instance_id |
| consumer_messages_remained | このメトリクスは、コンシューマーグループで残り消費可能なメッセージ数を集計します | Count | instance_id |
| consumer_messages_consumed | このメトリクスは、コンシューマーグループが現在消費済みのメッセージ数を集計します | Count | instance_id |
オブジェクト¶
収集された Huawei Cloud ROMA のオブジェクトデータ構造です。「インフラストラクチャー-リソースディレクトリ」でオブジェクトデータを確認できます
{
"measurement": "huaweicloud_SYS.ROMA",
"tags": {
"RegionId" : "cn-north-4",
"charging_mode" : "1",
"connect_address" : "192.168.0.161,192.168.0.126,192.168.0.31",
"description" : "",
"engine" : "kafka",
"engine_version" : "2.7",
"instance_id" : "beb33e02-xxxx-xxxx-xxxx-628a3994fd1f",
"kafka_manager_user" : "",
"name" : "beb33e02-xxxx-xxxx-xxxx-628a3994fd1f",
"port" : "9092",
"project_id" : "f5f4c067d68xxxx86e173b18367bf",
"resource_spec_code" : "",
"service_type" : "advanced",
"specification" : "kafka.2u4g.cluster.small * 3 broker",
"status" : "RUNNING",
"storage_type" : "hec",
"user_id" : "e4b27d49128e4bd0893b28d032a2e7c0",
"user_name" : "xxxx"
},
"fields": {
"created_at" : "1693203968959",
"maintain_begin" : "02:00:00",
"maintain_end" : "06:00:00",
"storage_space" : 186,
"total_storage_space" : 300,
"message" : "{インスタンス JSON データ}"
}
}
注意:
tags、fieldsのフィールドは、後続の更新により変更される場合がありますヒント 1:
tags.nameの値はインスタンス ID であり、一意識別子として使用されますヒント 2:以下のフィールドはすべて JSON シリアライズ後の文字列です