美文网首页
00022.Lambda getCsvFromS3ToJson

00022.Lambda getCsvFromS3ToJson

作者: 笑着字太黑 | 来源:发表于2024-02-18 09:22 被阅读0次
    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})));
           }
      }
    

    相关文章

      网友评论

          本文标题:00022.Lambda getCsvFromS3ToJson

          本文链接:https://www.haomeiwen.com/subject/gpnpadtx.html