パフォーマンスに関する考慮事項

Overview

このガイドでは、Rust ドライバーのパフォーマンスを最適化する方法を学習できます。 MongoDB に接続するには、 Clientインスタンスを作成する必要があります。 Clientインスタンスは、サーバー トポロジーの検出、接続のモニタリング、内部接続プールの維持など、接続のほとんどの要素を自動的に処理します。 このガイドでは、 Clientインスタンスの構成と使用に関するベストプラクティスについて説明します。

このガイドには、次のセクションが含まれています。

• クライアント ライフサイクルでは、 Clientインスタンスの作成と管理に関するベストプラクティスについて説明します。

• 接続プールは、ドライバーでの接続プーリングの仕組みを説明します

• 並列処理では、タスクを並行して実行するためのサンプルコードが提供されます

• Runtimeでは、 tokio作成とasync_std作成の機能を使用してランタイムを管理する方法について説明しています。

• 追加情報では、このガイドで言及されている型とメソッドのリソースとAPIドキュメントへのリンクを提供します

クライアントのライフサイクル

クライアントは複数のセッションやオペレーションで再利用することをお勧めします。 同じClientインスタンスを使用して複数のタスクを実行できます。 Client型は複数のスレッドで安全に同時使用できます。 リクエストごとに新しいClientインスタンスを作成すると、パフォーマンスが低下します。

次のコードでは、既存のClientインスタンスへのポインターを受け入れるメソッドが作成されます。これにより、同じクライアントを使用して多くのリクエストを実行できます。

// ... Create a client earlier in your code
async fn make_request(client: &Client) -> Result<(), Box<dyn Error>> {
    // Use the client to perform operations
    Ok(())
}

接続プール

すべてのClientインスタンスには、MongoDB トポロジー内の各サーバーに対する接続プールが組み込まれています。 接続プールはオンデマンドでソケットを開き、アプリケーション内の MongoDB への同時要求をサポートします。

Clientのデフォルト構成はほとんどのアプリケーションで動作します。 次のコードは、デフォルトの接続設定を持つクライアントを作成する方法を示しています。

let client = Client::with_uri_str("<connection string>").await?;

あるいは、アプリケーションのニーズに合わせて接続プールを調整し、パフォーマンスを最適化することもできます。 接続設定をカスタマイズする方法の詳細については、このガイドの次のサブセクションを参照してください。

• 最大プール サイズの設定

• 同時接続オプションの構成

• 最大アイドル時間の設定

let mut client_options = ClientOptions::parse("<connection string>").await?;
client_options.max_pool_size = Some(20);
let client = Client::with_options(client_options)?;

let mut client_options = ClientOptions::parse("<connection string>").await?;
client_options.max_connecting = Some(3);
client_options.min_pool_size = Some(1);
let client = Client::with_options(client_options)?;

let mut client_options = ClientOptions::parse("<connection string>").await?;
client_options.max_idle_time = Some(Duration::new(90, 0));
let client = Client::with_options(client_options)?;

並列処理

並列データ操作を実行できる場合は、非同期の同時実行タスクを実行することでパフォーマンスを最適化できます。 次のコードでは、 tokio::taskモジュールのspawn()メソッドを使用して、挿入操作を実行するための個別の同時実行タスクを作成します。

let client = Client::with_uri_str("<connection string>").await?;
let data = doc! { "title": "1984", "author": "George Orwell" };
for i in 0..5 {
    let client_ref = client.clone();
    let data_ref = data.clone();
    task::spawn(async move {
        let collection = client_ref
            .database("items")
            .collection::<Document>(&format!("coll{}", i));
        collection.insert_one(data_ref).await
    });
}

ランタイム

Clientインスタンスは、それを作成したtokioまたはasync-stdランタイムのインスタンスにバインドされます。 Clientインスタンスを使用して別のランタイムで操作を実行すると、予期しない動作や失敗が発生する可能性があります。

tokioまたはasync_stdのtestヘルパー マイクロを使用してアプリケーションをテストすると、意図したランタイムとは異なるランタイムで操作を実行する可能性があります。 これは、これらのヘルパー マイクロがテストごとに新しいランタイムを作成するためです。 ただし、この問題を回避するには、次のいずれかの戦略を使用できます。

• testヘルパー マイクロを使用せずに、ランタイムをClientインスタンスにアタッチします。

• asyncテストごとに新しいClientインスタンスを作成します。

この例では、最初の戦略に従い、テスト専用のグローバル ランタイムを作成しています。 次のコードでは、 test_list_dbs()メソッドは、このランタイムに手動で接続するクライアントを使用して配置内のデータベースを一覧表示します。

use tokio::runtime::Runtime;
use once_cell::sync::Lazy;
static CLIENT_RUNTIME: Lazy<(Client, Runtime)> = Lazy::new(|| {
    let rt = Runtime::new().unwrap();
    let client = rt.block_on(async {
        Client::with_uri_str("<connection string>").await.unwrap()
    });
    (client, rt)
});
#[test]
fn test_list_dbs() -> Result<(), Box<dyn Error>> {
    let (client, rt) = &*CLIENT_RUNTIME;
    rt.block_on(async {
        client.list_database_names().await
    })?;
    Ok(())
}

2 つ目の戦略を実装することで、次のコードはtokio::testを使用して実行されるテストごとに新しいClientインスタンスを作成し、ランタイム間で意図しない相互作用が存在しないようにします。

#[tokio::test]
async fn test_list_dbs() -> Result<(), Box<dyn Error>> {
    let client = Client::with_uri_str("<connection string>").await?;
    client.list_database_names().await?;
    Ok(())
}

詳細情報

MongoDB への接続の詳細については、「 接続ガイド 」を参照してください。

Rust ドライバーで利用可能なランタイムの詳細については、「非同期 API と同期 API に関するガイド 」を参照してください。