Sample Amazon SQS function code using Rust without batch item handling.

Author: kazhura-aws

integration-sqs-to-lambda/main.rs

@@ -0,0 +1,27 @@
+use aws_lambda_events::event::sqs::SqsEvent;
+use lambda_runtime::{run, service_fn, Error, LambdaEvent};
+
+static UNDEFINED: &str = "undefined";
+
+async fn function_handler(event: LambdaEvent<SqsEvent>) -> Result<(), Error> {
+
+    event.payload.records.iter().for_each(|record| {
+        // process the record
+        tracing::info!("Message body: {}", record.body.as_deref().unwrap_or(UNDEFINED))
+    });
+
+    Ok(())
+}
+
+#[tokio::main]
+async fn main() -> Result<(), Error> {
+    tracing_subscriber::fmt()
+        .with_max_level(tracing::Level::INFO)
+        // disable printing the name of the module in every log line.
+        .with_target(false)
+        // disabling time is handy because CloudWatch will add the ingestion time.
+        .without_time()
+        .init();
+
+    run(service_fn(function_handler)).await
+}

integration-sqs-to-lambda/snippet-data.json

@@ -96,6 +96,17 @@
               "language": "go"
             }
           ]
+        },
+        {
+          "id": "Rust",
+          "title": "Usage Example with Rust:",
+          "description": "Sample Amazon SQS function code using Rust without batch item handling.",
+          "snippets": [
+            {
+              "snippetPath": "main.rs",
+              "language": "rust"
+            }
+          ]
         }
       ]
     }