Dispatch errors when creating a s3 bucket with a lambda function #1098

DotRed108 · 2024-03-13T05:21:55Z

DotRed108
Mar 13, 2024

When creating a bucket I receive a dispatch error.

My code

use aws_config::BehaviorVersion;
use aws_sdk_s3::error::SdkError;
use aws_sdk_s3::operation::create_bucket::{CreateBucketError, CreateBucketOutput};
use aws_sdk_s3::types::{BucketLocationConstraint, CreateBucketConfiguration};
use lambda_http::{run, service_fn, tracing, Body, Error, Request, RequestExt, Response};
use aws_sdk_s3::{self};
use aws_sdk_s3::Client as S3Client;


/// - https://github.com/awslabs/aws-lambda-rust-runtime/tree/main/examples
pub async fn function_handler(_event: Request) -> Result<Response<Body>, Error> {
    let config = aws_config::load_defaults(BehaviorVersion::latest()).await;
    let client = aws_sdk_s3::Client::new(&config);

    let bucket_creation_result = match create_bucket(&client, "What-Da-Heck--use2-az2--x-s3", "us-east-2").await {
        Ok(_) => "Success".to_string(),
        Err(e) => format!("Bucket creation failed with {:?}", e),
    };
    
    let mut status_code = 500;
    if bucket_creation_result.starts_with("Success") {
        status_code = 200;
    }

    let resp = Response::builder()
        .status(status_code)
        .header("content-type", "text/html")
        .body(format!("{}", bucket_creation_result).into())
        .map_err(Box::new)?;

    Ok(resp)
}

pub async fn create_bucket(client: &S3Client, bucket_name: &str, region: &str) -> Result<CreateBucketOutput, SdkError<CreateBucketError>> {
    let constraint = BucketLocationConstraint::from(region);
    let cfg = CreateBucketConfiguration::builder()
        .location_constraint(constraint)
        .build();


    client.create_bucket()
        .create_bucket_configuration(cfg)
        .bucket(bucket_name)
        .send()
        .await
}

#[tokio::main]
async fn main() -> Result<(), Error> {
    tracing::init_default_subscriber();

    run(service_fn(function_handler)).await
}

When running the function with cargo lambda watch I get this error on MacOS when I send a request

{
  "statusCode":500,
  "headers": {
     "content-type":"text/html"
   },
   "multiValueHeaders": {
     "content-type":[
       "text/html"
     ]
   },
   "body":"Bucket creation failed with DispatchFailure(DispatchFailure { source: ConnectorError { kind: Io, source: hyper::Error(Connect, ConnectError(\"dns error\", Custom { kind: Uncategorized, error: \"failed to lookup address information: nodename nor servname provided, or not known\" })), connection: Unknown } })",
   "isBase64Encoded":false
}

When the function is deployed and sending a request with lambdas test utility I get this error

{
  "statusCode": 500,
  "headers": {
    "content-type": "text/html"
  },
  "multiValueHeaders": {
    "content-type": [
      "text/html"
    ]
  },
  "body": "Bucket creation failed with DispatchFailure(DispatchFailure { source: ConnectorError { kind: Io, source: hyper::Error(Connect, ConnectError(\"dns error\", Os { code: 16, kind: ResourceBusy, message: \"Device or resource busy\" })), connection: Unknown } })",
  "isBase64Encoded": false
}

I have been able to delete a bucket successfully using cargo lambda watch on the same computer.

The request event I'm using in both cases is https://github.com/calavera/aws-lambda-events/blob/main/src/fixtures/example-apigw-request.json