Commit 6f2a0fa8 authored by AWS SDK Rust Bot's avatar AWS SDK Rust Bot
Browse files

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



Includes commit(s):
  b7635b1ab88285a744547c4aa33b6ba8bf0a1c57
  9465b36910cdc1962dadfe53af2ce31098a7abd8
  a48be99cf3e1e920698bbbd4fe5c22c4f9bef279
  d73bd946755cb53a0984af323e6bc0817bf5c9f6
  a29f4e9d999254adf8b3594ad8904e781ab01f1b
  e68209ef191d825e7b19dd5b0ea84a980df54922
  8595338924aae24aa9815e26d8b536a231b52e78
  8d51b94f33b95667b76a2232762560304a28b6e5
  9f08f276537a38dc094727f1ad0b0ceacbb1dc7b

Co-authored-by: default avatarDavid Souther <davidsouther+github@gmail.com>
Co-authored-by: default avatarEric Shepherd <ericsh@amazon.com>
Co-authored-by: default avatarJohn DiSanti <jdisanti@amazon.com>
parent b6063d36

examples/cross_service/detect_faces/src/main.rs

+3 −2
Original line number Diff line number Diff line
@@ -4,6 +4,7 @@ 
 */



use aws_config::meta::region::RegionProviderChain;

use aws_config::BehaviorVersion;

use aws_sdk_s3::config::Region;

use clap::Parser;

use std::error::Error;
@@ -205,13 +206,13 @@ async fn main() -> Result<(), Box<dyn Error>> { 
        println!();

    }



    let s3_shared_config = aws_config::from_env()

    let s3_shared_config = aws_config::defaults(BehaviorVersion::latest())

        .region(s3_region_provider)

        .load()

        .await;

    let s3_client = aws_sdk_s3::Client::new(&s3_shared_config);



    let rek_shared_config = aws_config::from_env()

    let rek_shared_config = aws_config::defaults(BehaviorVersion::latest())

        .region(rek_region_provider)

        .load()

        .await;

examples/cross_service/detect_labels/src/main.rs

+4 −3
Original line number Diff line number Diff line
@@ -6,6 +6,7 @@ 
extern crate exif;



use aws_config::meta::region::RegionProviderChain;

use aws_config::BehaviorVersion;

use aws_sdk_dynamodb::config::Region;

use aws_sdk_dynamodb::types::AttributeValue;

use clap::Parser;
@@ -279,7 +280,7 @@ async fn main() -> Result<(), exif::Error> { 
        println!();

    }



    let s3_shared_config = aws_config::from_env()

    let s3_shared_config = aws_config::defaults(BehaviorVersion::latest())

        .region(s3_region_provider)

        .load()

        .await;
@@ -289,7 +290,7 @@ async fn main() -> Result<(), exif::Error> { 


    let edata = get_exif_data(&filename);



    let rek_shared_config = aws_config::from_env()

    let rek_shared_config = aws_config::defaults(BehaviorVersion::latest())

        .region(rek_region_provider)

        .load()

        .await;
@@ -297,7 +298,7 @@ async fn main() -> Result<(), exif::Error> { 


    let labels = get_label_data(&rek_client, &bucket, &filename).await;



    let dynamo_shared_config = aws_config::from_env()

    let dynamo_shared_config = aws_config::defaults(BehaviorVersion::latest())

        .region(dynamo_region_provider)

        .load()

        .await;

examples/cross_service/photo_asset_management/src/common.rs

+2 −2
Original line number Diff line number Diff line 
use aws_config::SdkConfig;

use aws_config::{BehaviorVersion, SdkConfig};



#[cfg(not(debug_assertions))]

pub fn init_tracing_subscriber() {
@@ -62,7 +62,7 @@ impl Common { 
    }



    pub async fn load_from_env() -> Self {

        let sdk_config = aws_config::load_from_env().await;

        let sdk_config = aws_config::load_defaults(BehaviorVersion::latest()).await;

        // PAM environment is declared in the cdk, in lib/backend/lambdas.ts

        let storage_bucket =

            std::env::var("STORAGE_BUCKET_NAME").expect("storage bucket in environment");

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

+6 −2
Original line number Diff line number Diff line
@@ -127,7 +127,7 @@ pub async fn handler( 
#[cfg(test)]

mod test {

    use super::prepare_update_expression;

    use aws_config::SdkConfig;

    use aws_config::{BehaviorVersion, SdkConfig};



    #[tokio::test]

    async fn test_prepare_update_statement() {
@@ -136,7 +136,11 @@ mod test { 
            .name("label")

            .build();



        let client = aws_sdk_dynamodb::Client::new(&SdkConfig::builder().build());

        let client = aws_sdk_dynamodb::Client::new(

            &SdkConfig::builder()

                .behavior_version(BehaviorVersion::latest())

                .build(),

        );

        let update = client.update_item();

        let update = prepare_update_expression(update, &object, &label);

examples/cross_service/photo_asset_management/src/uploader.rs

+4 −3
Original line number Diff line number Diff line
@@ -57,9 +57,10 @@ impl<'a> ZipUpload<'a> { 


        let mut byte_count = 0_usize;

        while let Some(bytes) = object.body.try_next().await? {

            let bytes = self.zip.write(&bytes)?;

            byte_count += bytes;

            tracing::trace!("Intermediate read of {bytes} (total {byte_count})");

            let bytes_len = bytes.len();

            self.zip.write_all(&bytes)?;

            byte_count += bytes_len;

            tracing::trace!("Intermediate read of {bytes_len} (total {byte_count})");

        }



        Ok(())