Extend Event Handler - メトリクス
注釈:本資料はAI技術を用いて翻訳されています。
メトリクスの一覧
non-message_type(メッセージタイプ以外)
total_messages_received: メッセージを受信するたびにインクリメントされるトップレベルのメトリクスです。このメトリクスがインクリメントされるとき、Kafka Sink Connector はそれ以上の処理が行われる前に、Kafka から送られてくるメッセージを受信しています。
message_type(メッセージタイプ)
-
filtered_messages: 読み取り可能な proto メッセージ名で処理されているメッセージの数を示すメトリクスです。proto メッセージ名は、どの gRPC 呼び出しを行うかをマッピングするために使用されます。 -
grpc_method_not_implemented_skipped: gRPC サービス名キャッシュから呼び出す gRPC が見つからないことを示します。その結果、gRPC メソッドの呼び出しはスキップされます。gRPC サービス名キャッシュは、コネクターが最初に起動したときに、gRPC サーバーに対して gRPC リフレクションでメソッドの一覧を照会して構築されます。gRPC が呼び出される前に、まずこのキャッシュが確認されます。 -
grpc_method_disabled_skipped: gRPC サービス名キャッシュが gRPC リフレクション経由で見つかったものの、そのステータスが無効になっていることを示します。これは、呼び出し時に以前は無効だったが gRPC サーバー側で IMPLEMENTED(実装済み)になったため、最適化のために無効化されているケースです。同時に、grpc_server_invocation_unimplementedもインクリメントされます。詳細はメトリクスgrpc_server_invocation_unimplementedを参照してください。gRPC サーバーとコネクターは同じ Pod 内で稼働しているため、実装済みメソッドの一覧は常に同期しているはずであり、gRPC の呼び出しがスキップされることは通常起こり得ないケースです。
フロー

マッピングファイルからメッセージ名を正常に読み取り、参照した後:
rpc_server_invocation_initiatedがインクリメントされ、続いて gRPC Extend アプリのマッピングされたメソッドが呼び出されます。
gRPC サーバー呼び出し時:
-
grpc_server_invocation_successfulは、gRPC Extend アプリがステータスコードOKで Extend アプリに正常に応答を返したときにインクリメントされます。 -
grpc_server_invocation_unimplementedは gRPC Extend アプリを呼び出しますが、アプリが UNIMPLEMENTED で応答した場合です。これは、gRPC Extend アプリのサイドカーであるコネクター内の gRPC サービス名キャッシュが、gRPC Extend アプリが完全に起動した後に構築されたために発生します。 -
grpc_server_invocation_retriable_exceptionsは gRPC Extend アプリを呼び出しますが、アプリがリトライ可能と見なされる例外で応答した場合です。リトライ可能な gRPC Extend アプリの例外の一覧:
- UNAVAILABLE
- CANCELLED
- DEADLINE_EXCEEDED
- RESOURCE_EXHAUSTED
- INTERNAL
-
grpc_server_invocation_other_exceptions: gRPC が呼び出されましたが、gRPC Extend アプリがリトライ可能とは見なされないその他の例外で応答した場合です。
例外に関する全体的なメトリクス
-
unexpected_exceptions_unknown_message_type: Kafka メッセージから、正確なメッセージタイプ(proto メッセージ名)を判別できないリトライ不可能な例外が発生していることを示します。 -
unexpected_exceptions: Kafka メッセージから、メッセージタイプ(proto メッセージ名)を判別できるリトライ不可能な例外が発生していることを示します。
メトリクスの命名規則
メトリクスの命名規則は以下のとおりです。
metrics_grpc_bridge:`<task_connector_id>`:`<topic>`:`<message_type_if_applicable>`:`<metric_name>`_Count
例
この例では、タスクコネクターインスタンス ID が 0、トピックが accelbyte_dev_userAuthentication の場合、メトリクスは以下のように識別されます。
- 最初のものは、そのトピックの
total_messages_receivedに属するトップレベルのメトリクスです。 - 残りは、メッセージタイプ(proto メッセージ名)
userLoggedInに属するメトリクスです。
