README.md | ||
test.py |
REST API na środoiwsku AWS Lambda i DynamoDB
Konfiguracja
Poradnik jak skonfigurować środowisko można znaleźć pod adresem: https://docs.aws.amazon.com/apigateway/latest/developerguide/http-api-dynamo-db.html
Kod
Poniżej znajduje się kod funkcji Lambda, która obsługuje zapytania HTTP i komunikuje się z bazą danych DynamoDB - wykonany na potrzebę zadania z przedmiotu Chmury obliczeniowe (zad. 6.2
)
import { DynamoDBClient } from "@aws-sdk/client-dynamodb";
import {
DynamoDBDocumentClient,
PutCommand,
GetCommand,
DeleteCommand,
} from "@aws-sdk/lib-dynamodb";
import { randomUUID } from 'crypto';
const client = new DynamoDBClient({});
const dynamo = DynamoDBDocumentClient.from(client);
const tableName = "posts";
const DB = {
async create({ userId, title, body }) {
const id = randomUUID();
await dynamo.send(
new PutCommand({
TableName: tableName,
Item: { id, userId, title, body },
})
);
return await DB.get(id);
},
async get(id) {
return (await dynamo.send(
new GetCommand({
TableName: tableName,
Key: { id },
})
))?.Item;
},
async update(id, { userId, title, body }) {
await dynamo.send(
new PutCommand({
TableName: tableName,
Item: { id, userId, title, body },
})
);
return await DB.get(id);
},
async delete(id) {
_result = await DB.get(id);
await dynamo.send(
new DeleteCommand({
TableName: tableName,
Key: { id },
})
);
return _result;
},
}
export const handler = async (event, context) => {
let body;
try {
switch (event.routeKey) {
case "POST /":
body = await DB.create(JSON.parse(event.body));
break;
case "DELETE /{id}":
body = await DB.delete(event.pathParameters.id);
break;
case "GET /{id}":
body = await DB.get(event.pathParameters.id);
break;
case "PUT /{id}":
body = await DB.update(event.pathParameters.id, JSON.parse(event.body));
break;
default:
throw new Error(`Unsupported route: "${event.routeKey}"`);
}
return {
statusCode: 200,
headers: { "Content-Type": "application/json" },
body: JSON.stringify(body),
};
} catch (err) {
return {
statusCode: 400,
body: JSON.stringify(err.message),
};
}
};