本地部署版本，在云函数中上传文件到oss

[seewhy163]

首先需要在域名dns解析中添加一条CNAME记录， 前缀为 *.oss ，值为 oss.mydomain.com
代码如下

import cloud from '@/cloud-sdk'
import { PutObjectCommand, S3 } from "@aws-sdk/client-s3";

// 本地部署 OSS_EXTERNAL_ENDPOINT 为 null ， 暂不清楚原因，这里直接写死endpoint路径
console.log(cloud.env.OSS_EXTERNAL_ENDPOINT);

// 在文件管理中获取 OSS EndPoint 
const ENDPINT = "http://oss.mydomain.com:8000";
// 在文件管理中获取 BUCKET
const BUCKET = "vxaq2a-data";

const s3Client = new S3({
  region: cloud.env.OSS_REGION,
  endpoint: ENDPINT,
  credentials: {
    accessKeyId: cloud.env.OSS_ACCESS_KEY,
    secretAccessKey: cloud.env.OSS_ACCESS_SECRET,
  },
});

const run = async () => {
  const uploadParams = {
    Bucket: BUCKET,
    Key: "index.html",
    Body: "Hello from laf oss!", 
    ContentType: "text/html",
  };
  try {
    const data = await s3Client.send(new PutObjectCommand(uploadParams));
    console.log("Success", data);
    return data; 
  } catch (err) {
    console.log("Error", err);
  }
};

exports.main = async function (ctx: FunctionContext) {

  await run();

  return {}
}

[SheepYang1993]

import cloud from '@/cloud-sdk'
import { PutObjectCommand, S3 } from "@aws-sdk/client-s3";

exports.main = async function (ctx: FunctionContext) {
  // body, query 为请求参数, auth 是授权对象

  const { auth, body, query } = ctx
  // 在文件管理中获取 OSS EndPoint 
  const ENDPINT = "";
  // 在文件管理中获取 BUCKET
  const BUCKET = "";

  const s3Client = new S3({
    region: cloud.env.OSS_REGION,
    endpoint: ENDPINT,
    credentials: {
      accessKeyId: cloud.env.OSS_ACCESS_KEY,
      secretAccessKey: cloud.env.OSS_ACCESS_SECRET,
    },
  forcePathStyle: true,
  });

  const file = ctx.files[0]
  console.log(file)
  const stream = require('fs').createReadStream(file.path)
  const cmd = new PutObjectCommand({
    Bucket: BUCKET,
    Key: file.originalname,
    Body:stream,
    ContentType: file.mimetype,
  })
  try {
    const data = await s3Client.send(cmd);
    return {code:200,data:data}
  } catch (err) {
    return {code:500,err:err}
  }
}