使用 AdonisJS 5 的文件存储 (S3)

Question

在 AdonisJS v4 文档中，我们有这一部分解释如何将文件流式传输到 S3 存储桶。我在 AdonisJS v5 文档中寻找类似的东西，但它只是一个如何将文件上传到本地服务器的示例。如果它还没有准备好，因为 Adonis 5 不是它的最新版本，这是通过 Adonis v5（特别是打字稿）将文件上传到 S3 的另一种方式？

Answer 1

我找到了一种使用 aws-sdk 执行此操作的方法，此代码并非 100% 我的代码：

uploadToS3Bucket功能：

import * as AWS from "aws-sdk";

import { v4 as uuid } from "uuid";

const s3 = new AWS.S3({

  region: process.env.AWS_REGION,

  secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,

  accessKeyId: process.env.AWS_ACCESS_KEY_ID,

});

export const uploadToS3Bucket = async (

  file: any,

  bucket: string

): Promise<{ key: string; url: string }> => {

  try {

    const { type, subtype, extname } = file;

    let mimeType = type + "/" + subtype;

    let fileType = "image/jpg";

    const name = uuid() + "." + extname;

    let buffer = Buffer.from(JSON.stringify(file), "utf-8");

    await s3

      .putObject({

        Key: name,

        Bucket: bucket,

        ContentType: fileType,

        Body: buffer.toString("base64"),

        ACL: "public-read",

      })

      .promise();

    let url = `https://${bucket}.s3.amazonaws.com/${name}`;

    console.log(url);

    return {

      key: name,

      url,

    };

  } catch (err) {

    console.log(err);

    return err;

  }

};

在控制器中：

public async store({ request }: HttpContextContract) {

  let file = getFileFromRequest(request, "defined_file_prop_name_here");

  if (file) {

    await uploadToS3Bucket(file, BUCKET_NAME);

  }

}

Answer 2

Adonis 4 使用flydrive来实现 s3 存储，您也可以使用它来简化和节省时间。使用 flydrive 配置和实例化后非常简单

// Supported drivers: "local", "s3", "gcs"
await storage.disk('s3').put('testfile.txt', 'filecontents');

Answer 3

您可以在没有 ACL 权限问题的情况下使用它

不要忘记安装 S3 驱动器：https ://docs.adonisjs.com/guides/drive

多个图像的示例：

import Route from '@ioc:Adonis/Core/Route'

import Drive from '@ioc:Adonis/Core/Drive'

import fs from 'fs'

import path from 'path'

import { string } from '@ioc:Adonis/Core/Helpers'

Route.post('upload', async ({ request }) => {

   const images = request.files('images')

   for (let image of images) {

      if (image !== null) {

         const slugFileName = string.camelCase(path.parse(image.clientName).name).toLowerCase();

         const fileName = `${slugFileName}.${image.extname}`

         const fileStream = fs.createReadStream(image.tmpPath!)

         await Drive.putStream(fileName, fileStream, {

            contentType: image.headers['content-type']

         })

      }

   }

})

如果要上传单张图片：

Route.post('upload', async ({ request }) => {

   const image = request.file('image')

      if (image !== null) {

         const slugFileName = string.camelCase(path.parse(image.clientName).name).toLowerCase();

         const fileName = `${slugFileName}.${image.extname}`

         const fileStream = fs.createReadStream(image.tmpPath!)

         await Drive.putStream(fileName, fileStream, {

            contentType: image.headers['content-type']

         })

      }

})