Object Storage Service:ファイルのアップロード (Python SDK V1)

次のコードは、シンプルアップロードを実行する方法を示しています。

# -*- coding: utf-8 -*-
import oss2
from oss2.credentials import EnvironmentVariableCredentialsProvider
# 環境変数からアクセス認証情報を取得します。サンプルコードを実行する前に、OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
auth = oss2.ProviderAuthV4(EnvironmentVariableCredentialsProvider())

# バケットが配置されているリージョンのエンドポイントを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
endpoint = "https://oss-cn-hangzhou.aliyuncs.com"
# エンドポイントが配置されているリージョン (cn-hangzhou など) を指定します。注意：このパラメーターは V4 署名に必要です。
region = "cn-hangzhou"

# yourBucketName をバケットの名前に設定します。
bucket = oss2.Bucket(auth, endpoint, "yourBucketName", region=region)

# ファイルをアップロードします。
result = bucket.put_object('yourObjectName', 'content of object')
# HTTP ステータスコード。
print('http response code: {0}'.format(result.status))
# アップロードされたオブジェクトのバージョン ID を表示します。
print('put object version:', result.versionid)

バージョン管理が有効なバケットでは、追加操作 (AppendObject) は追加可能なオブジェクトの現在のバージョンに対してのみ実行できます。追加可能なオブジェクトの以前のバージョンに対して AppendObject 操作を実行することはできません。

次のコードは、追加アップロードを実行する方法を示しています。

# -*- coding: utf-8 -*-
import oss2
from oss2.credentials import EnvironmentVariableCredentialsProvider
# 環境変数からアクセス認証情報を取得します。サンプルコードを実行する前に、OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
auth = oss2.ProviderAuthV4(EnvironmentVariableCredentialsProvider())

# バケットが配置されているリージョンのエンドポイントを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
endpoint = "https://oss-cn-hangzhou.aliyuncs.com"
# エンドポイントが配置されているリージョン (cn-hangzhou など) を指定します。注意：このパラメーターは V4 署名に必要です。
region = "cn-hangzhou"

# yourBucketName をバケットの名前に設定します。
bucket = oss2.Bucket(auth, endpoint, "yourBucketName", region=region)

# 最初のアップロードでは、追加位置 (Position パラメーター) を 0 に設定します。
result = bucket.append_object('yourObjectName', 0, 'content of first append')
# データが追加されたオブジェクトのバージョン ID を表示します。
print('append object versionid:', result.versionid)
# これが最初の追加操作でない場合は、bucket.head_object メソッドまたは以前の追加操作の戻り値の next_position プロパティから追加位置を取得できます。
bucket.append_object('yourObjectName', result.next_position, 'content of second append')

次のコードは、マルチパートアップロードを実行する方法を示しています。

# -*- coding: utf-8 -*-
import os
import oss2
from oss2.credentials import EnvironmentVariableCredentialsProvider
from oss2 import SizedFileAdapter, determine_part_size
from oss2.models import PartInfo
# 環境変数からアクセス認証情報を取得します。サンプルコードを実行する前に、OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
auth = oss2.ProviderAuthV4(EnvironmentVariableCredentialsProvider())

# バケットが配置されているリージョンのエンドポイントを指定します。たとえば、バケットが中国 (杭州) リージョンにある場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。
endpoint = "https://oss-cn-hangzhou.aliyuncs.com"
# エンドポイントが配置されているリージョン (cn-hangzhou など) を指定します。注意：このパラメーターは V4 署名に必要です。
region = "cn-hangzhou"

# yourBucketName をバケットの名前に設定します。
bucket = oss2.Bucket(auth, endpoint, "yourBucketName", region=region)

key = 'yourObjectName'
filename = 'yourLocalFile'

total_size = os.path.getsize(filename)
# determine_part_size メソッドは、パートサイズを決定するために使用されます。
part_size = determine_part_size(total_size, preferred_size=100 * 1024)

# マルチパートアップロードを初期化します。
upload_id = bucket.init_multipart_upload(key).upload_id
parts = []

# パートを 1 つずつアップロードします。
with open(filename, 'rb') as fileobj:
    part_number = 1
    offset = 0
    while offset < total_size:
        num_to_upload = min(part_size, total_size - offset)
    # SizedFileAdapter(fileobj, size) メソッドは、新しいファイルオブジェクトを生成し、データを追加するための開始位置を再計算します。
        result = bucket.upload_part(key, upload_id, part_number,
                                    SizedFileAdapter(fileobj, num_to_upload))
        parts.append(PartInfo(part_number, result.etag))

        offset += num_to_upload
        part_number += 1

# マルチパートアップロードを完了します。
result = bucket.complete_multipart_upload(key, upload_id, parts)
# 応答でアップロードされたファイルの versionid を表示します。
print('result.versionid:', result.versionid)


# マルチパートアップロードを検証します。
with open(filename, 'rb') as fileobj:
    assert bucket.get_object(key).read() == fileobj.read()