Objectのアップロード

// オブジェクトアップロード用のリードストリームを作成する
const file = fs.createReadStream("file_path");
// アップロードメソッドを呼び出す
const res = await bucket.putObject("sam/out/sample.txt", file);
console.log(res);

//オブジェクトを文字列としてアップロードする
const res = await bucket.putObject("sam/out/sample.txt", "Content of the file");
console.log(res);

const options = {
'overwrite': true, //これにより既存のオブジェクトが上書きされます
'ttl': '300', //有効期限（秒単位）
'metaData': {
'author': 'John'
}
};
const file = fs.createReadStream("filePath");
const uploadRes = await bucket.putObject("sam/out/sample.txt", file, options);
console.log(uploadRes);

const options = {
'ttl': '300', //有効期限（秒単位）
'metaData': {
'author': 'John'
},
// 指定されたZIPファイルの内容を展開し、各ファイルを個別のオブジェクトとしてバケットにアップロードする
'extractUpload': true
};
const file = fs.createReadStream("filePath");
const uploadRes = await bucket.putObject("sam/out/sample.zip", file, options);
console.log(uploadRes);

{ 'task_id': '1234263749' }

const initRes = await bucket.initiateMultipartUpload("sam/out/sample.txt");
console.log(initRes);

{
"bucket": "zcstratus123-development",
"key": "sam/out/sample.txt",
"upload_id": "01j7xbm4vm5750zbedxqgc4q6m",
"status": "PENDING"
}

let partNumber = 1;
const file = fs.createReadStream("filePath");
const uploadPartRes = await bucket.uploadPart("sam/out/sample.txt", "uploadId", file, partNumber);
console.log(uploadPartRes);

const uploadSummaryRes = await bucket.getMultipartUploadSummary("sam/out/sample.txt", "upload_id");
console.log(uploadSummaryRes);

{
"bucket": "zcstratus12345-development",
"key": "sam/out/sample.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
}
]
}

const completeUploadRes = await bucket.completeMultipartUpload("sam/out/sample.txt", "uploadId");
console.log(completeUploadRes);

const catalyst = require('zcatalyst-sdk-node');
const fs = require('fs');
module.exports = async (req, res) => {
url = req.url;
switch (url) {
case '/':
const app = catalyst.initialize(req);
const stratus = app.stratus();
// バケットインスタンスを作成する
const bucket = stratus.bucket("bucket_name");
// マルチパートアップロード
const key = 'sample.mp4';
// マルチパートアップロードを開始する
const initRes = await bucket.initiateMultipartUpload(key);
// アップロード開始レスポンスからアップロードIDを取得する。
const uploadId = initRes['upload_id'];
const filePath = '/Users/Aliza//sam.mp4';
const partSize = 50 * 1024 * 1024; // MB単位
const fileStream = fs.createReadStream(
filePath,
{ highWaterMark: partSize }
);
let partNumber = 1;
const uploadPromises = [];
fileStream.on('data', async (partData) => {
// 各パートのアップロードをPromise配列に追加して並列アップロードする
const partUploadPromise = bucket.uploadPart(
key,
uploadId,
partData,
partNumber
);
uploadPromises.push(partUploadPromise);
console.log('Part Number: ', partNumber);
partNumber++;
});
// すべてのパートが並列でアップロードされるのを待つ
fileStream.on('end', async () => {			
await Promise.all(uploadPromises);
// マルチパートアップロードを完了する
await bucket.completeMultipartUpload(key, uploadId);
console.log('Successfully Uploaded');
});
res.end();
break;
default:
res.writeHead(404);
res.write('You might find the page you are looking for at "/" path');
break;
}
}

const { TransferManager } = require('zcatalyst-sdk-node/lib/stratus');

 const transferManager = new TransferManager(bucket); // Transfer Managerインスタンスを作成

const multipart = await transferManager.createMultipartInstance("sam/out/sample.txt"); // マルチパートインスタンスを作成

const multipart = await transferManager.createMultipartInstance("sam/out/sample.txt", "uploadId");

const uploadRes = await multipart.uploadPart(fs.createReadStream("filePath"), partNumber);
console.log(uploadRes);

const summaryRes = await multipart.getUploadSummary();
console.log(summaryRes);

const completeRes = await multipart.completeUpload();
console.log(completeRes);

const file = fs.createReadStream("filePath");
const partSize = 50 // MB単位
const objectPartUploadRes = await transferManager.putObjectAsParts("sam/out/sample.txt",file, partSize);
console.log(objectPartUploadRes);

const signedURLRes = await bucket.generatePreSignedUrl("sam/out/sample.txt", 'PUT', {
'expiryIn': 100, // 有効期限（秒）
'activeFrom':'12334454327', // 指定された日付にURLを有効化
});
console.log(signedURLRes);

{
signature: "https://sadi-development.zohostratus.com/_signed/text.txt?organizationId=96862383&stsCredential=96858154-96862383&stsDate=1747896279887&stsExpiresAfter=300&stsSignedHeaders=host&stsSignature=3YBUX1HFSxNQzQJjFrln82AyJsEEuC5T9dsZwWxGyEE"
}

const axios = require('axios');
const fs = require('fs');
// アップロード用に生成された実際の署名付きURLに置き換えてください。
const url = 'https://sadi-development.zohostratus.com/_signed/text.txt?organizationId=96862383&stsCredential=96858154-96862383&stsDate=1747911331272&stsExpiresAfter=300&stsSignedHeaders=host&stsSignature=K9vuqC7JaATLeM3TX4xXWx0OHcSflbYQ2jCrbKSAAIE';
// 'file_path'を実際のファイルパスに置き換えてください
const data = fs.createReadStream('/Users/ranjitha-18338/Documents/NODE-SDK/Stratus/sam.py');
// オプションのヘッダー。コンテンツタイプはファイルタイプによって異なる場合があります
const headers = {
// 'Content-Type': 'application/json', 
// 非JSONファイルをアップロードする場合は調整してください（例：'text/plain'または'application/octet-stream'）
// 'overwrite': 'true', // オプションのヘッダー
};
(async () => {
try {
const response = await axios.put(url, data, { headers });
if (response.status === 200) {
console.log('Object uploaded successfully');
} else {
console.log('⚠️ Error uploading object:', response.data);
}
} catch (error) {
console.error('Upload failed:', error.response?.data || error.message);
}
})();