ali-oss

import OSS from 'ali-oss'; import { readFileSync, unlinkSync, existsSync, writeFileSync } from 'fs'; import { join } from 'path'; async function runOssOperations() { const client = new OSS({ region: process.env.ALI_OSS_REGION ?? 'oss-cn-hangzhou', // e.g., 'oss-cn-hangzhou' accessKeyId: process.env.ALI_OSS_AKID ?? 'YOUR_ACCESS_KEY_ID', accessKeySecret: process.env.ALI_OSS_AKSECRET ?? 'YOUR_ACCESS_KEY_SECRET', bucket: process.env.ALI_OSS_BUCKET ?? 'your-test-bucket', // Ensure this bucket exists secure: true, // Always use HTTPS for production }); const objectName = `my-test-file-${Date.now()}.txt`; const localFilePath = join(process.cwd(), 'temp_test_file.txt'); const fileContent = 'Hello, Alibaba Cloud OSS! This is a test file.\nAnother line of content.'; // Create a dummy local file for upload writeFileSync(localFilePath, fileContent); console.log(`Created local file: ${localFilePath}`); try { // 1. Upload a file console.log(`Uploading ${objectName}...`); const putResult = await client.put(objectName, localFilePath); console.log('Upload successful. ETag:', putResult.etag, 'Status:', putResult.res.status); // 2. Download the file and verify content console.log(`Downloading ${objectName}...`); const getResult = await client.get(objectName); console.log('Download successful. Content:', getResult.content.toString()); if (getResult.content.toString() === fileContent) { console.log('Content verification successful.'); } else { console.warn('Downloaded content differs from original.'); } // 3. List objects in the bucket console.log('Listing objects in bucket...'); const listResult = await client.list({ prefix: 'my-test-file-', // Filter for our test files 'max-keys': 5, }); console.log('Found objects:', listResult.objects.map(obj => obj.name)); // 4. Get object metadata (head request) console.log(`Getting metadata for ${objectName}...`); const headResult = await client.head(objectName); console.log('Object metadata status:', headResult.res.status, 'Content-Length:', headResult.res.headers['content-length']); // 5. Delete the file console.log(`Deleting ${objectName}...`); const deleteResult = await client.delete(objectName); console.log('Delete successful. Status:', deleteResult.res.status); } catch (error: any) { console.error('OSS operation failed:', error.message); if (error.code === 'NoSuchBucket') { console.error('ERROR: Please ensure the bucket exists and you have correct region and permissions.'); } else if (error.code === 'AccessDenied') { console.error('ERROR: Check your AccessKeyId, AccessKeySecret, and IAM permissions.'); } } finally { // Clean up local file if (existsSync(localFilePath)) { unlinkSync(localFilePath); console.log(`Cleaned up local file: ${localFilePath}`); } } } runOssOperations();