Nodejs AWS SDK模块node-aws-sdk的使用

Nodejs AWS SDK模块node-aws-sdk的使用
node-aws-sdk 是 Node.js 环境中使用 AWS 服务的官方 SDK。它提供了一种简单的方法来与 AWS 的各种服务进行交互，如 S3、DynamoDB、EC2 等等。下面是一些基本的使用示例。

安装

首先，你需要安装 aws-sdk 模块。你可以通过 npm 来安装：

npm install aws-sdk

配置

在使用任何 AWS 服务之前，你需要配置你的 AWS 凭证和区域。你可以通过环境变量、配置文件或直接在代码中设置这些值。

使用环境变量

export AWS_ACCESS_KEY_ID=your_access_key_id
export AWS_SECRET_ACCESS_KEY=your_secret_access_key
export AWS_REGION=us-west-2

在代码中设置

const AWS = require('aws-sdk');

AWS.config.update({
    accessKeyId: 'your_access_key_id',
    secretAccessKey: 'your_secret_access_key',
    region: 'us-west-2'
});

示例：使用 S3 服务

以下是一个简单的例子，展示如何使用 S3 服务创建一个桶（bucket）并上传一个文件。

const AWS = require('aws-sdk');
const s3 = new AWS.S3();

// 创建一个新的桶
async function createBucket(bucketName) {
    try {
        const data = await s3.createBucket({ Bucket: bucketName }).promise();
        console.log(`Bucket ${bucketName} created`);
    } catch (error) {
        console.error(error);
    }
}

// 上传文件到 S3 桶
async function uploadFile(bucketName, filePath, key) {
    const fileStream = fs.createReadStream(filePath);
    fileStream.on('error', (err) => {
        console.log('File Error', err);
    });

    const params = {
        Bucket: bucketName,
        Key: key,
        Body: fileStream
    };

    try {
        const data = await s3.upload(params).promise();
        console.log(`File uploaded successfully. ${data.Location}`);
    } catch (error) {
        console.error(error);
    }
}

(async () => {
    const bucketName = 'your-bucket-name';
    const filePath = '/path/to/your/file.txt';
    const key = 'file.txt';

    // 创建桶
    await createBucket(bucketName);

    // 上传文件
    await uploadFile(bucketName, filePath, key);
})();

示例：使用 DynamoDB 服务

以下是如何使用 DynamoDB 创建表并插入数据的例子：

const AWS = require('aws-sdk');
const dynamoDb = new AWS.DynamoDB.DocumentClient();

// 创建表
async function createTable() {
    const params = {
        TableName: 'YourTableName',
        KeySchema: [
            { AttributeName: 'id', KeyType: 'HASH' },  // Partition key
        ],
        AttributeDefinitions: [
            { AttributeName: 'id', AttributeType: 'S' },
        ],
        ProvisionedThroughput: {
            ReadCapacityUnits: 1,
            WriteCapacityUnits: 1
        }
    };

    try {
        const data = await dynamoDb.createTable(params).promise();
        console.log('Table created');
    } catch (error) {
        console.error(error);
    }
}

// 插入数据
async function putItem() {
    const params = {
        TableName: 'YourTableName',
        Item: {
            id: '1',
            name: 'John Doe'
        }
    };

    try {
        const data = await dynamoDb.put(params).promise();
        console.log('Item inserted');
    } catch (error) {
        console.error(error);
    }
}

(async () => {
    // 创建表
    await createTable();

    // 插入数据
    await putItem();
})();

以上就是使用 node-aws-sdk 进行基本操作的一些示例。你可以根据需要调整这些代码以适应你的具体需求。