Object Storage Service:Akses OSS menggunakan kredensial sementara STS

Java

import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.CredentialsProvider;
import com.aliyun.oss.common.auth.DefaultCredentialProvider;
import com.aliyun.oss.common.comm.SignVersion;
import com.aliyun.oss.model.PutObjectRequest;
import com.aliyun.oss.model.PutObjectResult;

import java.io.File;

public class Demo {

    public static void main(String[] args) throws Exception {
        // Tentukan ID AccessKey sementara, Rahasia AccessKey, dan token keamanan yang Anda peroleh di Langkah Sub-5 Langkah 1. Jangan gunakan kredensial identitas RAM user.
        // Perhatikan bahwa ID AccessKey yang diperoleh dari layanan STS dimulai dengan "STS".
        String accessKeyId = "yourSTSAccessKeyID";
        String accessKeySecret = "yourSTSAccessKeySecret";
        // Tentukan token keamanan yang Anda peroleh dari STS.
        String stsToken= "yourSecurityToken";

        // Gunakan metode DefaultCredentialProvider untuk langsung mengatur ID AccessKey dan Rahasia AccessKey.
        CredentialsProvider credentialsProvider = new DefaultCredentialProvider(accessKeyId, accessKeySecret, stsToken);
        // Inisialisasi klien menggunakan credentialsProvider.
        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        // Secara eksplisit nyatakan bahwa algoritma signature V4 digunakan.
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
        // Buat instance OSSClient.
        // Saat instance OSSClient tidak lagi digunakan, panggil metode shutdown untuk melepaskan resource.
        OSS ossClient = OSSClientBuilder.create()
                 // Atur nama domain akses OSS. Contoh untuk wilayah Tiongkok (Hangzhou): https://oss-cn-hangzhou.aliyuncs.com
                .endpoint("endpoint")
                .credentialsProvider(credentialsProvider)
                .clientConfiguration(clientBuilderConfiguration)
                // Atur wilayah bucket tujuan. Contoh untuk wilayah Tiongkok (Hangzhou): cn-hangzhou
                .region("region")
                .build();

        try {

            // Buat objek PutObjectRequest untuk mengunggah file lokal exampletest.txt ke examplebucket.
            PutObjectRequest putObjectRequest = new PutObjectRequest("examplebucket", "exampletest.txt", new File("D:\\localpath\\exampletest.txt"));

            // Jika Anda perlu mengatur kelas penyimpanan dan izin akses selama pengunggahan, lihat contoh kode berikut.
            // ObjectMetadata metadata = new ObjectMetadata();
            // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString());
            // metadata.setObjectAcl(CannedAccessControlList.Private);
            // putObjectRequest.setMetadata(metadata);

            // Unggah file.
            PutObjectResult result = ossClient.putObject(putObjectRequest);
        } catch (OSSException oe) {
            System.out.println("Terjadi OSSException, yang berarti permintaan Anda sampai ke OSS, "
                    + "tetapi ditolak dengan tanggapan error karena suatu alasan.");
            System.out.println("Pesan Error:" + oe.getErrorMessage());
            System.out.println("Kode Error:" + oe.getErrorCode());
            System.out.println("ID Permintaan:" + oe.getRequestId());
            System.out.println("ID Host:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Terjadi ClientException, yang berarti klien mengalami "
                    + "masalah internal serius saat mencoba berkomunikasi dengan OSS, "
                    + "seperti tidak dapat mengakses jaringan.");
            System.out.println("Pesan Error:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }
    }
}

Python

OSS SDK untuk Python tersedia dalam V2 dan V1. V2 merupakan penyusunan ulang komprehensif dari V1 yang menyederhanakan operasi dasar seperti verifikasi identitas, pengulangan permintaan, dan penanganan error. SDK ini juga menyediakan konfigurasi parameter yang lebih fleksibel dan antarmuka lanjutan baru. Lihat contoh berikut sesuai kebutuhan Anda.

import alibabacloud_oss_v2 as oss

def main():
    # Tentukan ID AccessKey sementara, Rahasia AccessKey, dan token keamanan yang Anda peroleh di Langkah Sub-5 Langkah 1. Jangan gunakan kredensial identitas RAM user.
    # Perhatikan bahwa ID AccessKey yang diperoleh dari layanan STS dimulai dengan "STS".
    sts_access_key_id = 'yourSTSAccessKeyID'
    sts_access_key_secret = 'yourSTSAccessKeySecret'
    # Tentukan token keamanan yang Anda peroleh dari STS.
    sts_security_token = 'yourSecurityToken'
    
    # Buat penyedia kredensial statis dan atur secara eksplisit ID AccessKey sementara, Rahasia AccessKey, dan token keamanan.
    credentials_provider = oss.credentials.StaticCredentialsProvider(
        access_key_id=sts_access_key_id,
        access_key_secret=sts_access_key_secret,
        security_token=sts_security_token,
    )

    # Muat konfigurasi default SDK dan atur penyedia kredensial.
    cfg = oss.config.load_default()
    cfg.credentials_provider = credentials_provider

    # Tentukan wilayah bucket. Contoh untuk Tiongkok (Hangzhou): cn-hangzhou.
    cfg.region = 'cn-hangzhou'

    # Buat klien OSS menggunakan informasi yang telah dikonfigurasi.
    client = oss.Client(cfg)

    # Path file lokal yang akan diunggah. Contoh: D:\\localpath\\exampletest.txt.
    local_file_path = 'D:\\localpath\\exampletest.txt'
    with open(local_file_path, 'rb') as file:
        data = file.read()

    # Jalankan permintaan unggah objek untuk mengunggah file lokal exampletest.txt ke examplebucket. Tentukan nama bucket, nama objek, dan file yang akan diunggah.
    result = client.put_object(oss.PutObjectRequest(
        # Nama bucket
        bucket='examplebucket',
        # Nama objek yang akan diunggah ke bucket
        key='exampletest.txt',
        body=data,
    ))

     # Keluarkan kode status permintaan, ID permintaan, MD5 konten, ETag, checksum CRC-64, dan ID versi untuk memeriksa apakah permintaan berhasil.
    print(f'status code: {result.status_code},'
          f' request id: {result.request_id},'
          f' content md5: {result.content_md5},'
          f' etag: {result.etag},'
          f' hash crc64: {result.hash_crc64},'
          f' version id: {result.version_id},'
    )


# Saat skrip ini dijalankan secara langsung, panggil fungsi main.
if __name__ == "__main__":
    main()  # Titik masuk skrip. Saat file dijalankan secara langsung, fungsi main dipanggil.

# -*- coding: utf-8 -*-
import oss2

# yourEndpoint menentukan endpoint wilayah bucket. Contoh untuk Tiongkok (Hangzhou): https://oss-cn-hangzhou.aliyuncs.com.
endpoint = 'https://oss-cn-hangzhou.aliyuncs.com'
# Tentukan ID AccessKey sementara dan Rahasia AccessKey yang Anda peroleh di Langkah Sub-5 Langkah 1. Jangan gunakan ID AccessKey dan Rahasia AccessKey Akun Alibaba Cloud.
sts_access_key_id = 'yourAccessKeyId'
sts_access_key_secret = 'yourAccessKeySecret'
# Tentukan nama bucket.
bucket_name = 'examplebucket'
# Tentukan path lengkap objek. Path lengkap objek tidak boleh mengandung nama bucket. 
object_name = 'examplebt.txt'
# Tentukan token keamanan yang Anda peroleh di Langkah Sub-5 Langkah 1.
security_token = 'yourSecurityToken'
# Inisialisasi instance StsAuth menggunakan informasi autentikasi dari kredensial sementara.
auth = oss2.StsAuth(sts_access_key_id,
                    sts_access_key_secret,
                    security_token)
# Inisialisasi bucket menggunakan instance StsAuth.
bucket = oss2.Bucket(auth, endpoint, bucket_name)
# Unggah objek.
result = bucket.put_object(object_name, "hello world")
print(result.status)

Go

OSS SDK untuk Go tersedia dalam V2 dan V1. V2 merupakan penyusunan ulang komprehensif dari V1 yang menyederhanakan operasi dasar seperti verifikasi identitas, pengulangan permintaan, dan penanganan error. SDK ini juga menyediakan konfigurasi parameter yang lebih fleksibel dan antarmuka lanjutan baru. Lihat contoh berikut sesuai kebutuhan Anda.

package main

import (
	"context"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

func main() {
	// Tentukan wilayah bucket. Contoh untuk Tiongkok (Hangzhou): cn-hangzhou.
	region := "cn-hangzhou"

	// Tentukan ID AccessKey sementara, Rahasia AccessKey, dan token keamanan yang Anda peroleh di Langkah Sub-5 Langkah 1. Jangan gunakan kredensial identitas RAM user.
    // Perhatikan bahwa ID AccessKey yang diperoleh dari layanan STS dimulai dengan "STS".
	accessKeyID := "yourSTSAccessKeyID"
	accessKeySecret := "yourSTSAccessKeySecret"
	// Tentukan token keamanan yang Anda peroleh dari STS.
	stsToken := "yourSecurityToken"

	// Gunakan metode NewStaticCredentialsProvider untuk langsung mengatur ID AccessKey, Rahasia AccessKey, dan token STS.
	provider := credentials.NewStaticCredentialsProvider(accessKeyID, accessKeySecret, stsToken)

	// Muat konfigurasi default dan atur penyedia kredensial serta wilayah.
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(provider).
		WithRegion(region)

	// Buat klien OSS.
	client := oss.NewClient(cfg)

	// Tentukan path dan nama file lokal yang akan diunggah. Contoh: D:\\localpath\\exampletest.txt.
	localFile := "D:\\localpath\\exampletest.txt"

	// Buat permintaan untuk mengunggah objek.
	putRequest := &oss.PutObjectRequest{
		Bucket:       oss.Ptr("examplebucket"),      // Nama bucket
		Key:          oss.Ptr("exampletest.txt"),    // Nama objek yang akan diunggah ke bucket
		StorageClass: oss.StorageClassStandard, // Atur kelas penyimpanan objek menjadi Standard.
		Acl:          oss.ObjectACLPrivate,     // Atur daftar kontrol akses (ACL) objek menjadi private.
		Metadata: map[string]string{
			"yourMetadataKey1": "yourMetadataValue1", // Atur metadata objek.
		},
	}

	// Jalankan permintaan unggah objek untuk mengunggah file lokal exampletest.txt ke examplebucket.
	result, err := client.PutObjectFromFile(context.TODO(), putRequest, localFile)
	if err != nil {
		log.Fatalf("gagal mengunggah objek dari file %v", err)
	}

	// Cetak hasil unggah objek.
	log.Printf("hasil unggah objek dari file:%#v\n", result)
	
}

package main

import (
    "fmt"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
    "os"
)

func main() {
    // Peroleh kredensial sementara dari variabel lingkungan yang Anda peroleh di Langkah Sub-5 Langkah 1. Sebelum menjalankan kode contoh ini, pastikan variabel lingkungan OSS_ACCESS_KEY_ID, OSS_ACCESS_KEY_SECRET, dan OSS_SESSION_TOKEN telah diatur.
    provider, err := oss.NewEnvironmentVariableCredentialsProvider()
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // Buat instance OSSClient.
    // yourEndpoint menentukan endpoint bucket. Contoh untuk Tiongkok (Hangzhou): https://oss-cn-hangzhou.aliyuncs.com. Tentukan endpoint sesuai wilayah Anda.
    client, err := oss.New("yourEndpoint", "", "", oss.SetCredentialsProvider(&provider))
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // Tentukan nama bucket. Contoh: examplebucket.
    bucketName := "examplebucket"
    // Tentukan path lengkap objek. Path lengkap tidak boleh mengandung nama bucket. Contoh: exampledir/exampleobject.txt.
    objectName := "exampledir/exampleobject.txt"
    // Tentukan path lengkap file lokal. Contoh: D:\\localpath\\examplefile.txt.
    filepath := "D:\\localpath\\examplefile.txt"
    bucket, err := client.Bucket(bucketName)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // Otorisasi pihak ketiga untuk mengunggah file menggunakan STS.
    err = bucket.PutObjectFromFile(objectName, filepath)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    fmt.Println("upload success")
}

Node.js

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

// Gunakan kredensial sementara untuk menginisialisasi klien OSS di sisi klien untuk akses berotorisasi sementara ke resource OSS.
const getToken = async () => {
  // Atur alamat bagi klien untuk meminta kredensial akses.
  await axios.get("http://localhost:8000/sts").then((token) => {
    const client = new OSS({
       // yourRegion menentukan wilayah bucket. Contoh untuk Tiongkok (Hangzhou): oss-cn-hangzhou.
      region: 'oss-cn-hangzhou',
      // Tentukan ID AccessKey sementara dan Rahasia AccessKey yang Anda peroleh di Langkah Sub-5 Langkah 1. Jangan gunakan ID AccessKey dan Rahasia AccessKey Akun Alibaba Cloud.
      accessKeyId: token.data.AccessKeyId,
      accessKeySecret: token.data.AccessKeySecret,
      // Tentukan token keamanan yang Anda peroleh di Langkah Sub-5 Langkah 1.
      stsToken: token.data.SecurityToken,
      authorizationV4: true,
      // Tentukan nama bucket.
      bucket: "examplebucket",
      // Segarkan kredensial sementara.
      refreshSTSToken: async () => {
        const refreshToken = await axios.get("http://localhost:8000/sts");
        return {
          accessKeyId: refreshToken.data.AccessKeyId,
          accessKeySecret: refreshToken.data.AccessKeySecret,
          stsToken: refreshToken.data.SecurityToken,
        };
      },
    });
    // Gunakan kredensial sementara untuk mengunggah file.
    // Tentukan path lengkap objek, tidak termasuk nama bucket. Contoh: exampleobject.jpg.
    // Tentukan path lengkap file lokal. Contoh: D:\\example.jpg.
    client.put('exampleobject.jpg', 'D:\\example.jpg').then((res)=>{console.log(res)}).catch(e=>console.log(e))
  });
};
getToken()

PHP

<?php
if (is_file(__DIR__ . 'autoload.php')) {
    require_once __DIR__ . 'autoload.php';
}
if (is_file(__DIR__ . '/vendor/autoload.php')) {
    require_once __DIR__ . '/vendor/autoload.php';
}

use OSS\Credentials\StaticCredentialsProvider;
use OSS\OssClient;
use OSS\Core\OssException;

try {
    // Tentukan ID AccessKey sementara, Rahasia AccessKey, dan token keamanan yang Anda peroleh di Langkah Sub-5 Langkah 1. Jangan gunakan kredensial identitas RAM user.
    // Perhatikan bahwa ID AccessKey yang diperoleh dari layanan STS dimulai dengan "STS".
    $accessKeyId = 'yourSTSAccessKeyID';
    $accessKeySecret = 'yourSTSAccessKeySecret';
    // Tentukan token keamanan yang Anda peroleh dari STS.
    $securityToken = 'yourSecurityToken';

    // Buat penyedia kredensial menggunakan kelas StaticCredentialsProvider.
    $provider = new StaticCredentialsProvider($accessKeyId, $accessKeySecret, $securityToken);

    // Tentukan endpoint wilayah bucket. Contoh untuk Tiongkok (Hangzhou): https://oss-cn-hangzhou.aliyuncs.com.
    $endpoint = "https://oss-cn-hangzhou.aliyuncs.com";

    // Tentukan nama bucket. Contoh: examplebucket.
    $bucket= "examplebucket";
    // Tentukan nama objek yang akan diunggah ke bucket.
    $object = "exampletest.txt";
    // Tentukan path file lokal yang akan diunggah. Contoh: D:\\localpath\\exampletest.txt.
    $localFilePath = "D:\\localpath\\exampletest.txt";

    // Anda dapat mengatur header terkait selama pengunggahan, seperti mengatur izin akses menjadi private dan menentukan metadata kustom.
    $options = array(
        OssClient::OSS_HEADERS => array(
            'x-oss-object-acl' => 'private',
            'x-oss-meta-info' => 'yourinfo'
        ),
    );

    $config = array(
        "provider" => $provider,
        "endpoint" => $endpoint,
        "signatureVersion" => OssClient::OSS_SIGNATURE_VERSION_V4,
        // Tentukan wilayah bucket. Contoh untuk Tiongkok (Hangzhou): cn-hangzhou.
        "region" => "cn-hangzhou"
    );
    
    // Buat klien OSS menggunakan informasi yang telah dikonfigurasi.
    $ossClient = new OssClient($config);
    
     // Kirim permintaan untuk mengunggah file lokal exampletest.txt ke examplebucket.
    $ossClient->putObject($bucket, $object, $localFilePath, $options);
} catch (OssException $e) {
    printf($e->getMessage() . "\n");
    return;
}

Ruby

require 'aliyun/sts'
require 'aliyun/oss'

client = Aliyun::OSS::Client.new(
  # Endpoint wilayah Tiongkok (Hangzhou) digunakan dalam contoh ini. Tentukan endpoint sesuai wilayah Anda.
  endpoint: 'https://oss-cn-hangzhou.aliyuncs.com',
  # Tentukan ID AccessKey sementara dan Rahasia AccessKey yang Anda peroleh di Langkah Sub-5 Langkah 1. Jangan gunakan ID AccessKey dan Rahasia AccessKey Akun Alibaba Cloud.
  access_key_id: 'token.access_key_id',
  access_key_secret: 'token.access_key_secret',
  # Tentukan token keamanan yang Anda peroleh di Langkah Sub-5 Langkah 1.
  sts_token: 'token.security_token'
  )
# Tentukan nama bucket. Contoh: examplebucket.
bucket = client.get_bucket('examplebucket')
# Unggah file.
bucket.put_object('exampleobject.txt', :file => 'D:\test.txt')