Chuyển đổi từ MongoDB sang DynamoDB

exports/
├── products.csv      (sản phẩm)
├── users.csv         (người dùng)
├── orders.csv        (đơn hàng)
├── carts.csv         (giỏ hàng)
└── categories.csv    (danh mục)

npm uninstall mongoose @nestjs/mongoose
npm install @aws-sdk/client-dynamodb @aws-sdk/lib-dynamodb

// product.service.ts
const product = await this.productModel.findById(id);

// product.repository.ts
import { Injectable } from '@nestjs/common';
import { DynamoDBClient } from "@aws-sdk/client-dynamodb";
import { GetCommand, ScanCommand, DynamoDBDocumentClient } from "@aws-sdk/lib-dynamodb";

@Injectable()
export class ProductRepository {
  private client: DynamoDBDocumentClient;

  constructor() {
    const ddbClient = new DynamoDBClient({ region: "ap-southeast-1" });
    this.client = DynamoDBDocumentClient.from(ddbClient);
  }

  async findById(id: string) {
    const result = await this.client.send(new GetCommand({
      TableName: "vinashoes-products",
      Key: { _id: id }
    }));
    return result.Item;
  }

  async findAll() {
    const result = await this.client.send(new ScanCommand({
      TableName: "vinashoes-products"
    }));
    return result.Items;
  }
}

# .env
AWS_REGION=ap-southeast-1
AWS_ACCESS_KEY_ID=your-key
AWS_SECRET_ACCESS_KEY=your-secret

# Test API endpoints vẫn hoạt động
curl http://localhost:3000/api/products

# Test pagination
curl "http://localhost:3000/api/products?limit=10&lastKey=abc123"

# Test search with GSI
curl "http://localhost:3000/api/products/category/shoes"

# Test write operations
curl -X POST http://localhost:3000/api/products \
  -H "Content-Type: application/json" \
  -d '{"name":"Test Product","price":100}'

# List all objects in the migration bucket
aws s3 ls s3://vinashoes-migration-data --recursive

# Delete all objects in the bucket
aws s3 rm s3://vinashoes-migration-data --recursive

# Delete the bucket
aws s3 rb s3://vinashoes-migration-data

# Delete products table
aws dynamodb delete-table --table-name vinashoes-products --region ap-southeast-1

# Delete users table
aws dynamodb delete-table --table-name vinashoes-users --region ap-southeast-1

# Delete orders table
aws dynamodb delete-table --table-name vinashoes-orders --region ap-southeast-1

# Delete carts table
aws dynamodb delete-table --table-name vinashoes-carts --region ap-southeast-1

# Delete categories table
aws dynamodb delete-table --table-name vinashoes-categories --region ap-southeast-1

# Delete any DynamoDB backups created during migration
aws dynamodb list-backups --region ap-southeast-1 | jq -r '.BackupSummaries[] | select(.TableName | startswith("vinashoes-")) | .BackupArn' | xargs -I {} aws dynamodb delete-backup --backup-arn {} --region ap-southeast-1

# Delete any export files in S3 (if any)
aws s3 rm s3://vinashoes-backup-exports --recursive

# Verify S3 bucket deleted
aws s3 ls | grep vinashoes-migration-data || echo "Migration bucket deleted"

# Verify DynamoDB tables deleted
aws dynamodb list-tables --region ap-southeast-1 | grep vinashoes- || echo "All DynamoDB tables deleted"

# Check remaining resources
aws dynamodb list-backups --region ap-southeast-1 | jq '.BackupSummaries | length'

# Get DynamoDB costs for last month
aws ce get-cost-and-usage \
    --time-period Start=2024-01-01,End=2024-02-01 \
    --granularity MONTHLY \
    --metrics BlendedCost \
    --group-by Type=DIMENSION,Key=SERVICE \
    --filter '{
        "Dimensions": {
            "Key": "SERVICE",
            "Values": ["Amazon DynamoDB"]
        }
    }' \
    --region us-east-1

# Monitor DynamoDB table size
aws cloudwatch get-metric-statistics \
    --namespace AWS/DynamoDB \
    --metric-name TableSizeBytes \
    --dimensions Name=TableName,Value=vinashoes-products \
    --start-time 2024-01-01T00:00:00Z \
    --end-time 2024-02-01T00:00:00Z \
    --period 86400 \
    --statistics Maximum \
    --region ap-southeast-1