オブジェクトのアップロード

file = open('file_path','rb')
res = bucket.put_object("sam/out/sample.txt",file)
print(res)

res = bucket.put_object("sam/out/sample.txt",'content of the file')
print(res)

options = {
    'overwrite': 'true',
    'ttl': '300', #有効期限を秒単位で指定する
    'meta_data': {
        'author': 'John'
    } 
}
file = open('file_path','rb')
res = bucket.put_object("sam/out/sample.txt",file, options)
print(res)

# extract_uploadを含むアップロードオプションを定義する
options = {
    # オブジェクトが既に存在する場合は上書きする
    'overwrite': 'true',
    # オブジェクトが期限切れになるまでの有効期間（秒）
    'ttl': '300',
    # ZIPファイルの内容を自動的に展開する
    'extract_upload': 'true',
    # オブジェクトのMIMEタイプ
    'content-type': 'application/zip',
    # オブジェクトに関連付けられたカスタムメタデータ
    'meta_data': {
        'author': 'Sam'
    }
}
#バイナリモードでファイルを開く
file = open('sam.zip', 'rb')
#ZIPの内容をアップロードして展開する
res = bucket.put_object('sam/sample.zip', file, options)

{ 'task_id': '1234263749' }

init_res = bucket.initiate_multipart_upload(key="")
print(init_res)

{
  bucket: 'zcstratus123-development',
  key: 'objectName.txt',
  upload_id: '01j7xbm4vm5750zbedxqgc4q6m',
  status: 'PENDING'
}

upload_res = bucket.upload_part(key="",upload_id="", part_number=3, body=open('file_path','rb'))
print(upload_res)

summary_res = bucket.get_multipart_upload_summary(key="", upload_id="")
print(summary_res)

{
    "bucket": "zcstratus12345-development",
    "key": "sasm.txt",
    "upload_id": "01hyfyeazrrstmt7k5fa7ej726",
    "status": "PENDING",
    "parts": [
        {
            "part_number": 1,
            "size": 0,
            "uploaded_at": 1716374678999
        },
        {
            "part_number": 2,
            "size": 2797094,
            "uploaded_at": 1716374678576
        },
        {
            "part_number": 4,
            "size": 0,
            "uploaded_at": 1716374679136
        }
    ]
}

complete_res = bucket.complete_multipart_upload(key="", upload_id="")
print(complete_res)

from concurrent.futures import ThreadPoolExecutor
import zcatalyst_sdk

def handler(request: Request):
    app = zcatalyst_sdk.initialize()
    if request.path == "/":
        # Stratusインスタンス
        stratus = app.stratus()
        # バケットインスタンス
        bucket = stratus.bucket('bucket_name')
        # マルチパートアップロード
        key = "sam/out/sample.txt"
        file_path = '/sam/smple.mp4'
        initiate_res = bucket.initiate_multipart_upload(key)
        part_number = 1
        part_size = 50 * 1024 * 1024
        futures = []
        try:
            with open(file_path, 'rb') as file:
                with ThreadPoolExecutor(max_workers=3) as executor:
                    while True:
                        chunk = file.read(part_size)
                        if not chunk:
                            break
                        futures.append(executor.submit(
      	bucket.upload_part,
      	key,
      	initiate_res['upload_id'],
      	chunk, part_number
     	)
       )
                        part_number += 1
            for future in futures:
                future.result()
         except Exception as err:
            raise err
         multipart_upload_res = bucket.complete_multipart_upload(key, initiate_res['upload_id'])
	return multipart_upload_res
	else:
 	response = make_response('Unknown path')
 	response.status_code = 400
 	return response

from zcatalyst_sdk.stratus.transfer_manager import TransferManager

transfer_manager = TranferManager(bucket)

init_ins = transfer_manager.create_multipart_instance(key="")

init_ins = transfer_manager.create_multipart_instance(key="", upload_id="")

upload_res = init_ins.upload_part(body=open('file_path','rb'), part_number=3)
print(upload_res)

summary_res = init_ins.get_upload_summary()
print(summary_res)

complete_res = init_ins.complete_upload()
print(complete_res)

upload_res = transfer_res.put_object_as_parts(key='', body=open('file_path', 'rb'), part_size=50)
print(upload_res)

pre_signed_url_res = bucket.generate_presigned_url("sam/out/sample.txt",url_action='PUT',expiry_in_sec='300', active_from='1023453725828')
print(pre_signed_url_res)

{
  "signature": "https://sadi-development.zohostratus.com/_signed/code.txt?organizationId=96862383&stsCredential=96858154-96862383&stsDate=1747899245773&stsExpiresAfter=300&stsSignedHeaders=host&stsSignature=YBPoNE9txCIUWWX3ntdgVd95VTt1jGFlSuvnTRFbCMQ"
file_path = "/Users/ranjitha-18338/Documents/Pyhton-SDK/filestore2.0/output.txt",
  "expiry_in_seconds": "300",
  "active_from": "1726492859577"
}

import requests

#実際の署名付きURLに置き換える
url = "https://sadi-development.zohostratus.com/_signed/code.txt?organizationId=96862383&stsCredential=96858154-96862383&stsDate=1747899245773&stsExpiresAfter=300&stsSignedHeaders=host&stsSignature=YBPoNE9txCIUWWX3ntdgVd95VTt1jGFlSuvnTRFbCMQ"
#アップロードするローカルファイルのパス
file_path = "file_path"
#必須ヘッダーを設定する
headers = {
    # 'Content-Type': 'text/plain',  # ファイルのコンテンツタイプを指定する
    # 'overwrite': 'true',           # 上書きを示すオプションのカスタムヘッダー（サーバーで必要な場合）
}
#バイナリ読み取りモードでファイルを開き、PUTリクエストを送信してアップロードする
with open(file_path, 'rb') as f:
    files = {'file': f}  #ファイルペイロードを作成する
    response = requests.put(url, headers=headers, files=files)
    #レスポンスステータスを確認する
    if response.status == 200:
        print('Object uploaded successfully')
    else:
        print('Object upload failed')