AWS Lambda 函数写入 S3
AWS Lambda function write to S3
我在 AWS 中有一个 Node 4.3 Lambda 函数。我希望能够将文本文件写入 S3,并且阅读了许多关于如何与 S3 集成的教程。然而,它们都是关于如何在 writing to S3.
之后调用 Lambda 函数的。
如何使用节点从 Lambda 在 S3 中创建文本文件?这可能吗?亚马逊的文档似乎没有涵盖它。
是的,绝对有可能!
var AWS = require('aws-sdk');
function putObjectToS3(bucket, key, data){
var s3 = new AWS.S3();
var params = {
Bucket : bucket,
Key : key,
Body : data
}
s3.putObject(params, function(err, data) {
if (err) console.log(err, err.stack); // an error occurred
else console.log(data); // successful response
});
}
通过选择或更新您的 lambda 在其下执行的 IAM 角色,确保为您的 Lambda 函数提供对目标 s3 存储桶/密钥路径所需的写入权限。
要添加的 IAM 语句:
{
"Sid": "Stmt1468366974000",
"Effect": "Allow",
"Action": "s3:*",
"Resource": [
"arn:aws:s3:::my-bucket-name-goes-here/optional-path-before-allow/*"
]
}
进一步阅读:
- AWS JavaScript SDK
- 具体的“Put Object”详情
您可以使用
在 s3 上上传文件
aws-sdk
如果您使用的是 IAM 用户,那么您必须提供访问密钥和密钥,并确保您已向 IAM[=21= 提供必要的权限] 用户。
var AWS = require('aws-sdk');
AWS.config.update({accessKeyId: "ACCESS_KEY",secretAccessKey: 'SECRET_KEY'});
var s3bucket = new AWS.S3({params: {Bucket: 'BUCKET_NAME'}});
function uploadFileOnS3(fileName, fileData){
var params = {
Key: fileName,
Body: fileData,
};
s3bucket.upload(params, function (err, res) {
if(err)
console.log("Error in uploading file on s3 due to "+ err)
else
console.log("File successfully uploaded.")
});
}
这里我暂时硬编码了 AWS 访问和密钥以用于测试目的。有关最佳实践,请参阅 documentation.
serverless.com 的 IAM 语句 - 将 S3 写入特定存储桶
service: YOURSERVICENAME
provider:
name: aws
runtime: nodejs8.10
stage: dev
region: eu-west-1
timeout: 60
iamRoleStatements:
- Effect: "Allow"
Action:
- s3:PutObject
Resource: "**BUCKETARN**/*"
- Effect: "Deny"
Action:
- s3:DeleteObject
Resource: "arn:aws:s3:::**BUCKETARN**/*"
在 'Task timed out after X' 长时间的沉默失败之后没有任何好的错误消息,我回到了开始,亚马逊默认模板示例,并且成功了!
> Lambda > Functions > Create function > Use a blueprints > filter: s3.
这是我对亚马逊示例的调整版本:
const aws = require('aws-sdk');
const s3 = new aws.S3({ apiVersion: '2006-03-01' });
async function uploadFileOnS3(fileData, fileName){
const params = {
Bucket: "The-bucket-name-you-want-to-save-the-file-to",
Key: fileName,
Body: JSON.stringify(fileData),
};
try {
const response = await s3.upload(params).promise();
console.log('Response: ', response);
return response;
} catch (err) {
console.log(err);
}
};
我在 AWS 中有一个 Node 4.3 Lambda 函数。我希望能够将文本文件写入 S3,并且阅读了许多关于如何与 S3 集成的教程。然而,它们都是关于如何在 writing to S3.
之后调用 Lambda 函数的。如何使用节点从 Lambda 在 S3 中创建文本文件?这可能吗?亚马逊的文档似乎没有涵盖它。
是的,绝对有可能!
var AWS = require('aws-sdk');
function putObjectToS3(bucket, key, data){
var s3 = new AWS.S3();
var params = {
Bucket : bucket,
Key : key,
Body : data
}
s3.putObject(params, function(err, data) {
if (err) console.log(err, err.stack); // an error occurred
else console.log(data); // successful response
});
}
通过选择或更新您的 lambda 在其下执行的 IAM 角色,确保为您的 Lambda 函数提供对目标 s3 存储桶/密钥路径所需的写入权限。
要添加的 IAM 语句:
{
"Sid": "Stmt1468366974000",
"Effect": "Allow",
"Action": "s3:*",
"Resource": [
"arn:aws:s3:::my-bucket-name-goes-here/optional-path-before-allow/*"
]
}
进一步阅读:
- AWS JavaScript SDK
- 具体的“Put Object”详情
您可以使用
在 s3 上上传文件aws-sdk
如果您使用的是 IAM 用户,那么您必须提供访问密钥和密钥,并确保您已向 IAM[=21= 提供必要的权限] 用户。
var AWS = require('aws-sdk');
AWS.config.update({accessKeyId: "ACCESS_KEY",secretAccessKey: 'SECRET_KEY'});
var s3bucket = new AWS.S3({params: {Bucket: 'BUCKET_NAME'}});
function uploadFileOnS3(fileName, fileData){
var params = {
Key: fileName,
Body: fileData,
};
s3bucket.upload(params, function (err, res) {
if(err)
console.log("Error in uploading file on s3 due to "+ err)
else
console.log("File successfully uploaded.")
});
}
这里我暂时硬编码了 AWS 访问和密钥以用于测试目的。有关最佳实践,请参阅 documentation.
serverless.com 的 IAM 语句 - 将 S3 写入特定存储桶
service: YOURSERVICENAME
provider:
name: aws
runtime: nodejs8.10
stage: dev
region: eu-west-1
timeout: 60
iamRoleStatements:
- Effect: "Allow"
Action:
- s3:PutObject
Resource: "**BUCKETARN**/*"
- Effect: "Deny"
Action:
- s3:DeleteObject
Resource: "arn:aws:s3:::**BUCKETARN**/*"
在 'Task timed out after X' 长时间的沉默失败之后没有任何好的错误消息,我回到了开始,亚马逊默认模板示例,并且成功了!
> Lambda > Functions > Create function > Use a blueprints > filter: s3.
这是我对亚马逊示例的调整版本:
const aws = require('aws-sdk');
const s3 = new aws.S3({ apiVersion: '2006-03-01' });
async function uploadFileOnS3(fileData, fileName){
const params = {
Bucket: "The-bucket-name-you-want-to-save-the-file-to",
Key: fileName,
Body: JSON.stringify(fileData),
};
try {
const response = await s3.upload(params).promise();
console.log('Response: ', response);
return response;
} catch (err) {
console.log(err);
}
};