shared s3 client - does not work

Author: peterborkuti

examples/basic-s3-test/Cargo.toml

@@ -0,0 +1,31 @@
+[package]
+name = "basic-s3-test"
+version = "0.1.0"
+edition = "2021"
+
+# Starting in Rust 1.62 you can use `cargo add` to add dependencies 
+# to your project.
+#
+# If you're using an older Rust version,
+# download cargo-edit(https://github.com/killercup/cargo-edit#installation) 
+# to install the `add` subcommand.
+#
+# Running `cargo add DEPENDENCY_NAME` will
+# add the latest version of a dependency to the list,
+# and it will keep the alphabetic ordering for you.
+
+[dependencies]
+aws_lambda_events = "0.7.2"
+json = "0.12.4"
+lambda_runtime = { path = "../../lambda-runtime" }
+serde = "1.0.136"
+serde_json = "1.0.93"
+tokio = { version = "1", features = ["macros"] }
+tracing = { version = "0.1", features = ["log"] }
+tracing-subscriber = { version = "0.3", default-features = false, features = ["ansi", "fmt"] }
+aws-config = "0.54.1"
+aws-sdk-s3 = "0.24.0"
+thumbnailer = "0.4.0"
+mime = "0.3.16"
+async-global-executor = "2.3.1"
+aws-smithy-http = "0.54.4"

examples/basic-s3-test/src/main.rs

@@ -0,0 +1,66 @@
+
+use aws_config::meta::region::RegionProviderChain;
+use aws_lambda_events::{event::s3::S3Event};
+use aws_sdk_s3::{types::ByteStream, Client};
+use aws_smithy_http::body::SdkBody;
+use lambda_runtime::{run, service_fn, Error, LambdaEvent};
+use serde::Serialize;
+
+#[derive(Serialize)]
+struct Response {
+    req_id: String,
+    msg: String,
+}
+
+struct SharedClient {
+    client: &'static Client,
+}
+
+impl SharedClient {
+    fn new(client: &'static Client) -> Self {
+        Self { client }
+    }
+
+    pub async fn put_file_x(&self) -> Response {
+        let stream = ByteStream::new(SdkBody::from("hello"));
+        let _ = self.put_file("bucket", "key", stream).await;
+
+        Response { req_id: "1".to_string(), msg: "msg".to_string()}
+    }
+
+    pub async fn put_file(&self, bucket: &str, key: &str, bytes: ByteStream) {
+        let _ = self
+            .client
+            .put_object()
+            .bucket(bucket)
+            .key(key)
+            .body(bytes)
+            .send()
+            .await;
+    }
+}
+
+async fn get_client() -> Client {
+    let region_provider = RegionProviderChain::default_provider().or_else("us-east-2");
+    let config = aws_config::from_env().region(region_provider).load().await;
+    let client = Client::new(&config);
+
+    return client;
+}
+
+#[tokio::main]
+async fn main() -> Result<(), Error> {
+    let s3_client = get_client().await;
+    let client = move || &SharedClient::new(&s3_client);
+
+    let client_ref = client();
+
+    run(service_fn(
+        move |_event: LambdaEvent<S3Event>| async move {
+            Ok::<Response, Error>(client_ref.put_file_x().await)
+        }
+    ))
+    .await?;
+    Ok(())
+}
+