更新时间：2023-11-08 GMT+08:00
流式上传
开发过程中，您有任何问题可以在github上提交issue，或者在华为云对象存储服务论坛中发帖求助。接口参考文档详细介绍了每个接口的参数和使用方法。
流式上传使用stream.Readable作为对象的数据源。以下代码展示了如何进行流式上传：
上传网络流
// 引入obs库
// 使用npm安装
const ObsClient = require('esdk-obs-nodejs');
// 使用源码安装
// const ObsClient = require('./lib/obs');
// 创建ObsClient实例
var obsClient = new ObsClient({
//推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
//您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
access_key_id: process.env.ACCESS_KEY_ID,
secret_access_key: process.env.SECRET_ACCESS_KEY,
server : 'https://your-endpoint'
});
// 定义网络流URL。
const url = 'https://www.example.com'
// 引入http库、https库。
const http = require('http');
const https = require('https');
// 根据URL选择对应的请求库。
const request = url.startsWith('http') ? http : https;
// 获取网络流。
request.get(url, (res) => {
if (res.statusCode === 200) {
// 获取网络流成功后调用putObject方法。
obsClient.putObject({
// Bucket名称，例如examplebucket。
Bucket: 'examplebucket',
// 填写Object完整路径，例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。
Key: 'exampledir/exampleobject.txt',
// res 是http.IncomingMessage类的实例，是一个可读流。
Body: res
}, (err, result) => {
if (err) {
console.error('Error-->' + err);
// 这里处理网络异常或者其他异常。
} else {
console.log('Status-->' + result.CommonMsg.Status);
// 这里处理业务代码。
}
});
}
});
上传文件流
// 引入obs库
// 使用npm安装
const ObsClient = require('esdk-obs-nodejs');
// 使用源码安装
// const ObsClient = require('./lib/obs');
// 创建ObsClient实例
var obsClient = new ObsClient({
//推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
//您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
access_key_id: process.env.ACCESS_KEY_ID,
secret_access_key: process.env.SECRET_ACCESS_KEY,
server : 'https://your-endpoint'
});
const fs = require('fs');
// 填写本地文件的完整路径，从本地文件中读取数据流。
// 如果本地文件的完整路径中未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件。
const stream = fs.createReadStream('D:\\localpath\\examplefile.txt');
obsClient.putObject({
// Bucket名称，例如examplebucket。
Bucket: 'examplebucket',
// 填写Object完整路径，例如exampledir/exampleobject.txt。Object完整路径中不能包含Bucket名称。
Key: 'exampledir/exampleobject.txt',
// stream 是一个文件可读流。
Body: stream
}, (err, result) => {
if(err){
console.error('Error-->' + err);
}else{
console.log('Status-->' + result.CommonMsg.Status);
}
});
- 使用Body参数指定待上传的流数据时，其值必须是一个stream.Readable实例。
- 大文件上传建议使用分段上传。
- 上传内容大小不能超过5GB。
父主题： 上传对象
