@aws-sdk v3

import { S3Client, GetObjectCommand } from "@aws-sdk/client-s3";
 
const s3 = new S3Client({ region: process.env.AWS_REGION });
 
export async function getObjectText(bucket: string, key: string) {
  const res = await s3.send(new GetObjectCommand({ Bucket: bucket, Key: key }));
  return await res.Body?.transformToString();
}

// src/aws/clients.ts
import { DynamoDBClient } from "@aws-sdk/client-dynamodb";
import { DynamoDBDocumentClient, GetCommand, PutCommand } from "@aws-sdk/lib-dynamodb";
import { SSMClient, GetParameterCommand } from "@aws-sdk/client-ssm";
import { NodeHttpHandler } from "@smithy/node-http-handler";
 
const requestHandler = new NodeHttpHandler({
  connectionTimeout: 3_000,
  requestTimeout: 10_000,
});
 
const ddbDoc = DynamoDBDocumentClient.from(
  new DynamoDBClient({ maxAttempts: 3, requestHandler }),
  { marshallOptions: { removeUndefinedValues: true } }
);
 
const ssm = new SSMClient({ maxAttempts: 3 });
 
export async function getOrder(id: string) {
  const res = await ddbDoc.send(
    new GetCommand({ TableName: process.env.TABLE_NAME!, Key: { id } })
  );
  return res.Item;
}
 
export async function putOrder(item: Record<string, unknown>) {
  await ddbDoc.send(
    new PutCommand({ TableName: process.env.TABLE_NAME!, Item: item })
  );
}
 
let cachedApiKey: string | undefined;
 
export async function getApiKey() {
  if (cachedApiKey) return cachedApiKey;
  const res = await ssm.send(
    new GetParameterCommand({ Name: "/prod/api/KEY", WithDecryption: true })
  );
  cachedApiKey = res.Parameter?.Value;
  return cachedApiKey!;
}

// src/handler.ts
import type { APIGatewayProxyHandlerV2 } from "aws-lambda";
import { getOrder } from "./aws/clients.js";
 
export const handler: APIGatewayProxyHandlerV2 = async (event) => {
  const id = event.pathParameters?.id!;
  const order = await getOrder(id);
  return {
    statusCode: order ? 200 : 404,
    body: JSON.stringify(order ?? { error: "not found" }),
  };
};

import { SQSClient, SendMessageCommand } from "@aws-sdk/client-sqs";
 
await sqs.send(new SendMessageCommand({
  QueueUrl: process.env.QUEUE_URL!,
  MessageBody: JSON.stringify({ orderId: "42" }),
}));

import { S3Client } from "@aws-sdk/client-s3";
 
const s3 = new S3Client({});
 
s3.middlewareStack.add(
  (next) => async (args) => {
    const start = Date.now();
    const result = await next(args);
    console.log(JSON.stringify({ awsCall: args.request?.hostname, ms: Date.now() - start }));
    return result;
  },
  { step: "finalizeRequest", name: "logLatency" }
);

aws sso login --profile dev
AWS_PROFILE=dev npm run invoke:local