AWS SDK for Rust でのウェイターの使用

ウェイターは、クライアント側の抽象化で、リソースが目的の状態に達するまで、またはそのリソースが目的の状態に入らないと判断されるまで、リソースをポーリングします。これは、Amazon Simple Storage Service などの結果整合性のあるサービスや、Amazon Elastic Compute Cloud などのリソースを非同期で作成するサービスを使用する場合の一般的なタスクです。リソースのステータスを定期的にポーリングするロジックを自分で記述するのは、手間がかかりエラーの原因にもなります。ウェイターの目的は、この責任を顧客コードから外し、AWS オペレーションのタイミングに関する深い知識を持つ AWS SDK for Rust に移すことです。

ウェイターのサポートを提供する AWS のサービスには、<service>::waiters モジュールが含まれます。

次の例では、Amazon S3 を使用しています。ただし、1 つ以上のウェイターが定義されている AWS のサービス については、概念は同じです。

次のコード例は、バケット作成後にその存在を待つためのポーリングロジックを記述する代わりに、ウェイター関数を使用する方法を示しています。

use std::time::Duration;
use aws_config::BehaviorVersion;
// Import Waiters trait to get `wait_until_<Condition>` methods on Client.
use aws_sdk_s3::client::Waiters;


let config = aws_config::defaults(BehaviorVersion::latest())
    .load()
    .await;
    
let s3 = aws_sdk_s3::Client::new(&config);

// This initiates creating an S3 bucket and potentially returns before the bucket exists.
s3.create_bucket()
    .bucket("my-bucket")
    .send()
    .await?;

// When this function returns, the bucket either exists or an error is propagated.
s3.wait_until_bucket_exists()
    .bucket("my-bucket")
    .wait(Duration::from_secs(5))
    .await?;

// The bucket now exists.