Application Real-Time Monitoring Service:SkyWalking を使用した Rust アプリケーションのイベントトラッキング

ステップ 1: SkyWalking の依存関係の追加

ご利用の Cargo.toml に依存関係を追加します：

[dependencies]
skywalking = { version = "0.8.0", features = ["vendored"] }

または、次のコマンドを実行します：

cargo add skywalking --features vendored

ステップ 2: SkyWalking モジュールのインポート

イベントトラッキング対象のソースファイルに、次のインポート文を追加します：

use skywalking::{reporter::grpc::GrpcReporter, trace::tracer::Tracer};

ステップ 3: gRPC レポーターの設定

レポーターを SkyWalking エンドポイントに接続し、トークンを使用して認証します。プレースホルダーを実際の値に置き換えてください。

// これらのプレースホルダーを実際の値に置き換えます。
let endpoint = "<your-skywalking-endpoint>";
let token = "<your-authentication-token>";
let service_name = "<your-service-name>";
let instance_name = "<your-instance-name>";

let reporter = GrpcReporter::connect(endpoint).await?;
let reporter = reporter.with_authentication(token);
let tracer = Tracer::new(service_name, instance_name, reporter.clone());

ステップ 4: スパンの作成

SkyWalking は、エンドツーエンドの分散トレーシングのために 3 種類のスパンタイプを使用します：

クライアントサイドのコード (コンテキストを伝播するためのエグジットスパンを作成)：

let mut ctx = tracer.create_trace_context();
{
    // アウトバウンド呼び出しを行う前にエグジットスパンを作成します。
    let span = ctx.create_exit_span("operation1", "remote_peer");
    // ... リクエストを送信 ...
}

サーバーサイドのコード (コンテキストを受け取るためのエントリースパンを作成)：

let mut ctx = tracer.create_trace_context();
{
    // 受信リクエストを処理する際にエントリースパンを作成します。
    let span = ctx.create_entry_span("operation1");
    // ... リクエストを処理 ...
}

ステップ 5: アプリケーションの再ビルドと再起動

イベントトラッキングを追加した後、アプリケーションを再ビルドして再起動します：

cargo build --release

アプリケーションがリクエストを処理すると、トレースデータが OpenTelemetry 向けマネージドサービスに送信され始めます。

Protobuf 関連のエラーでビルドが失敗する

原因： Protobuf コンパイラがインストールされていないか、PATH に含まれていません。

解決策： 「前提条件」で説明されているように Protobuf をインストールしてから、ビルドを再試行してください。