960 lines
38 KiB
JavaScript
960 lines
38 KiB
JavaScript
var COS = require('./lib/cos-wx-sdk-v5');
|
||
var wxfs = wx.getFileSystemManager();
|
||
var config = require('./config');
|
||
|
||
var TaskId;
|
||
|
||
|
||
// 签名回调
|
||
var getAuthorization = function(options, callback) {
|
||
|
||
// 格式一、（推荐）后端通过获取临时密钥给到前端，前端计算签名
|
||
// 服务端 JS 和 PHP 例子：https://github.com/tencentyun/cos-js-sdk-v5/blob/master/server/
|
||
// 服务端其他语言参考 COS STS SDK ：https://github.com/tencentyun/qcloud-cos-sts-sdk
|
||
wx.request({
|
||
method: 'GET',
|
||
url: config.stsUrl, // 服务端签名，参考 server 目录下的两个签名例子
|
||
dataType: 'json',
|
||
success: function(result) {
|
||
var data = result.data;
|
||
var credentials = data && data.credentials;
|
||
if (!data || !credentials) return console.error('credentials invalid');
|
||
callback({
|
||
TmpSecretId: credentials.tmpSecretId,
|
||
TmpSecretKey: credentials.tmpSecretKey,
|
||
XCosSecurityToken: credentials.sessionToken,
|
||
StartTime: data.startTime, // 时间戳，单位秒，如：1580000000，建议返回服务器时间作为签名的开始时间，避免用户浏览器本地时间偏差过大导致签名错误
|
||
ExpiredTime: data.expiredTime, // 时间戳，单位秒，如：1580000900
|
||
});
|
||
}
|
||
});
|
||
|
||
|
||
// // 格式二、（推荐）【细粒度控制权限】后端通过获取临时密钥给到前端，前端只有相同请求才重复使用临时密钥，后端可以通过 Scope 细粒度控制权限
|
||
// // 服务端例子：https://github.com/tencentyun/qcloud-cos-sts-sdk/edit/master/scope.md
|
||
// wx.request({
|
||
// method: 'POST',
|
||
// url: 'http://127.0.0.1:3000/sts-scope',
|
||
// data: options.Scope,
|
||
// dataType: 'json',
|
||
// success: function(result) {
|
||
// var data = result.data;
|
||
// var credentials = data && data.credentials;
|
||
// if (!data || !credentials) return console.error('credentials invalid');
|
||
// callback({
|
||
// TmpSecretId: credentials.tmpSecretId,
|
||
// TmpSecretKey: credentials.tmpSecretKey,
|
||
// XCosSecurityToken: credentials.sessionToken,
|
||
// StartTime: data.startTime, // 时间戳，单位秒，如：1580000000，建议返回服务器时间作为签名的开始时间，避免用户浏览器本地时间偏差过大导致签名错误
|
||
// ExpiredTime: data.expiredTime, // 时间戳，单位秒，如：1580000900
|
||
// ScopeLimit: true, // 细粒度控制权限需要设为 true，会限制密钥只在相同请求时重复使用
|
||
// });
|
||
// }
|
||
// });
|
||
|
||
|
||
// // 格式三、（不推荐，分片上传权限不好控制）前端每次请求前都需要通过 getAuthorization 获取签名，后端使用固定密钥或临时密钥计算签名返回给前端
|
||
// // 服务端获取签名，请参考对应语言的 COS SDK：https://cloud.tencent.com/document/product/436/6474
|
||
// // 注意：这种有安全风险，后端需要通过 method、pathname 严格控制好权限，比如不允许 put / 等
|
||
// wx.request({
|
||
// method: 'POST',
|
||
// url: 'https://example.com/sts-auth.php, // 服务端签名，参考 server 目录下的两个签名例子
|
||
// data: {
|
||
// method: options.Method,
|
||
// pathname: options.Pathname,
|
||
// query: options.Query,
|
||
// headers: options.Headers,
|
||
// },
|
||
// dataType: 'json',
|
||
// success: function(result) {
|
||
// var data = result.data;
|
||
// if (!data || !data.authorization) return console.error('authorization invalid');
|
||
// callback({
|
||
// Authorization: data.authorization,
|
||
// // XCosSecurityToken: data.sessionToken, // 如果使用临时密钥，需要传 sessionToken
|
||
// });
|
||
// }
|
||
// });
|
||
|
||
|
||
// // 格式四、（不推荐，适用于前端调试，避免泄露密钥）前端使用固定密钥计算签名
|
||
// var authorization = COS.getAuthorization({
|
||
// SecretId: 'AKIDxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx',
|
||
// SecretKey: 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx',
|
||
// Method: options.Method,
|
||
// Pathname: options.Pathname,
|
||
// Query: options.Query,
|
||
// Headers: options.Headers,
|
||
// Expires: 60,
|
||
// });
|
||
// callback({
|
||
// Authorization: authorization,
|
||
// // XCosSecurityToken: credentials.sessionToken, // 如果使用临时密钥，需要传 XCosSecurityToken
|
||
// });
|
||
|
||
};
|
||
|
||
var cos = new COS({
|
||
// path style 指正式请求时，Bucket 是在 path 里，这样用相同园区多个 bucket 只需要配置一个园区域名
|
||
// ForcePathStyle: true,
|
||
getAuthorization: getAuthorization,
|
||
// 是否使用全球加速域名。开启该配置后仅以下接口支持操作：putObject、getObject、headObject、optionsObject、multipartInit、multipartListPart、multipartUpload、multipartAbort、multipartComplete、multipartList、sliceUploadFile、uploadFiles
|
||
// UseAccelerate: true,
|
||
});
|
||
|
||
|
||
// 回调统一处理函数
|
||
var requestCallback = function(err, data) {
|
||
console.log(err || data);
|
||
if (err && err.error) {
|
||
wx.showModal({
|
||
title: '返回错误',
|
||
content: '请求失败：' + (err.error.Message || err.error) + '；状态码：' + err.statusCode,
|
||
showCancel: false
|
||
});
|
||
} else if (err) {
|
||
wx.showModal({
|
||
title: '请求出错',
|
||
content: '请求出错：' + err + '；状态码：' + err.statusCode,
|
||
showCancel: false
|
||
});
|
||
} else {
|
||
wx.showToast({
|
||
title: '请求成功',
|
||
icon: 'success',
|
||
duration: 3000
|
||
});
|
||
}
|
||
};
|
||
|
||
var mylog = function (msg) {
|
||
wx.showToast({
|
||
title: msg,
|
||
icon: 'success',
|
||
duration: 3000
|
||
});
|
||
};
|
||
|
||
var toolsDao = {
|
||
'request': function(){
|
||
// 对云上数据进行图片处理
|
||
cos.request({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: 'photo.png',
|
||
Method: 'POST',
|
||
Action: 'image_process',
|
||
Headers: {
|
||
// 通过 imageMogr2 接口使用图片缩放功能：指定图片宽度为 200，宽度等比压缩
|
||
'Pic-Operations': '{"is_pic_info": 1, "rules": [{"fileid": "desample_photo.jpg", "rule": "imageMogr2/thumbnail/200x/"}]}'
|
||
},
|
||
}, (err, data) => {
|
||
console.log(err || data)
|
||
});
|
||
},
|
||
'uploadFile 高级上传': function() {
|
||
var uploadFile = function(file) {
|
||
cos.uploadFile({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: file.name,
|
||
FilePath: file.path,
|
||
SliceSize: 1024 * 1024 * 5, // 文件大于5mb自动使用分块上传
|
||
onProgress: function (info) {
|
||
var percent = parseInt(info.percent * 10000) / 100;
|
||
var speed = parseInt(info.speed / 1024 / 1024 * 100) / 100;
|
||
console.log('进度：' + percent + '%; 速度：' + speed + 'Mb/s;');
|
||
},
|
||
onFileFinish: function (err, data, options) {
|
||
console.log(options.Key + '上传' + (err ? '失败' : '完成'));
|
||
},
|
||
}, function (err, data) {
|
||
console.log(err || data);
|
||
});
|
||
}
|
||
wx.chooseMessageFile({
|
||
count: 10,
|
||
type: 'all',
|
||
success: function(res) {
|
||
uploadFile(res.tempFiles[0]);
|
||
}
|
||
});
|
||
},
|
||
'uploadFiles 批量上传': function() {
|
||
var uploadFiles = function(files) {
|
||
const fileList = files.map(function(file) {
|
||
return Object.assign(file, {
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: file.name,
|
||
FilePath: file.path,
|
||
});
|
||
});
|
||
cos.uploadFiles({
|
||
files: fileList,
|
||
SliceSize: 1024 * 1024 * 5, // 文件大于5mb自动使用分块上传
|
||
onProgress: function (info) {
|
||
var percent = parseInt(info.percent * 10000) / 100;
|
||
var speed = parseInt(info.speed / 1024 / 1024 * 100) / 100;
|
||
console.log('进度：' + percent + '%; 速度：' + speed + 'Mb/s;');
|
||
},
|
||
onFileFinish: function (err, data, options) {
|
||
console.log(options.Key + '上传' + (err ? '失败' : '完成'));
|
||
},
|
||
}, function (err, data) {
|
||
console.log(err || data);
|
||
});
|
||
}
|
||
wx.chooseMessageFile({
|
||
count: 10,
|
||
type: 'all',
|
||
success: function(res) {
|
||
uploadFiles(res.tempFiles);
|
||
}
|
||
});
|
||
},
|
||
'sliceUploadFile 分片上传': function() {
|
||
var sliceUploadFile = function (file) {
|
||
var key = file.name;
|
||
cos.sliceUploadFile({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: key,
|
||
FilePath: file.path,
|
||
FileSize: file.size,
|
||
CacheControl: 'max-age=7200',
|
||
Headers: {
|
||
aa: 123,
|
||
},
|
||
Query: {
|
||
bb: 123,
|
||
},
|
||
onTaskReady: function(taskId) {
|
||
TaskId = taskId
|
||
},
|
||
onHashProgress: function(info) {
|
||
console.log('check hash', JSON.stringify(info));
|
||
},
|
||
onProgress: function(info) {
|
||
console.log(JSON.stringify(info));
|
||
}
|
||
}, requestCallback);
|
||
};
|
||
wx.chooseMessageFile({
|
||
count: 10,
|
||
type: 'all',
|
||
success: function(res) {
|
||
sliceUploadFile(res.tempFiles[0]);
|
||
}
|
||
});
|
||
// wx.chooseVideo({
|
||
// sourceType: ['album','camera'],
|
||
// maxDuration: 60,
|
||
// camera: 'back',
|
||
// success(res) {
|
||
// var name = res.tempFilePath.replace(/^.*?([^/]{32}\.\w+)$/, '$1');
|
||
// sliceUploadFile({
|
||
// name: name,
|
||
// path: res.tempFilePath,
|
||
// size: res.size,
|
||
// });
|
||
// },
|
||
// fail(err) {
|
||
// console.log(err);
|
||
// }
|
||
// })
|
||
},
|
||
// 上传文件适用于单请求上传大文件
|
||
'postObject 简单上传': function() {
|
||
wx.chooseImage({
|
||
count: 1, // 默认9
|
||
sizeType: ['original'], // 可以指定是原图还是压缩图，默认二者都有
|
||
sourceType: ['album', 'camera'], // 可以指定来源是相册还是相机，默认二者都有
|
||
success: function(res) {
|
||
var file = res.tempFiles[0];
|
||
cos.postObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.png',
|
||
FilePath: file.path,
|
||
onTaskReady: function(taskId) {
|
||
TaskId = taskId
|
||
},
|
||
onProgress: function(info) {
|
||
console.log(JSON.stringify(info));
|
||
}
|
||
}, requestCallback);
|
||
}
|
||
})
|
||
},
|
||
'putObject 简单上传文件': function(type) {
|
||
wx.chooseMessageFile({
|
||
count: 10,
|
||
type: 'all',
|
||
success: function(res) {
|
||
var file = res.tempFiles[0];
|
||
wxfs.readFile({
|
||
filePath: file.path,
|
||
success: function (res) {
|
||
cos.putObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: file.name,
|
||
Body: res.data, // 在小程序里，putObject 接口只允许传字符串的内容，不支持 TaskReady 和 onProgress，上传请使用 cos.postObject 接口
|
||
Headers: {
|
||
// 万象持久化接口，上传时持久化。例子：通过 imageMogr2 接口使用图片缩放功能：指定图片宽度为 200，宽度等比压缩
|
||
// 'Pic-Operations': '{"is_pic_info": 1, "rules": [{"fileid": "desample_photo.jpg", "rule": "imageMogr2/thumbnail/200x/"}]}'
|
||
},
|
||
}, requestCallback);
|
||
},
|
||
fail: err => console.error(err),
|
||
});
|
||
},
|
||
fail: err => console.error(err),
|
||
});
|
||
},
|
||
'putObject 上传字符串': function(type) {
|
||
cos.putObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.txt',
|
||
Body: 'hello world', // 在小程序里，putObject 接口只允许传字符串的内容，不支持 TaskReady 和 onProgress，上传请使用 cos.postObject 接口
|
||
Headers: {
|
||
aa: 123,
|
||
},
|
||
Query: {
|
||
bb: 123,
|
||
},
|
||
}, requestCallback);
|
||
},
|
||
// 上传文件
|
||
'putObject base64 转 ArrayBuffer 上传': function() {
|
||
var base64Url = 'data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAACAAAAAgCAMAAABEpIrGAAABRFBMVEUAAAAAo/8Ao/8Ao/8Ao/8ApP8Aov8Ao/8Abv8Abv8AyNwAyNwAo/8Ao/8Ao/8Abv8Ao/8AivgAo/8AyNwAbv8Abv8AydwApf8Abf8Ao/8AbP8Ao/8AyNwAydwAbv8AydwApP8Ao/8AyNwAo/8AyNwAydsAyNwAxd8Aov8AyNwAytsAo/8Abv8AyNwAbv8Av+MAo/8AytsAo/8Abv8AyNwAo/8Abv8AqfkAbv8Aov8Abv8AyNwAov8Abv8Ao/8Abv8Ao/8AydwAo/8Ao/8Ate8Ay9oAvOcAof8AveAAyNwAyNwAo/8AyNwAy9kAo/8AyNwAyNwAo/8AqP8Aaf8AyNwAbv0Abv8Abv8AaP8Ao/8Ao/8Ao/8Ao/8Abv8AyNwAgvcAaP8A0dkAo/8AyNwAav8Abv8Ao/8Abv8AyNwAy9sAvOUAtePdkYxjAAAAZnRSTlMAw/co8uAuJAn8+/Tt29R8DAX77+nZz87Jv6CTh3lxTklAPjouJRsL5tjAuLiyr62roaCakYp0XVtOQTMyLiohICAcGRP49vTv5+PJurawq6mnnJuYl4+OiIB7eXVvX15QSDgqHxNcw3l6AAABe0lEQVQ4y82P11oCQQxGIy5FUJpKk6aAhV6k92LvvXedDfj+92ZkYQHxnnMxu3/OfJMEJo6y++baXf5XVw22GVGcsRmq431mQZRYyIzRGgdXi+HwIv86NDBKisrRAtU1hSj9pkZ9jpo/9YKbRsmNNKCHDXI00BxfMMirKNpMcjQ5Lm4/YZArUXyBYUwg40nsdr5jb3LBe25VWpNeKa1GENsEnq52C80z1uW48estiKjb19G54QdCrScnKAU69U3KJ4jzrsBawDWPuOcBqMyRvlcb1Y+zjMUBVsivAKe4gXgEKiVjSh9wlunGMmwiOqFL3RI0cj+nkgp3jC1BELVFkGiZSuvkp3tZZWZ2sKCuDj185PXqfmwI7AAOUctHkJoOeXg3sxA4ES+l7CVvrYHMEmNp8GtR+wycPG0+1RrwWQUzl4CvgQmPP5Ddofl8tWkJVT7J+BIAaxEktrYZoRAUfXgOGYHfcOqw3WF/EdLccz5cMfvUCPb4QwUmhB8+v12HZPCkbgAAAABJRU5ErkJggg==';
|
||
var m = (/data:image\/(\w+);base64,(.*)/.exec(base64Url) || []);
|
||
var format = m[1];
|
||
var bodyData = m[2];
|
||
var fileBuf = wx.base64ToArrayBuffer(bodyData);
|
||
cos.putObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.' + format,
|
||
Body: fileBuf,
|
||
}, requestCallback);
|
||
},
|
||
'getObjectUrl 获取对象访问url': function() {
|
||
var url = cos.getObjectUrl({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: '1mb.zip',
|
||
Expires: 60,
|
||
Sign: true,
|
||
}, function(err, data) {
|
||
console.log(err || data);
|
||
});
|
||
console.log(url);
|
||
},
|
||
};
|
||
|
||
var bucketDao = {
|
||
// Service
|
||
'getService 获取存储桶列表': function() {
|
||
cos.getService(requestCallback);
|
||
},
|
||
// 简单 Bucket 操作
|
||
'putBucket 创建存储桶': function() {
|
||
cos.putBucket({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
}, requestCallback);
|
||
},
|
||
'headBucket 检索存储桶及其权限': function() {
|
||
cos.headBucket({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'deleteBucket 删除存储桶': function() {
|
||
cos.deleteBucket({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'getBucketACL 查询存储桶 ACL': function() {
|
||
cos.getBucketAcl({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'putBucketACL 设置存储桶 ACL': function() {
|
||
cos.putBucketAcl({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
ACL: 'public-read'
|
||
}, requestCallback);
|
||
},
|
||
'getBucketCors 查询跨域配置': function() {
|
||
cos.getBucketCors({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'putBucketCors 设置跨域配置': function() {
|
||
cos.putBucketCors({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
CORSRules: [{
|
||
"AllowedOrigin": ["*"],
|
||
"AllowedMethod": ["GET", "POST", "PUT", "DELETE", "HEAD"],
|
||
"AllowedHeader": ["*"],
|
||
"ExposeHeader": ["ETag", "Content-Length"],
|
||
"MaxAgeSeconds": "5"
|
||
}]
|
||
}, requestCallback);
|
||
},
|
||
'deleteBucketCors 删除跨域配置': function() {
|
||
cos.deleteBucketCors({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'putBucketPolicy 设置存储桶策略': function() {
|
||
var AppId = config.Bucket.substr(config.Bucket.lastIndexOf('-') + 1);
|
||
cos.putBucketPolicy({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Policy: {
|
||
"version": "2.0",
|
||
"principal": {
|
||
"qcs": ["qcs::cam::uin/10001:uin/10001"]
|
||
}, // 这里的 10001 是 QQ 号
|
||
"statement": [{
|
||
"effect": "allow",
|
||
"action": [
|
||
"name/cos:GetBucket",
|
||
"name/cos:PutObject",
|
||
"name/cos:PostObject",
|
||
"name/cos:PutObjectCopy",
|
||
"name/cos:InitiateMultipartUpload",
|
||
"name/cos:UploadPart",
|
||
"name/cos:UploadPartCopy",
|
||
"name/cos:CompleteMultipartUpload",
|
||
"name/cos:AbortMultipartUpload",
|
||
"name/cos:AppendObject"
|
||
],
|
||
// "resource": ["qcs::cos:ap-guangzhou:uid/1250000000:test-1250000000/*"] // 1250000000 是 appid
|
||
"resource": ["qcs::cos:" + config.Region + ":uid/" + AppId + ":" + config.Bucket + "/*"] // 1250000000 是 appid
|
||
}]
|
||
},
|
||
}, requestCallback);
|
||
},
|
||
'getBucketPolicy 查询存储桶策略': function() {
|
||
cos.getBucketPolicy({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'deleteBucketPolicy 删除存储桶策略': function() {
|
||
cos.deleteBucketPolicy({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'getBucketLocation 获取Bucket的地域信息': function() {
|
||
cos.getBucketLocation({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'getBucketTagging 获取Bucket标签': function() {
|
||
cos.getBucketTagging({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
'putBucketTagging 设置Bucket标签': function() {
|
||
cos.putBucketTagging({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Tagging: {
|
||
"Tags": [
|
||
{
|
||
"Key": "k1",
|
||
"Value": "v1"
|
||
},
|
||
{
|
||
"Key": "k2",
|
||
"Value": "v2"
|
||
}
|
||
]
|
||
}
|
||
}, requestCallback);
|
||
},
|
||
'deleteBucketTagging 删除存储桶标签': function() {
|
||
cos.deleteBucketTagging({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
};
|
||
|
||
var objectDao = {
|
||
'getBucket 获取对象列表': function() {
|
||
cos.getBucket({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region
|
||
}, requestCallback);
|
||
},
|
||
// 上传文件适用于单请求上传大文件
|
||
'postObject 表单上传对象': function() {
|
||
wx.chooseImage({
|
||
count: 1, // 默认9
|
||
sizeType: ['original'], // 可以指定是原图还是压缩图，默认二者都有
|
||
sourceType: ['album', 'camera'], // 可以指定来源是相册还是相机，默认二者都有
|
||
success: function(res) {
|
||
var file = res.tempFiles[0];
|
||
cos.postObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.png',
|
||
FilePath: file.path,
|
||
onTaskReady: function(taskId) {
|
||
TaskId = taskId
|
||
},
|
||
onProgress: function(info) {
|
||
console.log(JSON.stringify(info));
|
||
}
|
||
}, requestCallback);
|
||
}
|
||
})
|
||
},
|
||
'putObject 简单上传文件': function(type) {
|
||
wx.chooseMessageFile({
|
||
count: 10,
|
||
type: 'all',
|
||
success: function(res) {
|
||
var file = res.tempFiles[0];
|
||
wxfs.readFile({
|
||
filePath: file.path,
|
||
success: function (res) {
|
||
cos.putObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: file.name,
|
||
Body: res.data, // 在小程序里，putObject 接口只允许传字符串的内容，不支持 TaskReady 和 onProgress，上传请使用 cos.postObject 接口
|
||
Headers: {
|
||
// 万象持久化接口，上传时持久化。例子：通过 imageMogr2 接口使用图片缩放功能：指定图片宽度为 200，宽度等比压缩
|
||
// 'Pic-Operations': '{"is_pic_info": 1, "rules": [{"fileid": "desample_photo.jpg", "rule": "imageMogr2/thumbnail/200x/"}]}'
|
||
},
|
||
}, requestCallback);
|
||
},
|
||
fail: err => console.error(err),
|
||
});
|
||
},
|
||
fail: err => console.error(err),
|
||
});
|
||
},
|
||
'putObject 上传字符串': function(type) {
|
||
cos.putObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.txt',
|
||
Body: 'hello world', // 在小程序里，putObject 接口只允许传字符串的内容，不支持 TaskReady 和 onProgress，上传请使用 cos.postObject 接口
|
||
Headers: {
|
||
aa: 123,
|
||
},
|
||
Query: {
|
||
bb: 123,
|
||
},
|
||
}, requestCallback);
|
||
},
|
||
// 上传文件
|
||
'putObject base64 转 ArrayBuffer 上传': function() {
|
||
var base64Url = 'data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAACAAAAAgCAMAAABEpIrGAAABRFBMVEUAAAAAo/8Ao/8Ao/8Ao/8ApP8Aov8Ao/8Abv8Abv8AyNwAyNwAo/8Ao/8Ao/8Abv8Ao/8AivgAo/8AyNwAbv8Abv8AydwApf8Abf8Ao/8AbP8Ao/8AyNwAydwAbv8AydwApP8Ao/8AyNwAo/8AyNwAydsAyNwAxd8Aov8AyNwAytsAo/8Abv8AyNwAbv8Av+MAo/8AytsAo/8Abv8AyNwAo/8Abv8AqfkAbv8Aov8Abv8AyNwAov8Abv8Ao/8Abv8Ao/8AydwAo/8Ao/8Ate8Ay9oAvOcAof8AveAAyNwAyNwAo/8AyNwAy9kAo/8AyNwAyNwAo/8AqP8Aaf8AyNwAbv0Abv8Abv8AaP8Ao/8Ao/8Ao/8Ao/8Abv8AyNwAgvcAaP8A0dkAo/8AyNwAav8Abv8Ao/8Abv8AyNwAy9sAvOUAtePdkYxjAAAAZnRSTlMAw/co8uAuJAn8+/Tt29R8DAX77+nZz87Jv6CTh3lxTklAPjouJRsL5tjAuLiyr62roaCakYp0XVtOQTMyLiohICAcGRP49vTv5+PJurawq6mnnJuYl4+OiIB7eXVvX15QSDgqHxNcw3l6AAABe0lEQVQ4y82P11oCQQxGIy5FUJpKk6aAhV6k92LvvXedDfj+92ZkYQHxnnMxu3/OfJMEJo6y++baXf5XVw22GVGcsRmq431mQZRYyIzRGgdXi+HwIv86NDBKisrRAtU1hSj9pkZ9jpo/9YKbRsmNNKCHDXI00BxfMMirKNpMcjQ5Lm4/YZArUXyBYUwg40nsdr5jb3LBe25VWpNeKa1GENsEnq52C80z1uW48estiKjb19G54QdCrScnKAU69U3KJ4jzrsBawDWPuOcBqMyRvlcb1Y+zjMUBVsivAKe4gXgEKiVjSh9wlunGMmwiOqFL3RI0cj+nkgp3jC1BELVFkGiZSuvkp3tZZWZ2sKCuDj185PXqfmwI7AAOUctHkJoOeXg3sxA4ES+l7CVvrYHMEmNp8GtR+wycPG0+1RrwWQUzl4CvgQmPP5Ddofl8tWkJVT7J+BIAaxEktrYZoRAUfXgOGYHfcOqw3WF/EdLccz5cMfvUCPb4QwUmhB8+v12HZPCkbgAAAABJRU5ErkJggg==';
|
||
var m = (/data:image\/(\w+);base64,(.*)/.exec(base64Url) || []);
|
||
var format = m[1];
|
||
var bodyData = m[2];
|
||
var fileBuf = wx.base64ToArrayBuffer(bodyData);
|
||
cos.putObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.' + format,
|
||
Body: fileBuf,
|
||
}, requestCallback);
|
||
},
|
||
'getObject 下载对象': function() {
|
||
cos.getObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.png',
|
||
// 下载时使用图片处理
|
||
// QueryString: `imageMogr2/thumbnail/200x/`,
|
||
}, requestCallback);
|
||
},
|
||
'headObject 检索对象': function() {
|
||
cos.headObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.txt'
|
||
}, requestCallback);
|
||
},
|
||
'deleteObject 删除对象': function() {
|
||
cos.deleteObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.txt'
|
||
}, requestCallback);
|
||
},
|
||
'getObjectACL 获取对象ACL': function() {
|
||
cos.getObjectAcl({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.txt'
|
||
}, requestCallback);
|
||
},
|
||
'putObjectACL 设置对象ACL': function() {
|
||
cos.putObjectAcl({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: '1.txt',
|
||
// GrantFullControl: 'id="qcs::cam::uin/1001:uin/1001",id="qcs::cam::uin/1002:uin/1002"',
|
||
// GrantWrite: 'id="qcs::cam::uin/1001:uin/1001",id="qcs::cam::uin/1002:uin/1002"',
|
||
// GrantRead: 'id="qcs::cam::uin/1001:uin/1001",id="qcs::cam::uin/1002:uin/1002"',
|
||
// ACL: 'public-read-write',
|
||
// ACL: 'public-read',
|
||
// ACL: 'private',
|
||
ACL: 'default', // 继承上一级目录权限
|
||
// AccessControlPolicy: {
|
||
// "Owner": { // AccessControlPolicy 里必须有 owner
|
||
// "ID": 'qcs::cam::uin/459000000:uin/459000000' // 459000000 是 Bucket 所属用户的 QQ 号
|
||
// },
|
||
// "Grants": [{
|
||
// "Grantee": {
|
||
// "ID": "qcs::cam::uin/10002:uin/10002", // 10002 是 QQ 号
|
||
// },
|
||
// "Permission": "READ"
|
||
// }]
|
||
// }
|
||
}, requestCallback);
|
||
},
|
||
'deleteMultipleObject 批量删除对象': function() {
|
||
cos.deleteMultipleObject({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Objects: [{
|
||
Key: '1.txt'
|
||
},
|
||
{
|
||
Key: '1.copy.txt'
|
||
},
|
||
]
|
||
}, requestCallback);
|
||
},
|
||
'putObjectCopy 复制对象': function() {
|
||
cos.putObjectCopy({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: '1.copy.txt',
|
||
CopySource: config.Bucket + '.cos.' + config.Region + '.myqcloud.com/1.txt',
|
||
}, requestCallback);
|
||
},
|
||
'restoreObject 恢复归档对象': function() {
|
||
cos.restoreObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.txt',
|
||
RestoreRequest: {
|
||
Days: 1,
|
||
CASJobParameters: {
|
||
Tier: 'Expedited'
|
||
}
|
||
}
|
||
}, requestCallback);
|
||
},
|
||
'appendObject 追加上传': function() {
|
||
// 初始化一个可追加上传的对象append.txt
|
||
cos.appendObject({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: 'append.txt', /* 必须 */
|
||
Body: '12345',
|
||
Position: 0,
|
||
},
|
||
function(err, data) {
|
||
logger.log('putObject:', err || data);
|
||
})
|
||
},
|
||
'appendObject_continue 继续追加上传': function() {
|
||
// append.txt必须是一个可追加上传的对象，参考文档：https://cloud.tencent.com/document/product/436/7741
|
||
cos.headObject({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: 'append.txt', /* 必须 */
|
||
}, function(err, data) {
|
||
if (err) return console.log(err);
|
||
// 首先取到要追加的文件当前长度，即需要上送的Position
|
||
var position = data.headers['content-length'];
|
||
cos.appendObject({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: 'append.txt', /* 必须 */
|
||
Body: '66666',
|
||
Position: position,
|
||
},
|
||
function(err, data) {
|
||
// 也可以取到下一次上传的position继续追加上传
|
||
// var nextPosition = data.headers['x-cos-next-append-position'];
|
||
logger.log('putObject:', err || data);
|
||
})
|
||
});
|
||
},
|
||
'abortUploadTask 抛弃分块上传任务': function() {
|
||
cos.abortUploadTask({
|
||
Bucket: config.Bucket,
|
||
/* 必须 */ // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
/* 必须 */
|
||
// 格式1，删除单个上传任务
|
||
// Level: 'task',
|
||
// Key: '10mb.zip',
|
||
// UploadId: '14985543913e4e2642e31db217b9a1a3d9b3cd6cf62abfda23372c8d36ffa38585492681e3',
|
||
// 格式2，删除单个文件所有未完成上传任务
|
||
Level: 'file',
|
||
Key: '10mb.zip',
|
||
// 格式3，删除 Bucket 下所有未完成上传任务
|
||
// Level: 'bucket',
|
||
}, requestCallback);
|
||
},
|
||
}
|
||
|
||
var advanceObjectDao = {
|
||
'sliceUploadFile 分块上传': function() {
|
||
var sliceUploadFile = function (file) {
|
||
var key = file.name;
|
||
cos.sliceUploadFile({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: key,
|
||
FilePath: file.path,
|
||
FileSize: file.size,
|
||
CacheControl: 'max-age=7200',
|
||
Headers: {
|
||
aa: 123,
|
||
},
|
||
Query: {
|
||
bb: 123,
|
||
},
|
||
onTaskReady: function(taskId) {
|
||
TaskId = taskId
|
||
},
|
||
onHashProgress: function(info) {
|
||
console.log('check hash', JSON.stringify(info));
|
||
},
|
||
onProgress: function(info) {
|
||
console.log(JSON.stringify(info));
|
||
}
|
||
}, requestCallback);
|
||
};
|
||
wx.chooseMessageFile({
|
||
count: 10,
|
||
type: 'all',
|
||
success: function(res) {
|
||
sliceUploadFile(res.tempFiles[0]);
|
||
}
|
||
});
|
||
// wx.chooseVideo({
|
||
// sourceType: ['album','camera'],
|
||
// maxDuration: 60,
|
||
// camera: 'back',
|
||
// success(res) {
|
||
// var name = res.tempFilePath.replace(/^.*?([^/]{32}\.\w+)$/, '$1');
|
||
// sliceUploadFile({
|
||
// name: name,
|
||
// path: res.tempFilePath,
|
||
// size: res.size,
|
||
// });
|
||
// },
|
||
// fail(err) {
|
||
// console.log(err);
|
||
// }
|
||
// })
|
||
},
|
||
'sliceCopyFile 分块复制对象': function() {
|
||
// 创建测试文件
|
||
var sourceName = '1.txt';
|
||
var Key = '1.slicecopy.exe';
|
||
|
||
var sourcePath = config.Bucket + '.cos.' + config.Region + '.myqcloud.com/' + sourceName;
|
||
|
||
cos.sliceCopyFile({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: Key,
|
||
CopySource: sourcePath,
|
||
SliceSize: 20 * 1024 * 1024, // 大于20M的文件用分片复制，小于则用单片复制
|
||
onProgress: function(info) {
|
||
var percent = parseInt(info.percent * 10000) / 100;
|
||
var speed = parseInt(info.speed / 1024 / 1024 * 100) / 100;
|
||
console.log('进度：' + percent + '%; 速度：' + speed + 'Mb/s;');
|
||
}
|
||
}, requestCallback);
|
||
},
|
||
cancelTask: function() {
|
||
cos.cancelTask(TaskId);
|
||
console.log('canceled');
|
||
},
|
||
pauseTask: function() {
|
||
cos.pauseTask(TaskId);
|
||
console.log('paused');
|
||
},
|
||
restartTask: function() {
|
||
cos.restartTask(TaskId);
|
||
console.log('restart');
|
||
},
|
||
};
|
||
|
||
var ciObjectDao = {
|
||
'上传时使用图片处理': function(){
|
||
wx.chooseMessageFile({
|
||
count: 10,
|
||
type: 'all',
|
||
success: function (res) {
|
||
var file = res.tempFiles[0];
|
||
wxfs.readFile({
|
||
filePath: file.path,
|
||
success: function (res) {
|
||
cos.putObject({
|
||
Bucket: config.Bucket, // Bucket 格式：test-1250000000
|
||
Region: config.Region,
|
||
Key: file.name,
|
||
Body: res.data,
|
||
Headers: {
|
||
// 通过 imageMogr2 接口使用图片缩放功能：指定图片宽度为 200，宽度等比压缩
|
||
'Pic-Operations':
|
||
'{"is_pic_info": 1, "rules": [{"fileid": "desample_photo.jpg", "rule": "imageMogr2/thumbnail/200x/"}]}',
|
||
},
|
||
},
|
||
requestCallback,
|
||
);
|
||
},
|
||
fail: (err) => console.error(err),
|
||
});
|
||
},
|
||
fail: (err) => console.error(err),
|
||
});
|
||
},
|
||
'对云上数据进行图片处理': function(){
|
||
// 对云上数据进行图片处理
|
||
cos.request({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: 'photo.png',
|
||
Method: 'POST',
|
||
Action: 'image_process',
|
||
Headers: {
|
||
// 通过 imageMogr2 接口使用图片缩放功能：指定图片宽度为 200，宽度等比压缩
|
||
'Pic-Operations': '{"is_pic_info": 1, "rules": [{"fileid": "desample_photo.jpg", "rule": "imageMogr2/thumbnail/200x/"}]}'
|
||
},
|
||
}, requestCallback);
|
||
},
|
||
'下载时使用图片处理': function(){
|
||
cos.getObject({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: '1.png',
|
||
QueryString: `imageMogr2/thumbnail/200x/`,
|
||
}, requestCallback);
|
||
},
|
||
'生成带图片处理参数的签名 URL': function(){
|
||
// 生成带图片处理参数的文件签名URL，过期时间设置为 30 分钟。
|
||
cos.getObjectUrl({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: 'photo.png',
|
||
QueryString: `imageMogr2/thumbnail/200x/`,
|
||
Expires: 1800,
|
||
Sign: true,
|
||
},
|
||
(err, data) => {
|
||
console.log('带签名', err || data);
|
||
});
|
||
|
||
// 生成带图片处理参数的文件URL，不带签名。
|
||
cos.getObjectUrl({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Key: 'photo.png',
|
||
QueryString: `imageMogr2/thumbnail/200x/`,
|
||
Sign: false,
|
||
},
|
||
(err, data) => {
|
||
console.log('不带签名', err || data);
|
||
});
|
||
},
|
||
'describeMediaBuckets 查询已经开通数据万象功能的存储桶': function() {
|
||
var host = 'ci.' + config.Region + '.myqcloud.com';
|
||
var url = 'https://' + host + '/mediabucket';
|
||
cos.request({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Method: 'GET',
|
||
Key: 'mediabucket', /** 固定值，必须 */
|
||
Url: url,
|
||
Query: {
|
||
pageNumber: '1', /** 第几页，非必须 */
|
||
pageSize: '10', /** 每页个数，非必须 */
|
||
// regions: 'ap-chengdu', /** 地域信息，例如'ap-beijing'，支持多个值用逗号分隔如'ap-shanghai,ap-beijing'，非必须 */
|
||
// bucketNames: 'test-1250000000', /** 存储桶名称，精确搜索，例如'test-1250000000'，支持多个值用逗号分隔如'test1-1250000000,test2-1250000000'，非必须 */
|
||
// bucketName: 'test', /** 存储桶名称前缀，前缀搜索，例如'test'，支持多个值用逗号分隔如'test1,test2'，非必须 */
|
||
}
|
||
},
|
||
function(err, data){
|
||
console.log(err || data);
|
||
});
|
||
},
|
||
'getMediaInfo 获取媒体文件信息': function() {
|
||
cos.request({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Method: 'GET',
|
||
Key: 'test.mp4',
|
||
Query: {
|
||
'ci-process': 'videoinfo' /** 固定值，必须 */
|
||
}
|
||
},
|
||
function(err, data){
|
||
console.log(err || data);
|
||
});
|
||
},
|
||
'getSnapshot 获取媒体文件某个时间的截图': function() {
|
||
cos.request({
|
||
Bucket: config.Bucket,
|
||
Region: config.Region,
|
||
Method: 'GET',
|
||
Key: 'test.mp4',
|
||
Query: {
|
||
'ci-process': 'snapshot', /** 固定值，必须 */
|
||
time: 1, /** 截图的时间点，单位为秒，必须 */
|
||
// width: 0, /** 截图的宽，非必须 */
|
||
// height: 0, /** 截图的高，非必须 */
|
||
// format: 'jpg', /** 截图的格式，支持 jpg 和 png，默认 jpg，非必须 */
|
||
// rotate: 'auto', /** 图片旋转方式，默认为'auto'，非必须 */
|
||
// mode: 'exactframe', /** 截帧方式，默认为'exactframe'，非必须 */
|
||
},
|
||
RawBody: true,
|
||
},
|
||
function(err, data){
|
||
console.log(err || data);
|
||
});
|
||
},
|
||
}
|
||
|
||
// require('./test');
|
||
|
||
module.exports = {
|
||
toolsDao: toolsDao,
|
||
bucketDao: bucketDao,
|
||
objectDao: objectDao,
|
||
advanceObjectDao: advanceObjectDao,
|
||
ciObjectDao: ciObjectDao,
|
||
};
|