import { S3Client, GetObjectCommand } from '@aws-sdk/client-s3';
const s3 = new S3Client({region: process.env.REGION});
import csv from 'csvtojson'
export const handler = async (event) => {
try {
const command = new GetObjectCommand({
Bucket: process.env.S3_BUCKET_NAME,
Key: process.env.S3_OBJECTKEY
});
const s3Obj = await getS3Object(command);
for (let i = 0; i < s3Obj.length; i++) {
console.log(`UserName: [${s3Obj[i].username}].`);
}
return { statusCode: 200, body: {aaa: XXXX, bbb: XXXX} };
} catch (error) {
if (error.name && error.name == 'XXXX') {
}
console.error(error);
return { statusCode: 500, body: {aaa: XXXX, bbb: XXXX} };
}
}
async function getS3Object(command) {
try {
const response = await s3.send(command);
const stringRes = await response.Body.transformToString('utf-8');
const json = csv().fromString(stringRes);
return json;
} catch (e) {
throw new Error((JSON.stringify({aaa: XXXX, bbb: XXXX})));
}
}
网友评论