# 2. 项目初始化
serverless create –template aws-nodejs –path my-api-service
cd my-api-service

# 3. 安装依赖
npm install aws-sdk uuid

# 4. 创建函数代码
cat > handler.js << 'EOF' const AWS = require('aws-sdk'); const uuid = require('uuid'); const dynamodb = new AWS.DynamoDB.DocumentClient(); const TABLE_NAME = process.env.TABLE_NAME; module.exports.create = async (event) => {
const item = JSON.parse(event.body);
const id = uuid.v4();

await dynamodb.put({
TableName: TABLE_NAME,
Item: {
id,
…item,
createdAt: new Date().toISOString()
}
}).promise();

return {
statusCode: 201,
body: JSON.stringify({ id, …item })
};
};

module.exports.get = async (event) => {
const { id } = event.pathParameters;

const result = await dynamodb.get({
TableName: TABLE_NAME,
Key: { id }
}).promise();

if (!result.Item) {
return {
statusCode: 404,
body: JSON.stringify({ error: ‘Item not found’ })
};
}

return {
statusCode: 200,
body: JSON.stringify(result.Item)
};
};

module.exports.update = async (event) => {
const { id } = event.pathParameters;
const updates = JSON.parse(event.body);

const expression = [];
const values = {};

Object.keys(updates).forEach(key => {
expression.push(`${key} = :${key}`);
values[`:${key}`] = updates[key];
});

await dynamodb.update({
TableName: TABLE_NAME,
Key: { id },
UpdateExpression: `SET ${expression.join(‘, ‘)}`,
ExpressionAttributeValues: values,
ReturnValues: ‘ALL_NEW’
}).promise();

return {
statusCode: 200,
body: JSON.stringify({ id, …updates })
};
};

module.exports.delete = async (event) => {
const { id } = event.pathParameters;

await dynamodb.delete({
TableName: TABLE_NAME,
Key: { id }
}).promise();

return {
statusCode: 204
};
};
EOF

# 5. 配置serverless.yml
cat > serverless.yml << 'EOF' service: my-api-service provider: name: aws runtime: nodejs16.x region: us-east-1 environment: TABLE_NAME: ${self:service}-${opt:stage, self:provider.stage} iam: role: statements: - Effect: Allow Action: - dynamodb:PutItem - dynamodb:GetItem - dynamodb:UpdateItem - dynamodb:DeleteItem Resource: - !GetAtt MyTable.Arn functions: create: handler: handler.create events: - http: path: items method: post get: handler: handler.get events: - http: path: items/{id} method: get update: handler: handler.update events: - http: path: items/{id} method: put delete: handler: handler.delete events: - http: path: items/{id} method: delete resources: Resources: MyTable: Type: AWS::DynamoDB::Table Properties: TableName: ${self:service}-${opt:stage, self:provider.stage} AttributeDefinitions: - AttributeName: id AttributeType: S KeySchema: - AttributeName: id KeyType: HASH ProvisionedThroughput: ReadCapacityUnits: 1 WriteCapacityUnits: 1 EOF # 6. 部署服务 serverless deploy # 7. 测试API # 创建设备 curl -X POST https://.execute-api.us-east-1.amazonaws.com/dev/items -d ‘{“name”: “Test Item”, “value”: 100}’

# 获取设备
curl https://.execute-api.us-east-1.amazonaws.com/dev/items/

# 更新设备
curl -X PUT https://.execute-api.us-east-1.amazonaws.com/dev/items/ -d ‘{“value”: 200}’

# 删除设备
curl -X DELETE https://.execute-api.us-east-1.amazonaws.com/dev/items/

# 8. 应用效果
# 无服务器API服务
# 自动扩缩容
# 按需计费
# 高可用性

# 部署脚本
cat > serverless-api.sh << 'EOF' #!/bin/bash # daily_check.sh # from:www.itpux.com.qq113257174.wx:itpux-com # web: `http://www.fgedu.net.cn` # 初始化项目 serverless create --template aws-nodejs --path my-api-service cd my-api-service # 安装依赖 npm install aws-sdk uuid # 部署服务 serverless deploy # 输出API URL echo "API URL: $(serverless info --verbose | grep ServiceEndpoint | cut -d ' ' -f 2)" EOF # 运行部署脚本 bash serverless-api.sh

# 2. 项目初始化
serverless create –template aws-nodejs –path my-data-processing
cd my-data-processing

# 3. 安装依赖
npm install aws-sdk

# 4. 创建函数代码
cat > handler.js << 'EOF' const AWS = require('aws-sdk'); const s3 = new AWS.S3(); const dynamodb = new AWS.DynamoDB.DocumentClient(); const TABLE_NAME = process.env.TABLE_NAME; module.exports.process = async (event) => {
for (const record of event.Records) {
const bucket = record.s3.bucket.name;
const key = record.s3.object.key;

// 读取S3文件
const data = await s3.getObject({ Bucket: bucket, Key: key }).promise();
const content = data.Body.toString();

// 处理数据
const items = JSON.parse(content);

// 写入DynamoDB
for (const item of items) {
await dynamodb.put({
TableName: TABLE_NAME,
Item: item
}).promise();
}

console.log(`Processed ${items.length} items from ${key}`);
}

return {
statusCode: 200,
body: ‘Data processed successfully’
};
};
EOF

# 5. 配置serverless.yml
cat > serverless.yml << 'EOF' service: my-data-processing provider: name: aws runtime: nodejs16.x region: us-east-1 environment: TABLE_NAME: ${self:service}-${opt:stage, self:provider.stage} iam: role: statements: - Effect: Allow Action: - s3:GetObject Resource: - arn:aws:s3:::${self:custom.bucket}/* - Effect: Allow Action: - dynamodb:PutItem Resource: - !GetAtt MyTable.Arn custom: bucket: my-data-bucket-${opt:stage, self:provider.stage} functions: process: handler: handler.process events: - s3: bucket: ${self:custom.bucket} event: s3:ObjectCreated:* resources: Resources: MyTable: Type: AWS::DynamoDB::Table Properties: TableName: ${self:service}-${opt:stage, self:provider.stage} AttributeDefinitions: - AttributeName: id AttributeType: S KeySchema: - AttributeName: id KeyType: HASH ProvisionedThroughput: ReadCapacityUnits: 1 WriteCapacityUnits: 1 MyBucket: Type: AWS::S3::Bucket Properties: BucketName: ${self:custom.bucket} EOF # 6. 部署服务 serverless deploy # 7. 测试数据处理 # 上传测试文件到S3 aws s3 cp test-data.json s3://my-data-bucket-dev/test-data.json # 查看CloudWatch日志 serverless logs -f process # 8. 应用效果 # 自动处理S3文件 # 无服务器数据处理 # 按需计费 # 高可用性 # 部署脚本 cat > serverless-data-processing.sh << 'EOF' #!/bin/bash # 初始化项目 serverless create --template aws-nodejs --path my-data-processing cd my-data-processing # 安装依赖 npm install aws-sdk # 部署服务 serverless deploy # 创建测试数据 cat > test-data.json << 'EOF' [ {"id": "1", "name": "Item 1", "value": 100}, {"id": "2", "name": "Item 2", "value": 200}, {"id": "3", "name": "Item 3", "value": 300} ] EOF # 上传测试数据 aws s3 cp test-data.json s3://my-data-bucket-dev/test-data.json # 查看日志 serverless logs -f process EOF # 运行部署脚本 bash serverless-data-processing.sh

# 2. 项目初始化
mkdir -p my-microservices
cd my-microservices

# 3. 创建用户服务
mkdir -p user-service
cd user-service
serverless create –template aws-nodejs

# 4. 安装依赖
npm install aws-sdk

# 5. 创建用户服务代码
cat > handler.js << 'EOF' const AWS = require('aws-sdk'); const dynamodb = new AWS.DynamoDB.DocumentClient(); const TABLE_NAME = process.env.TABLE_NAME; module.exports.createUser = async (event) => {
const user = JSON.parse(event.body);

await dynamodb.put({
TableName: TABLE_NAME,
Item: user
}).promise();

return {
statusCode: 201,
body: JSON.stringify(user)
};
};

module.exports.getUser = async (event) => {
const { id } = event.pathParameters;

const result = await dynamodb.get({
TableName: TABLE_NAME,
Key: { id }
}).promise();

if (!result.Item) {
return {
statusCode: 404,
body: JSON.stringify({ error: ‘User not found’ })
};
}

return {
statusCode: 200,
body: JSON.stringify(result.Item)
};
};
EOF

# 6. 配置用户服务
cat > serverless.yml << 'EOF' service: user-service provider: name: aws runtime: nodejs16.x region: us-east-1 environment: TABLE_NAME: ${self:service}-${opt:stage, self:provider.stage} iam: role: statements: - Effect: Allow Action: - dynamodb:PutItem - dynamodb:GetItem Resource: - !GetAtt UserTable.Arn functions: createUser: handler: handler.createUser events: - http: path: users method: post getUser: handler: handler.getUser events: - http: path: users/{id} method: get resources: Resources: UserTable: Type: AWS::DynamoDB::Table Properties: TableName: ${self:service}-${opt:stage, self:provider.stage} AttributeDefinitions: - AttributeName: id AttributeType: S KeySchema: - AttributeName: id KeyType: HASH ProvisionedThroughput: ReadCapacityUnits: 1 WriteCapacityUnits: 1 EOF # 7. 部署用户服务 serverless deploy # 8. 创建订单服务 cd .. mkdir -p order-service cd order-service serverless create --template aws-nodejs # 9. 安装依赖 npm install aws-sdk # 10. 创建订单服务代码 cat > handler.js << 'EOF' const AWS = require('aws-sdk'); const dynamodb = new AWS.DynamoDB.DocumentClient(); const lambda = new AWS.Lambda(); const TABLE_NAME = process.env.TABLE_NAME; module.exports.createOrder = async (event) => {
const order = JSON.parse(event.body);

// 验证用户存在
try {
const userResponse = await lambda.invoke({
FunctionName: process.env.USER_SERVICE_FUNCTION,
Payload: JSON.stringify({
httpMethod: ‘GET’,
pathParameters: { id: order.userId }
})
}).promise();

const user = JSON.parse(userResponse.Payload);
if (user.statusCode !== 200) {
return {
statusCode: 400,
body: JSON.stringify({ error: ‘User not found’ })
};
}
} catch (error) {
console.error(‘Error calling user service:’, error);
return {
statusCode: 500,
body: JSON.stringify({ error: ‘Internal server error’ })
};
}

// 创建订单
await dynamodb.put({
TableName: TABLE_NAME,
Item: order
}).promise();

return {
statusCode: 201,
body: JSON.stringify(order)
};
};

module.exports.getOrder = async (event) => {
const { id } = event.pathParameters;

const result = await dynamodb.get({
TableName: TABLE_NAME,
Key: { id }
}).promise();

if (!result.Item) {
return {
statusCode: 404,
body: JSON.stringify({ error: ‘Order not found’ })
};
}

return {
statusCode: 200,
body: JSON.stringify(result.Item)
};
};
EOF

# 11. 配置订单服务
cat > serverless.yml << 'EOF' service: order-service provider: name: aws runtime: nodejs16.x region: us-east-1 environment: TABLE_NAME: ${self:service}-${opt:stage, self:provider.stage} USER_SERVICE_FUNCTION: user-service-dev-getUser iam: role: statements: - Effect: Allow Action: - dynamodb:PutItem - dynamodb:GetItem Resource: - !GetAtt OrderTable.Arn - Effect: Allow Action: - lambda:InvokeFunction Resource: - arn:aws:lambda:${self:provider.region}:${AWS::AccountId}:function:user-service-dev-getUser functions: createOrder: handler: handler.createOrder events: - http: path: orders method: post getOrder: handler: handler.getOrder events: - http: path: orders/{id} method: get resources: Resources: OrderTable: Type: AWS::DynamoDB::Table Properties: TableName: ${self:service}-${opt:stage, self:provider.stage} AttributeDefinitions: - AttributeName: id AttributeType: S KeySchema: - AttributeName: id KeyType: HASH ProvisionedThroughput: ReadCapacityUnits: 1 WriteCapacityUnits: 1 EOF # 12. 部署订单服务 serverless deploy # 13. 测试微服务 # 创建用户 curl -X POST https://.execute-api.us-east-1.amazonaws.com/dev/users -d ‘{“id”: “1”, “name”: “John Doe”, “email”: “john@example.com”}’

# 创建订单
curl -X POST https://.execute-api.us-east-1.amazonaws.com/dev/orders -d ‘{“id”: “1”, “userId”: “1”, “items”: [{“id”: “1”, “name”: “Product 1”, “quantity”: 2}], “total”: 100}’

# 获取订单
curl https://.execute-api.us-east-1.amazonaws.com/dev/orders/1

# 14. 应用效果
# 无服务器微服务
# 服务间通信
# 自动扩缩容
# 按需计费

# 部署脚本
cat > serverless-microservices.sh << 'EOF' #!/bin/bash # 创建用户服务 mkdir -p user-service cd user-service serverless create --template aws-nodejs npm install aws-sdk serverless deploy # 创建订单服务 cd .. mkdir -p order-service cd order-service serverless create --template aws-nodejs npm install aws-sdk serverless deploy # 测试服务 echo "Testing user service..." curl -X POST https://.execute-api.us-east-1.amazonaws.com/dev/users -d ‘{“id”: “1”, “name”: “John Doe”, “email”: “john@example.com”}’

echo “\nTesting order service…”
curl -X POST https://.execute-api.us-east-1.amazonaws.com/dev/orders -d ‘{“id”: “1”, “userId”: “1”, “items”: [{“id”: “1”, “name”: “Product 1”, “quantity”: 2}], “total”: 100}’
EOF

# 运行部署脚本
bash serverless-microservices.sh