Object Storage Service:STS が提供する一時的なアクセス認証情報を使用して OSS にアクセスする

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 {
        // ステップ 1.5 で生成された一時的な AccessKey ID、AccessKey シークレット、および STS トークンを指定します。RAM ユーザーの認証情報は使用しないでください。
        // STS によって提供される AccessKey ID は STS で始まることに注意してください。
        String accessKeyId = "yourSTSAccessKeyID";
        String accessKeySecret = "yourSTSAccessKeySecret";
        // STS から取得したセキュリティトークンを指定します。
        String stsToken= "yourSecurityToken";

        // AccessKey ID とシークレットを DefaultCredentialProvider に渡して、認証情報プロバイダーを初期化します。
        CredentialsProvider credentialsProvider = new DefaultCredentialProvider(accessKeyId, accessKeySecret, stsToken);
        // credentialsProvider を使用してクライアントを初期化します。
        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        // V4 署名アルゴリズムの使用を明示的に宣言します。
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
        // OSSClient インスタンスを作成します。
        // OSSClient が不要になったら、shutdown メソッドを呼び出してリソースを解放します。
        OSS ossClient = OSSClientBuilder.create()
                 // バケットが配置されているリージョンのエンドポイントを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
                .endpoint("endpoint")
                .credentialsProvider(credentialsProvider)
                .clientConfiguration(clientBuilderConfiguration)
                // リージョン ID を指定します。例: cn-hangzhou。
                .region("region")
                .build();

        try {

            // PutObjectRequest オブジェクトを作成します。ローカルファイル exampletest.txt を examplebucket にアップロードします。
            PutObjectRequest putObjectRequest = new PutObjectRequest("examplebucket", "exampletest.txt", new File("D:\\localpath\\exampletest.txt"));

            // オプション。オブジェクトのストレージクラスと ACL を指定します。
            // ObjectMetadata metadata = new ObjectMetadata();
            // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString());
            // metadata.setObjectAcl(CannedAccessControlList.Private);
            // putObjectRequest.setMetadata(metadata);

            // オブジェクトをアップロードします。
            PutObjectResult result = ossClient.putObject(putObjectRequest);
        } catch (OSSException oe) {
            System.out.println("OSSException がキャッチされました。これは、リクエストが OSS に到達したものの、"
                    + "何らかの理由でエラー応答で拒否されたことを意味します。");
            System.out.println("エラーメッセージ:" + oe.getErrorMessage());
            System.out.println("エラーコード:" + oe.getErrorCode());
            System.out.println("リクエスト ID:" + oe.getRequestId());
            System.out.println("ホスト ID:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("ClientException がキャッチされました。これは、クライアントが OSS と通信しようとしているときに、"
                    + "ネットワークにアクセスできないなど、重大な内部問題が発生したことを意味します。");
            System.out.println("エラーメッセージ:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }
    }
}

Python

OSS SDK for Python は、2.0 と 1.0 の 2 つのバージョンで利用できます。 OSS SDK for Python 2.0 は 1.0 の完全なリファクタリングであり、認証、リクエストの再試行、エラー処理などのコア操作を合理化しています。より柔軟なパラメーター構成を提供し、新しい高度な機能を導入しています。 実際の要件に基づいて OSS SDK for Python を実装するのに役立つように、次の例を示します。

import alibabacloud_oss_v2 as oss

def main():
    # ステップ 1.5 で生成された一時的な AccessKey ID、AccessKey シークレット、および STS トークンを指定します。RAM ユーザーの認証情報は使用しないでください。
    # STS によって提供される AccessKey ID は STS で始まることに注意してください。
    sts_access_key_id = 'yourSTSAccessKeyID'
    sts_access_key_secret = 'yourSTSAccessKeySecret'
    # STS から取得した STS トークンを指定します。
    sts_security_token = 'yourSecurityToken'
    
    # 静的認証情報プロバイダーを作成し、STS によって提供される AccessKey ID、AccessKey シークレット、および STS トークンを明示的に指定します。
    credentials_provider = oss.credentials.StaticCredentialsProvider(
        access_key_id=sts_access_key_id,
        access_key_secret=sts_access_key_secret,
        security_token=sts_security_token,
    )

    # SDK のデフォルト構成を読み込み、認証情報プロバイダーを指定します。
    cfg = oss.config.load_default()
    cfg.credentials_provider = credentials_provider

    # バケットが配置されているリージョンを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、リージョンを cn-hangzhou に設定します。
    cfg.region = 'cn-hangzhou'

    # 前述の構成を使用して、OSSClient インスタンスを作成します。
    client = oss.Client(cfg)

    # アップロードするローカルオブジェクトの完全なパスを指定します。 例: D:\\localpath\\exampletest.txt。
    local_file_path = 'D:\\localpath\\exampletest.txt'
    with open(local_file_path, 'rb') as file:
        data = file.read()

    # exampletest.txt を examplebucket にアップロードするリクエストを実行します。
    result = client.put_object(oss.PutObjectRequest(
        # バケットの名前。
        bucket='examplebucket',
        # アップロードするオブジェクトの名前。
        key='exampletest.txt',
        body=data,
    ))

     # リクエストが成功したかどうかを確認するために、HTTP ステータスコード、リクエスト ID、MD5 ハッシュ、ETag、CRC-64 値、およびオブジェクトバージョン ID を表示します。
    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},'
    )


# スクリプトが直接実行されたときに main 関数を呼び出します。
if __name__ == "__main__":
    main()  # スクリプトのエントリポイント。スクリプトが直接実行されると、main 関数が呼び出されます。

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

# バケットが配置されているリージョンのエンドポイントを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
endpoint = 'https://oss-cn-hangzhou.aliyuncs.com'
# ステップ 1.5 で生成された一時的な AccessKey ID と AccessKey シークレットを指定します。Alibaba Cloud アカウントの AccessKey ID と AccessKey シークレットは使用しないでください。
sts_access_key_id = 'yourAccessKeyId'
sts_access_key_secret = 'yourAccessKeySecret'
# バケットの名前を指定します。
bucket_name = 'examplebucket'
# 文字列を使用してオブジェクトの完全なパスを指定します。完全なパスにバケット名は含めないでください。
object_name = 'examplebt.txt'
# ステップ 1.5 で生成された STS トークンを入力します。
security_token = 'yourSecurityToken'
# 一時アクセス認証情報を使用して StsAuth インスタンスを初期化します。
auth = oss2.StsAuth(sts_access_key_id,
                    sts_access_key_secret,
                    security_token)
# StsAuth インスタンスを使用してバケットを初期化します。
bucket = oss2.Bucket(auth, endpoint, bucket_name)
# オブジェクトをアップロードします。
result = bucket.put_object(object_name, "hello world")
print(result.status)

Go

OSS SDK for Go は、2.0 と 1.0 の 2 つのバージョンで利用可能です。 OSS SDK for Go 2.0 は 1.0 の完全なリファクタリングであり、認証、リクエストの再試行、エラー処理などのコア操作を合理化しています。より柔軟なパラメーター構成を提供し、新しい高度な機能を導入しています。実際の要件に基づいて OSS SDK for Go を実装するのに役立つように、以下の例を示します。

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() {
	// バケットが配置されているリージョンを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、リージョンを cn-hangzhou に設定します。
	region := "cn-hangzhou"

	// 手順 1.5 で生成された一時的な AccessKey ID、AccessKey シークレット、および STS トークンを指定します。 RAM ユーザーの認証情報を使用しないでください。
        // STS によって提供される AccessKey ID は STS で始まることに注意してください。
	accessKeyID := "yourSTSAccessKeyID"
	accessKeySecret := "yourSTSAccessKeySecret"
	// STS から取得した STS トークンを指定します。
	stsToken := "yourSecurityToken"

	// NewStaticCredentialsProvider メソッドを使用して、AccessKey ID、AccessKey シークレット、および STS トークンを指定します。
	provider := credentials.NewStaticCredentialsProvider(accessKeyID, accessKeySecret, stsToken)

	// SDK のデフォルト構成を読み込み、認証情報プロバイダーとリージョンを指定します。
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(provider).
		WithRegion(region)

	// OSS クライアントを作成します。
	client := oss.NewClient(cfg)

	// アップロードするローカルファイルのパスを指定します。例: D:\\localpath\\exampletest.txt。
	localFile := "D:\\localpath\\exampletest.txt"

	// オブジェクトをアップロードするリクエストを作成します。
	putRequest := &oss.PutObjectRequest{
		Bucket:       oss.Ptr("examplebucket"),      // バケットの名前。
		Key:          oss.Ptr("exampletest.txt"),    // アップロードするオブジェクトの名前。
		StorageClass: oss.StorageClassStandard, // オブジェクトのストレージクラスを Standard に設定します。
		Acl:          oss.ObjectACLPrivate,     // オブジェクトの ACL を private に設定します。
		Metadata: map[string]string{
			"yourMetadataKey1": "yourMetadataValue1", // オブジェクトのメタデータを構成します。
		},
	}

	// exampletest.txt を examplebucket にアップロードするリクエストを実行します。
	result, err := client.PutObjectFromFile(context.TODO(), putRequest, localFile)
	if err != nil {
		log.Fatalf("failed to put object from file %v", err) // ファイルからのオブジェクトの配置に失敗しました
	}

	// オブジェクトアップロードの結果を表示します。
	log.Printf("put object from file result:%#v\n", result) // ファイルからのオブジェクト配置結果:
	
}

package main

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

func main() {
    // 環境変数から一時的なアクセス認証情報を取得します。サンプルコードを実行する前に、OSS_ACCESS_KEY_ID、OSS_ACCESS_KEY_SECRET、および OSS_SESSION_TOKEN 環境変数が構成されていることを確認してください。
    provider, err := oss.NewEnvironmentVariableCredentialsProvider()
    if err != nil {
        fmt.Println("Error:", err) // エラー:
        os.Exit(-1)
    }
    // OSSClient インスタンスを作成します。 // バケットが配置されているリージョンのエンドポイントを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。実際のエンドポイントを指定します。
    client, err := oss.New("yourEndpoint", "", "", oss.SetCredentialsProvider(&provider))
    if err != nil {
        fmt.Println("Error:", err) // エラー:
        os.Exit(-1)
    }
    // バケットの名前を指定します。例: examplebucket。
    bucketName := "examplebucket"// オブジェクトの完全なパスを指定します。完全なパスにバケット名を含めないでください。例: exampledir/exampleobject.txt。
    objectName := "exampledir/exampleobject.txt"// ローカルオブジェクトの完全なパスを指定します。例: D:\\localpath\\examplefile.txt。
    filepath := "D:\\localpath\\examplefile.txt"
    bucket,err := client.Bucket(bucketName)
    // 一時的なアクセス認証情報を使用してローカルファイルをアップロードします。
    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");

// 一時アクセス認証情報を使用して OSSClient インスタンスを初期化します。このインスタンスは、OSS リソースへの一時的なアクセスの承認に使用されます。
const getToken = async () => {
  // クライアントが一時アクセス認証情報を取得するために使用するアドレスを指定します。
  await axios.get("http://localhost:8000/sts").then((token) => {
    const client = new OSS({
       // バケットが配置されているリージョンを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、リージョンを oss-cn-hangzhou に設定します。
      region: 'oss-cn-hangzhou',
      // ステップ 1.5 で生成された一時的な AccessKey ID、AccessKey Secret、および STS トークンを指定します。 RAM ユーザーの認証情報は使用しないでください。
      accessKeyId: token.data.AccessKeyId,
      accessKeySecret: token.data.AccessKeySecret,
      // ステップ 1.5 で生成された STS トークンを入力します。
      stsToken: token.data.SecurityToken,
      authorizationV4: true,
      // バケットの名前を指定します。
      bucket: "examplebucket",
      // 一時アクセス認証情報を更新します。
      refreshSTSToken: async () => {
        const refreshToken = await axios.get("http://localhost:8000/sts");
        return {
          accessKeyId: refreshToken.data.AccessKeyId,
          accessKeySecret: refreshToken.data.AccessKeySecret,
          stsToken: refreshToken.data.SecurityToken,
        };
      },
    });
    // 一時アクセス認証情報を使用してオブジェクトをアップロードします。
    // オブジェクトの完全なパスを指定します。完全なパスにバケット名を含めないでください。例: exampleobject.jpg。
    // ローカルオブジェクトの完全なパスを指定します。例: 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 {
    // ステップ 1.5 で生成された一時的な AccessKey ID、AccessKey Secret、および STS トークンを指定します。RAM ユーザーの認証情報を使用しないでください。
    // STS によって提供される AccessKey ID は STS で始まることに注意してください。
    $accessKeyId = 'yourSTSAccessKeyID';
    $accessKeySecret = 'yourSTSAccessKeySecret';
    // STS から取得した STS トークンを指定します。
    $securityToken = 'yourSecurityToken';

    // StaticCredentialsProvider を使用して認証情報プロバイダーを作成します。
    $provider = new StaticCredentialsProvider($accessKeyId, $accessKeySecret, $securityToken);

    // バケットが配置されているリージョンのエンドポイントを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
    $endpoint = "https://oss-cn-hangzhou.aliyuncs.com";

    // バケットの名前を指定します。例: examplebucket。
    $bucket= "examplebucket";
    // アップロードするオブジェクトの名前を指定します。
    $object = "exampletest.txt";
    // アップロードするローカルオブジェクトの完全なパスを指定します。例: D:\\localpath\\exampletest.txt。
    $localFilePath = "D:\\localpath\\exampletest.txt";

    // アップロードリクエストでヘッダーを構成して、アップロードされた文字列に関する情報を指定できます。たとえば、オブジェクト ACL を非公開に設定し、オブジェクトのユーザーメタデータを構成できます。
    $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,
        // バケットが配置されているリージョンを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合は、リージョンを cn-hangzhou に設定します。
        "region" => "cn-hangzhou"
    );
    
    // 前述の構成を使用して、OSSClient インスタンスを作成します。
    $ossClient = new OssClient($config);
    
     // exampletest.txt という名前のローカルファイルを 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: 'https://oss-cn-hangzhou.aliyuncs.com',
  # ステップ 1.5 で生成された一時的な AccessKey ID と AccessKey Secret を指定します。Alibaba Cloud アカウントの AccessKey ID と AccessKey Secret は使用しないでください。
  access_key_id: 'token.access_key_id',
  access_key_secret: 'token.access_key_secret',
  # ステップ 1.5 で生成された STS トークンを入力します。
  sts_token: 'token.security_token'
  )
# バケット名を指定します。例: examplebucket。
bucket = client.get_bucket('examplebucket')
# オブジェクトをアップロードします。
bucket.put_object('exampleobject.txt', :file => 'D:\test.txt')