Harmony使用预签名URL下载文件

更新时间:2025-03-10 10:31:36

默认情况下,OSS Bucket中的文件是私有的,仅文件拥有者可访问。本文介绍如何使用OSS Python SDK生成带有过期时间的GET方法预签名URL,以允许他人临时下载文件。在有效期内可多次访问,超期后需重新生成。

注意事项

  • 关于OSS支持的RegionEndpoint的对应关系,请参见OSS地域和访问域名

  • 生成GET方法的预签名URL时,您必须具有oss:GetObject权限。具体操作,请参见RAM用户授权自定义的权限策略

    说明

    在生成预签名 URL 的过程中,SDK 利用本地存储的密钥信息,根据特定算法计算出预签名(signature),然后将其附加到 URL 上,以确保 URL 的有效性和安全性。这一系列计算和构造 URL 的操作都是在客户端完成的,不涉及网络请求到服务端。因此,生成预签名 URL 时不需要授予调用者特定权限。然而,为避免第三方用户无法对预签名URL授权的资源执行相关操作,需要确保调用生成预签名 URL 接口的身份主体已被授予相应的权限。

  • 本文示例代码使用V4预签名URL,有效期最大为7天。更多信息,请参见签名版本4(推荐)

使用过程

使用预签名URL下载文件的过程如下:

image

示例代码

  1. 文件拥有者生成GET方法的预签名URL。

    import Client from '@aliyun/oss';
    
    // 创建OSS客户端实例
    const client = new Client({
      // 请替换为STS临时访问凭证的Access Key ID
      accessKeyId: 'yourAccessKeyId',
      // 请替换为STS临时访问凭证的Access Key Secret
      accessKeySecret: 'yourAccessKeySecret',
      // 请替换为STS临时访问凭证的Security Token
      securityToken: 'yourSecurityToken',
      // 填写Bucket所在地域。以华东1(杭州)为例,Region填写为oss-cn-hangzhou
      region: 'oss-cn-hangzhou',
    });
    
    // 指定要操作的Bucket名称,请替换为您实际使用的Bucket名称
    const bucket = 'yourBucketName';
    // 指定要生成签名URL的对象(文件)名称,请替换为您实际要操作的对象名称
    const key = 'yourObjectName';
    
    /**
     * 生成用于获取对象的签名URL。
     * 使用signatureUrl方法生成一个用于GET请求的签名URL,默认使用Client.options.signVersion。
     */
    const signatureUrlForGetObject = async () => {
      /**
       * 如果未明确声明使用哪个签名版本,默认使用Client.options.signVersion。
       */
      const url = await client.signatureUrl({
        bucket, // Bucket名称
        key,    // 对象(文件)名称
        expires: 60 * 60, // 设置过期时间为60分钟(单位为秒)
      });
    
      // 打印生成的签名URL
      console.log(url);
    };
    
    signatureUrlForGetObject();
    
  2. 其他人使用GET方法的预签名URL下载文件。

    curl
    Java
    Node.js
    Python
    Go
    JavaScript
    Android-Java
    Objective-C
    curl -SO "https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241112T092756Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a939feb8d79a389572719f7e2939939936d0**********"
    import java.io.BufferedInputStream;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.HttpURLConnection;
    import java.net.URL;
    
    public class Demo {
        public static void main(String[] args) {
            // 替换为生成的GET方法的预签名URL。
            String fileURL = "https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241112T092756Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a939feb8d79a389572719f7e2939939936d0**********";
            // 填写文件保存的目标路径,包括文件名和扩展名。
            String savePath = "C:/downloads/myfile.txt";
    
            try {
                downloadFile(fileURL, savePath);
                System.out.println("Download completed!");
            } catch (IOException e) {
                System.err.println("Error during download: " + e.getMessage());
            }
        }
    
        private static void downloadFile(String fileURL, String savePath) throws IOException {
            URL url = new URL(fileURL);
            HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
            httpConn.setRequestMethod("GET");
    
            // 检查响应代码
            int responseCode = httpConn.getResponseCode();
            if (responseCode == HttpURLConnection.HTTP_OK) {
                // 输入流
                InputStream inputStream = new BufferedInputStream(httpConn.getInputStream());
                // 输出流
                FileOutputStream outputStream = new FileOutputStream(savePath);
    
                byte[] buffer = new byte[4096]; // 缓冲区
                int bytesRead;
                while ((bytesRead = inputStream.read(buffer)) != -1) {
                    outputStream.write(buffer, 0, bytesRead);
                }
    
                outputStream.close();
                inputStream.close();
            } else {
                System.out.println("No file to download. Server replied HTTP code: " + responseCode);
            }
            httpConn.disconnect();
        }
    }
    const https = require('https');
    const fs = require('fs');
    
    const fileURL = "https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241112T092756Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a939feb8d79a389572719f7e2939939936d0**********";
    const savePath = "C:/downloads/myfile.txt";
    
    https.get(fileURL, (response) => {
        if (response.statusCode === 200) {
            const fileStream = fs.createWriteStream(savePath);
            response.pipe(fileStream);
            
            fileStream.on('finish', () => {
                fileStream.close();
                console.log("Download completed!");
            });
        } else {
            console.error(`Download failed. Server responded with code: ${response.statusCode}`);
        }
    }).on('error', (err) => {
        console.error("Error during download:", err.message);
    });
    import requests
    
    file_url = "https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241112T092756Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a939feb8d79a389572719f7e2939939936d0**********"
    save_path = "C:/downloads/myfile.txt"
    
    try:
        response = requests.get(file_url, stream=True)
        if response.status_code == 200:
            with open(save_path, 'wb') as f:
                for chunk in response.iter_content(4096):
                    f.write(chunk)
            print("Download completed!")
        else:
            print(f"No file to download. Server replied HTTP code: {response.status_code}")
    except Exception as e:
        print("Error during download:", e)
    package main
    
    import (
        "io"
        "net/http"
        "os"
    )
    
    func main() {
        fileURL := "https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241112T092756Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a939feb8d79a389572719f7e2939939936d0**********"
        savePath := "C:/downloads/myfile.txt"
    
        response, err := http.Get(fileURL)
        if err != nil {
            panic(err)
        }
        defer response.Body.Close()
    
        if response.StatusCode == http.StatusOK {
            outFile, err := os.Create(savePath)
            if err != nil {
                panic(err)
            }
            defer outFile.Close()
    
            _, err = io.Copy(outFile, response.Body)
            if err != nil {
                panic(err)
            }
            println("Download completed!")
        } else {
            println("No file to download. Server replied HTTP code:", response.StatusCode)
        }
    }
    const fileURL = "https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241112T092756Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a939feb8d79a389572719f7e2939939936d0**********";
    const savePath = "C:/downloads/myfile.txt"; // 文件将在下载时使用的文件名
    
    fetch(fileURL)
        .then(response => {
            if (!response.ok) {
                throw new Error(`Server replied HTTP code: ${response.status}`);
            }
            return response.blob(); // 将响应转换为 blob
        })
        .then(blob => {
            const link = document.createElement('a');
            link.href = window.URL.createObjectURL(blob);
            link.download = savePath; // 设置下载文件的名字
            document.body.appendChild(link); // 此步骤确保链接存在于文档中
            link.click(); // 模拟点击下载链接
            link.remove(); // 完成后移除链接
            console.log("Download completed!");
        })
        .catch(error => {
            console.error("Error during download:", error);
        });
    import android.os.AsyncTask;
    import android.os.Environment;
    import java.io.BufferedInputStream;
    import java.io.FileOutputStream;
    import java.io.InputStream;
    import java.net.HttpURLConnection;
    import java.net.URL;
    
    public class DownloadTask extends AsyncTask<String, String, String> {
        @Override
        protected String doInBackground(String... params) {
            String fileURL = params[0];
            String savePath = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS) + "/myfile.txt"; // 修改后的保存路径
            try {
                URL url = new URL(fileURL);
                HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
                httpConn.setRequestMethod("GET");
                int responseCode = httpConn.getResponseCode();
                if (responseCode == HttpURLConnection.HTTP_OK) {
                    InputStream inputStream = new BufferedInputStream(httpConn.getInputStream());
                    FileOutputStream outputStream = new FileOutputStream(savePath);
                    byte[] buffer = new byte[4096];
                    int bytesRead;
                    while ((bytesRead = inputStream.read(buffer)) != -1) {
                        outputStream.write(buffer, 0, bytesRead);
                    }
                    outputStream.close();
                    inputStream.close();
                    return "Download completed!";
                } else {
                    return "No file to download. Server replied HTTP code: " + responseCode;
                }
            } catch (Exception e) {
                return "Error during download: " + e.getMessage();
            }
        }
    }
    #import <Foundation/Foundation.h>
    
    int main(int argc, const char * argv[]) {
        @autoreleasepool {
            // 定义文件 URL 和保存路径(修改为有效的路径)
            NSString *fileURL = @"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241112T092756Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a939feb8d79a389572719f7e2939939936d0**********";
            NSString *savePath = @"/Users/your_username/Desktop/myfile.txt"; // 请替换为您的用户名
            
            // 创建 URL 对象
            NSURL *url = [NSURL URLWithString:fileURL];
            
            // 创建下载任务
            NSURLSessionDataTask *task = [[NSURLSession sharedSession] dataTaskWithURL:url completionHandler:^(NSData *data, NSURLResponse *response, NSError *error) {
                // 错误处理
                if (error) {
                    NSLog(@"Error during download: %@", error.localizedDescription);
                    return;
                }
                
                // 检查数据
                if (!data) {
                    NSLog(@"No data received.");
                    return;
                }
                
                // 保存文件
                NSError *writeError = nil;
                BOOL success = [data writeToURL:[NSURL fileURLWithPath:savePath] options:NSDataWritingAtomic error:&writeError];
                if (success) {
                    NSLog(@"Download completed!");
                } else {
                    NSLog(@"Error saving file: %@", writeError.localizedDescription);
                }
            }];
            
            // 启动任务
            [task resume];
            
            // 让主线程继续运行以便异步请求能够完成
            [[NSRunLoop currentRunLoop] run];
        }
        return 0;
    }

常见使用场景

使用预签名URL下载指定请求头的文件

在生成GET方式的预签名URL时,如果指定了请求头,确保在通过该预签名URL发起GET请求时也包含相应的请求头,以免出现不一致,导致请求失败和预签名错误。

  1. 生成带请求头的GET方法预签名URL。

    import Client, { EHeaderKey } from '@aliyun/oss';
    
    // 创建OSS客户端实例
    const client = new Client({
      // 请替换为STS临时访问凭证的Access Key ID
      accessKeyId: 'yourAccessKeyId',
      // 请替换为STS临时访问凭证的Access Key Secret
      accessKeySecret: 'yourAccessKeySecret',
      // 请替换为STS临时访问凭证的Security Token
      securityToken: 'yourSecurityToken',
      // 填写Bucket所在地域。以华东1(杭州)为例,Region填写为oss-cn-hangzhou
      region: 'oss-cn-hangzhou',
    });
    
    // 指定要操作的Bucket名称,请替换为您实际使用的Bucket名称
    const bucket = 'yourBucketName';
    // 指定要生成签名URL的对象(文件)名称,请替换为您实际要操作的对象名称
    const key = 'yourObjectName';
    
    /**
     * 生成用于获取对象的签名URL。
     * 使用signatureUrl方法生成一个用于GET请求的签名URL,默认使用Client.options.signVersion。
     */
    const signatureUrlForGetObject = async () => {
      /**
       * 如果未明确声明使用哪个签名版本,默认使用Client.options.signVersion。
       */
      const url = await client.signatureUrl({
        bucket, // Bucket名称
        key,    // 对象(文件)名称
        expires: 60 * 60, // 设置过期时间为60分钟(单位为秒)
        headers: {
          [EHeaderKey.RANGE]: 'bytes=0-1024', // 设置Range头部
        },
      });
    
      // 打印生成的签名URL
      console.log(url);
    };
    
    signatureUrlForGetObject();
    
  2. 使用预签名URL并指定请求头下载文件。

    curl
    curl -X GET "https://examplebucket.oss-cn-hangzhou.aliyuncs.com/exampleobject.txt?x-oss-date=20241113T093321Z&x-oss-expires=3599&x-oss-signature-version=OSS4-HMAC-SHA256&x-oss-credential=LTAI5tKHJzUF3wMmACXgf1aH****************&x-oss-signature=f1746f121783eed5dab2d665da95fbca08505263e27476a46f88dbe3702af8a9***************************************" \
    -H "Range: bytes=0-1024" \
    -o "myfile.txt"
  • 本页导读 (1)
  • 注意事项
  • 使用过程
  • 示例代码
  • 常见使用场景
  • 使用预签名URL下载指定请求头的文件