[examples] Sync SDK examples from awsdocs/aws-doc-sdk-examples

Includes commit(s):
  f4d62c78cc9833e0761e6c8f2d30a69801b0c021
  299c9a6fdbbb541261a567d38dd527996f910d86
  1d52fa7c63b2fb7bb0a3adb4d51d8b21fc8390af
  5b0cb7a97ee764ef54fc93b66a658d7e2730a718
  b36c1c3b333bb2c03928e066774ada74c05ea165
  304651bf073daba16331cb7dcc4614953c314e62
  b4935440f4f1c031330173ea5fe45ed364fd9f2c
  3f0570319a5862411cb767a005363f78a187c0ab
  a8606e2ac77b2a2e871f06f0e13717755a22e938
  26f1a3d11de9c6488e9b1db175ffc92c370c5c27

Co-authored-by: David Souther <[email protected]>
Co-authored-by: ford prior <[email protected]>

Author: 3 people

Cargo.toml

@@ -1,6 +1,7 @@
 [workspace]
 exclude = [
     "examples/cross_service",
+    "examples/lambda",
     "examples/test-utils",
     "examples/examples",
     "examples/webassembly",

examples/cross_service/Cargo.toml

@@ -1,6 +1,7 @@
 # Note: this workspace exists solely for the convenience of 
 # compiling/auto-formatting/testing all the AWS Rust SDK examples together.
 [workspace]
+resolver = "2"
 members = [
     "detect_faces",
     "detect_labels",

examples/cross_service/detect_faces/Cargo.toml

@@ -9,13 +9,14 @@ publish = false
 aws-config= { version = "0.57.1", path = "../../../sdk/aws-config" }
 aws-sdk-rekognition= { version = "0.35.0", path = "../../../sdk/rekognition" }
 aws-sdk-s3= { version = "0.35.0", path = "../../../sdk/s3" }
+aws-smithy-types= { version = "0.57.1", path = "../../../sdk/aws-smithy-types", features = ["rt-tokio"] }
 
 [dependencies.tokio]
 version = "1.20.1"
 features = ["full"]
 
 [dependencies.clap]
-version = "~4.2"
+version = "~4.4"
 features = ["derive"]
 
 [dependencies.tracing-subscriber]

examples/cross_service/detect_labels/Cargo.toml

@@ -11,14 +11,15 @@ aws-config= { version = "0.57.1", path = "../../../sdk/aws-config" }
 aws-sdk-dynamodb= { version = "0.35.0", path = "../../../sdk/dynamodb" }
 aws-sdk-rekognition= { version = "0.35.0", path = "../../../sdk/rekognition" }
 aws-sdk-s3= { version = "0.35.0", path = "../../../sdk/s3" }
+aws-smithy-types= { version = "0.57.1", path = "../../../sdk/aws-smithy-types", features = ["rt-tokio"] }
 aws-types= { version = "0.57.1", path = "../../../sdk/aws-types" }
 
 [dependencies.tokio]
 version = "1.20.1"
 features = ["full"]
 
 [dependencies.clap]
-version = "~4.2"
+version = "~4.4"
 features = ["derive"]
 
 [dependencies.tracing-subscriber]

examples/cross_service/photo_asset_management/Cargo.toml

@@ -35,15 +35,19 @@ aws-sdk-dynamodb= { version = "0.35.0", path = "../../../sdk/dynamodb" }
 aws-sdk-rekognition= { version = "0.35.0", path = "../../../sdk/rekognition" }
 aws-sdk-s3= { version = "0.35.0", path = "../../../sdk/s3" }
 aws-sdk-sns= { version = "0.35.0", path = "../../../sdk/sns" }
-aws-smithy-client= { version = "0.57.1", path = "../../../sdk/aws-smithy-client", features = ["test-util"] }
 aws-smithy-http= { version = "0.57.1", path = "../../../sdk/aws-smithy-http" }
+aws-smithy-runtime= { version = "0.57.1", path = "../../../sdk/aws-smithy-runtime" }
 aws-smithy-types-convert= { version = "0.57.1", path = "../../../sdk/aws-smithy-types-convert", features = ["convert-chrono"] }
 
 [dependencies.aws_lambda_events]
-version = "0.10.0"
+version = "0.11.1"
 features = ["s3", "apigw"]
 default-features = false
 
+[dependencies.sdk-examples-test-utils]
+path = "../../test-utils"
+version = "0.1.0"
+
 [dependencies.serde]
 version = "1.0.159"
 features = ["derive"]

examples/cross_service/photo_asset_management/src/chunked_uploader.rs

@@ -5,7 +5,6 @@ use aws_sdk_dynamodb::primitives::DateTime;
 use aws_sdk_s3::{operation::get_object::GetObjectOutput, types::CompletedPart};
 use aws_smithy_types_convert::date_time::DateTimeExt;
 use chrono::NaiveDateTime;
-use futures::TryStreamExt;
 use pipe::{pipe, PipeReader, PipeWriter};
 use streaming_zip::{Archive, CompressionMode};
 use uuid::Uuid;

examples/cross_service/photo_asset_management/src/handlers/detect_labels.rs

@@ -64,7 +64,6 @@ async fn detect_record<'a>(
         .send()
         .await?
         .labels()
-        .ok_or_else(|| anyhow!("missing labels"))?
         .iter()
         .map(|l| l.to_owned())
         .collect();
@@ -159,7 +158,5 @@ mod test {
         assert!(update_inner_debug.contains("\":image\": L([S(\"object\")])"));
         assert!(update_inner_debug.contains("\":one\": N(\"1\")"));
         assert!(update_inner_debug.contains("\":zero\": N(\"0\")"));
-
-        ()
     }
 }

examples/cross_service/photo_asset_management/src/handlers/labels.rs

@@ -84,10 +84,8 @@ async fn get_labels(
         .send()
         .await?;
 
-    let items = scan.items().ok_or_else(|| anyhow!("no scanned items"))?;
-
     let mut labels = Labels::new();
-    for item in items {
+    for item in scan.items() {
         labels.insert(item.try_into()?);
     }
 
@@ -106,10 +104,9 @@ pub async fn handler(
 
 #[cfg(test)]
 mod test {
+    use sdk_examples_test_utils::single_shot_client;
     use serde_json::json;
 
-    use crate::single_shot_client;
-
     use super::{get_labels, Labels};
 
     #[tokio::test]

examples/cross_service/photo_asset_management/src/lib.rs

@@ -1,5 +1,4 @@
 pub mod chunked_uploader;
 pub mod common;
 pub mod handlers;
-pub mod test_utils;
 pub mod uploader;