批量下载

本示例用于批量下载对象。

// 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全；本示例以ak和sk保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量AccessKeyID和SecretAccessKey。
// 前端本身没有process对象，可以使用webpack类打包工具定义环境变量，就可以在代码中运行了。
// 您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
const AK = process.env.AccessKeyID
const SK = process.env.SecretAccessKey
// 【可选】如果使用临时AKSK和SecurityToken访问OBS，则同样推荐通过环境变量获取
const security_token= process.env.SecurityToken
//  server填写Bucket对应的Endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
const server = "https://obs.cn-north-4.myhuaweicloud.com"
// 创建ObsClient实例
var obsClient = new ObsClient({
    access_key_id: AK,
    secret_access_key: SK,
    server: server
});

// 桶名
var bucket = 'ztw-test11';
// 要下载的对象前缀（为空则下载所有对象）
var prefix = 'prefix/';
// 触发浏览器下载
function downloadBlob(blob, filename) {
    var url = URL.createObjectURL(blob);
    var a = document.createElement('a');
    a.href = url;
    a.download = filename;
    document.body.appendChild(a);
    a.click();
    document.body.removeChild(a);
    URL.revokeObjectURL(url);
}
async function getObjects() {
    var marker = '';
    var totalCount = 0;
    console.log('开始列举并下载对象...');
    while (true) {
        var listParams = { Bucket: bucket };
        if (prefix) {
            listParams.Prefix = prefix;
        }
        if (marker) {
            listParams.Marker = marker;
        }
        var listResult = await obsClient.listObjects(listParams);
        if (listResult.CommonMsg.Status <= 300) {
            if (listResult.InterfaceResult.Contents) {
                var batchCount = listResult.InterfaceResult.Contents.length;
                console.log('本批获取 ' + batchCount + ' 个对象，开始下载...');
                for (var i = 0; i < listResult.InterfaceResult.Contents.length; i++) {
                    var key = listResult.InterfaceResult.Contents[i].Key;
                    var size = listResult.InterfaceResult.Contents[i].Size;
                    totalCount++;
                    try {
                        var params = {
                            Bucket: bucket,
                            Key: key,
                            SaveByType: 'arraybuffer'
                        };
                        var result = await obsClient.getObject(params);
                        if (result.CommonMsg.Status <= 300) {
                            var blob = new Blob([result.InterfaceResult.Content]);
                            downloadBlob(blob, key.split('/').pop());
                            console.log('[' + totalCount + '] 成功: ' + key + ' (' + size + ' bytes)');
                        } else {
                            console.log('[' + totalCount + '] 失败: ' + key + ' - ' + result.CommonMsg.Message);
                        }
                    } catch (error) {
                        console.log('[' + totalCount + '] 异常: ' + key + ' - ' + error);
                    }
                }
            }
            if (listResult.InterfaceResult.IsTruncated == 'true') {
                marker = listResult.InterfaceResult.NextMarker;
            } else {
                break;
            }
        } else {
            console.log('列举对象失败:', listResult.CommonMsg.Message);
            return;
        }
    }
    console.log('批量下载完成，共处理 ' + totalCount + ' 个对象！');
}
getObjects()