unduh node.js menggunakan url yang ditandatangani sebelumnya - Object Storage Service

Secara default, objek dalam bucket Object Storage Service (OSS) bersifat privat dan hanya dapat diakses oleh pemiliknya. Anda dapat menggunakan OSS SDK untuk Node.js guna menghasilkan URL yang ditandatangani sebelumnya untuk permintaan GET, sehingga pengguna lain dapat mengunduh objek tersebut secara sementara. URL tersebut dapat diakses beberapa kali hingga masa berlakunya habis. Setelah kedaluwarsa, Anda harus membuat URL baru.

Catatan

Topik ini menggunakan titik akhir publik wilayah China (Hangzhou). Untuk mengakses OSS dari layanan Alibaba Cloud lainnya dalam wilayah yang sama, gunakan titik akhir internal. Untuk detail wilayah dan titik akhir yang didukung, lihat Regions and endpoints.
Topik ini memberikan contoh cara mengambil kredensial akses dari variabel lingkungan. Untuk informasi lebih lanjut tentang konfigurasi kredensial akses, lihat Configure access credentials (Node.js SDK).
Untuk menghasilkan URL yang ditandatangani sebelumnya untuk permintaan GET, Anda harus memiliki izin oss:GetObject. Untuk informasi lebih lanjut, lihat Grant custom permissions to a RAM user.
Topik ini menggunakan URL V4 yang ditandatangani sebagai contoh. Masa berlaku maksimum adalah tujuh hari. Untuk informasi lebih lanjut, lihat Tanda Tangan V4 (Direkomendasikan).

Proses

Proses pengunduhan objek menggunakan URL yang ditandatangani sebelumnya adalah sebagai berikut:

Contoh kode

Pemilik objek menghasilkan URL yang ditandatangani sebelumnya untuk permintaan GET.

const OSS = require("ali-oss");

// Definisikan fungsi untuk menghasilkan URL yang ditandatangani sebelumnya.
async function generateSignatureUrl(fileName) {
  // Dapatkan URL yang ditandatangani sebelumnya.
  const client = await new OSS({
      // Ambil kredensial akses dari variabel lingkungan. Sebelum menjalankan kode ini, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah disetel.
      accessKeyId: process.env.OSS_ACCESS_KEY_ID,
      accessKeySecret: process.env.OSS_ACCESS_KEY_SECRET,
      bucket: 'examplebucket',
      // Ganti yourregion dengan wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah China (Hangzhou), setel Region ke oss-cn-hangzhou.
      region: 'oss-cn-hangzhou',
      // Setel secure ke true untuk menggunakan HTTPS. Ini mencegah browser memblokir tautan unduhan yang dihasilkan.
      secure: true,
      authorizationV4: true
  });

  return await client.signatureUrlV4('GET', 3600, {
      headers: {} // Setel header permintaan sesuai dengan header permintaan aktual.
  }, fileName);
}
// Panggil fungsi dan berikan nama file.
generateSignatureUrl('yourFileName').then(url => {
  console.log('Generated Signature URL:', url);
}).catch(err => {
  console.error('Error generating signature URL:', err);
});

Pengguna lain mengunduh objek menggunakan URL yang ditandatangani sebelumnya untuk permintaan GET.

curl

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=LTAI****************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a******************************************************"

Java

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) {
        // Ganti dengan URL yang ditandatangani sebelumnya untuk permintaan GET yang dihasilkan.
        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=LTAI****************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a******************************************************";
        // Masukkan jalur tujuan untuk menyimpan file, termasuk nama file dan ekstensi.
        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");

        // Periksa kode respons.
        int responseCode = httpConn.getResponseCode();
        if (responseCode == HttpURLConnection.HTTP_OK) {
            // Aliran input.
            InputStream inputStream = new BufferedInputStream(httpConn.getInputStream());
            // Aliran output.
            FileOutputStream outputStream = new FileOutputStream(savePath);

            byte[] buffer = new byte[4096]; // Buffer.
            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();
    }
}

Node.js

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=LTAI****************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a******************************************************";
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);
});

Python

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=LTAI****************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a******************************************************"
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)

Go

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=LTAI****************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a******************************************************"
    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)
    }
}

JavaScript

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=LTAI****************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a******************************************************";
const savePath = "C:/downloads/myfile.txt"; // Nama file yang akan digunakan untuk unduhan.

fetch(fileURL)
    .then(response => {
        if (!response.ok) {
            throw new Error(`Server replied HTTP code: ${response.status}`);
        }
        return response.blob(); // Konversi respons menjadi blob.
    })
    .then(blob => {
        const link = document.createElement('a');
        link.href = window.URL.createObjectURL(blob);
        link.download = savePath; // Tetapkan nama file yang diunduh.
        document.body.appendChild(link); // Langkah ini memastikan tautan ada dalam dokumen.
        link.click(); // Simulasikan klik pada tautan unduhan.
        link.remove(); // Hapus tautan setelah selesai.
        console.log("Download completed!");
    })
    .catch(error => {
        console.error("Error during download:", error);
    });

Android-Java

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"; // Jalur penyimpanan yang dimodifikasi.
        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();
        }
    }
}

Objective-C

#import <Foundation/Foundation.h>

int main(int argc, const char * argv[]) {
    @autoreleasepool {
        // Definisikan URL file dan jalur penyimpanan (ubah ke jalur yang valid).
        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=LTAI****************/20241112/cn-hangzhou/oss/aliyun_v4_request&x-oss-signature=ed5a******************************************************";
        NSString *savePath = @"/Users/your_username/Desktop/myfile.txt"; // Ganti dengan username Anda.

        // Buat objek URL.
        NSURL *url = [NSURL URLWithString:fileURL];

        // Buat tugas unduhan.
        NSURLSessionDataTask *task = [[NSURLSession sharedSession] dataTaskWithURL:url completionHandler:^(NSData *data, NSURLResponse *response, NSError *error) {
            // Penanganan error.
            if (error) {
                NSLog(@"Error during download: %@", error.localizedDescription);
                return;
            }

            // Periksa data.
            if (!data) {
                NSLog(@"No data received.");
                return;
            }

            // Simpan file.
            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);
            }
        }];

        // Mulai tugas.
        [task resume];

        // Pertahankan thread utama agar permintaan asinkron dapat diselesaikan.
        [[NSRunLoop currentRunLoop] run];
    }
    return 0;
}

Skenario lainnya

Hasilkan URL yang ditandatangani sebelumnya dengan parameter pemrosesan citra

const OSS = require("ali-oss");

// Definisikan fungsi untuk menghasilkan URL yang ditandatangani sebelumnya.
async function generateSignatureUrl(fileName) {
  // Dapatkan URL yang ditandatangani sebelumnya.
  const client = await new OSS({
    // Ambil kredensial akses dari variabel lingkungan. Sebelum menjalankan kode ini, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah disetel.
    accessKeyId: process.env.OSS_ACCESS_KEY_ID,
    accessKeySecret: process.env.OSS_ACCESS_KEY_SECRET,
    bucket: 'examplebucket',
    // Ganti yourregion dengan wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah China (Hangzhou), setel Region ke oss-cn-hangzhou.
    region: 'oss-cn-hangzhou',
    authorizationV4: true,
    cname: true
  });

  // Hasilkan URL yang ditandatangani yang mencakup parameter pemrosesan dokumen.
  return await client.signatureUrlV4('GET', 3600, {
    headers: {}, // Setel header permintaan sesuai dengan header permintaan aktual.
    queries: {
     "x-oss-process": "image/resize,m_fixed,w_100,h_100" // Tambahkan parameter pemrosesan citra.
    }
  }, fileName);
}

// Panggil fungsi dan berikan nama citra.
generateSignatureUrl('test.jpg').then(url => {
  console.log('Generated Signature URL:', url);
}).catch(err => {
  console.error('Error generating signature URL:', err);
});

Hasilkan URL yang ditandatangani sebelumnya dengan ID versi

const OSS = require("ali-oss");

const client = await new OSS({
  // Ambil kredensial akses dari variabel lingkungan. Sebelum menjalankan kode ini, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah disetel.
  accessKeyId: process.env.OSS_ACCESS_KEY_ID,
  accessKeySecret: process.env.OSS_ACCESS_KEY_SECRET,
  bucket: 'examplebucket',
  // Ganti yourregion dengan wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah China (Hangzhou), setel Region ke oss-cn-hangzhou.
  region: 'oss-cn-hangzhou',
  // Setel secure ke true untuk menggunakan HTTPS. Ini mencegah browser memblokir tautan unduhan yang dihasilkan.
  secure: true,
  authorizationV4: true
});


// Hasilkan URL yang ditandatangani sebelumnya.
const signedUrl = await client.signatureUrlV4('GET', 3600, {
  queries:{
    // Tentukan ID versi objek.
    "versionId":'yourVersionId'
  }
}, 'demo.pdf');

Hasilkan URL yang ditandatangani sebelumnya untuk unduhan menggunakan nama domain kustom

Kode berikut menunjukkan cara menghasilkan URL yang ditandatangani sebelumnya untuk permintaan GET menggunakan nama domain kustom.

const OSS = require("ali-oss");

// Definisikan fungsi untuk menghasilkan URL yang ditandatangani sebelumnya.
async function generateSignatureUrl(fileName) {
  // Dapatkan URL yang ditandatangani sebelumnya.
  const client = await new OSS({
      // Gunakan nama domain kustom sebagai titik akhir.
      endpoint: 'http://static.example.com', 
      // Ambil kredensial akses dari variabel lingkungan. Sebelum menjalankan kode ini, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah disetel.
      accessKeyId: process.env.OSS_ACCESS_KEY_ID,
      accessKeySecret: process.env.OSS_ACCESS_KEY_SECRET,
      bucket: 'examplebucket',
      // Ganti yourregion dengan wilayah tempat bucket berada. Misalnya, jika bucket berada di wilayah China (Hangzhou), setel Region ke oss-cn-hangzhou.
      region: 'oss-cn-hangzhou',
      authorizationV4: true,
      cname: true
  });

  return await client.signatureUrlV4('GET', 3600, {
      headers: {} // Setel header permintaan sesuai dengan header permintaan aktual.
  }, fileName);
}
// Panggil fungsi dan berikan nama file.
generateSignatureUrl('yourFileName').then(url => {
  console.log('Generated Signature URL:', url);
}).catch(err => {
  console.error('Error generating signature URL:', err);
});

Referensi

Untuk informasi lebih lanjut tentang operasi API yang digunakan untuk menghasilkan URL yang ditandatangani sebelumnya, lihat GeneratePresignedUrlRequest.