nodejs 之 express 实现下载网络图片并上传到七牛云对象存储oss空间
为方便阅读,本文将所有逻辑放在一个函数里,可根据自己的情况拆分。
安装依赖
在项目根目录下运行以下命令安装依赖
npm install express qiniu axios
业务逻辑
在项目根目录下创建一个名为 app.js 的文件,并添加以下内容
const express = require('express');
const app = express();
const axios = require('axios');
const qiniu = require('qiniu');// 填写你的七牛云 Access Key 和 Secret Key 以及 空间名称 bucket
const accessKey = 'YOUR_QINIU_ACCESS_KEY';
const secretKey = 'YOUR_QINIU_SECRET_KEY';
const bucket = 'YOUR_QINIU_BUCKET';// 创建七牛云对象并配置
const config = new qiniu.conf.Config();
const formUploader = new qiniu.form_up.FormUploader(config);
const putExtra = new qiniu.form_up.PutExtra();// 获取七牛认证信息
const mac = new qiniu.auth.digest.Mac(accessKey, secretKey);
const options = {scope: bucket,expires: 3600 // 设置凭证的有效时间,单位为秒,默认为3600秒(1小时)
};
const putPolicy = new qiniu.rs.PutPolicy(options);
const uploadToken = putPolicy.uploadToken(mac);// 设置 Express 路由
app.get('/download', async (req, res) => {const imageUrl = req.query.url;// 下载图片const response = await axios.get(imageUrl, {responseType: 'arraybuffer'});const dataBuffer = Buffer.from(response.data, 'binary');// 生成唯一的文件名const key = Date.now().toString() + '.jpg';// 上传图片到七牛云formUploader.put(uploadToken,key,dataBuffer,putExtra,function (respErr, respBody, respInfo) {if (respErr) {throw respErr;}if (respInfo.statusCode === 200) {res.send('图片上传成功!');} else {res.send('图片上传失败!');}});
});// 启动 Express 服务器
app.listen(3000, () => {console.log('Server is running on port 3000');
});
你可以通过访问 http://localhost:3000/download?url=IMAGE_URL
来下载远程图片并将其存储到七牛云,其中 IMAGE_URL 是你希望下载的远程图片的URL