产品动态
公告
上传方式 | 上传域名 | 上传凭证 | 支持操作 |
存储桶内网预置域名 | [BucketId].vodsrc-internal.[存储地域].eovod.com | 永久密钥 | 上传至指定存储桶 |
1234567890 ，存储桶的存储地域为 ap-guangzhou，存储桶 ID 为 bucketid1。bucketid1.vodsrc-internal.ap-guangzhou.eovod.com。nslookup等指令进行域名解析，若得到形如 10.*.*.*、100.*.*.*或169.254.*.*等形式的 IP，则一般可以进行内网访问。// Package main// 本示例基于 AWS SDK for Go v2 service/s3 v1.72.3 实现。// AWS SDK for Go v2 service/s3 v1.73.0 及以后版本需禁用 S3 的默认完整性保护。// 具体参考: https://github.com/aws/aws-sdk-go-v2/discussions/2960package mainimport ("context""errors""fmt""log""net/url""os""github.com/aws/aws-sdk-go-v2/aws""github.com/aws/aws-sdk-go-v2/credentials""github.com/aws/aws-sdk-go-v2/feature/s3/manager""github.com/aws/aws-sdk-go-v2/service/s3"smep "github.com/aws/smithy-go/endpoints""github.com/aws/smithy-go/logging")// customEndpointResolverV2 自定义接入点type customEndpointResolverV2 struct{}// ResolveEndpoint 自定义接入点func (r *customEndpointResolverV2) ResolveEndpoint(ctx context.Context,params s3.EndpointParameters) (smep.Endpoint, error) {if params.Bucket == nil || params.Region == nil {return smep.Endpoint{}, errors.New("invalid endpoint param")}return smep.Endpoint{URI: url.URL{Scheme: "https",Host: fmt.Sprintf("%s.vodsrc-internal.ap-guangzhou.eovod.com", *params.Bucket),},}, nil}func main() {// new s3 clients3cli := s3.New(s3.Options{Credentials: credentials.NewStaticCredentialsProvider("AccessKeyId", // 填入密钥对中的 AccessKeyId"SecretAccessKey", // 填入密钥对中的 SecretAccessKey""), // 永久密钥无需填充 SessionTokenEndpointResolverV2: new(customEndpointResolverV2), // 自定义接入点UsePathStyle: false, // 请求禁用 path styleLogger: logging.NewStandardLogger(os.Stdout), // 日志打印到标准输出流ClientLogMode: aws.LogRequest | aws.LogResponse, // 打印请求头和响应头Region: "auto", // 固定填写 auto})// 打开本地文件file, err := os.Open("demo.mp4") // 本地文件路径if err != nil {log.Fatalf("failed to open file: %v", err)return}defer file.Close()// 上传文件到 S3// 创建上传器uploader := manager.NewUploader(s3cli, func(u *manager.Uploader) {u.PartSize = 10 * 1024 * 1024 // 设置分片大小为 10MBu.Concurrency = 5 // 设置并发上传的分片数})// 上传文件result, err := uploader.Upload(context.TODO(), &s3.PutObjectInput{Bucket: aws.String("bucketid1"), // Bucket 设置为点播专业版应用中的存储桶 IDKey: aws.String("upload/demo.mp4"), // 媒体文件在存储桶中的路径Body: file,})if err != nil {log.Fatalf("failed to upload file: %v", err)return}log.Printf("etag: %s", *result.ETag) // 获取上传文件 etag}
// 本示例基于 AWS SDK for Java v2 service/s3 v2.31.35 实现。// AWS SDK for Java 2.30.0 及以后版本需禁用 S3 的默认完整性保护。// 具体参考: https://github.com/aws/aws-sdk-java-v2/issues/5801import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;import software.amazon.awssdk.http.nio.netty.NettyNioAsyncHttpClient;import software.amazon.awssdk.regions.Region;import software.amazon.awssdk.services.s3.S3AsyncClient;import software.amazon.awssdk.services.s3.S3Configuration;import software.amazon.awssdk.transfer.s3.S3TransferManager;import software.amazon.awssdk.transfer.s3.model.UploadFileRequest;import software.amazon.awssdk.transfer.s3.progress.LoggingTransferListener;import software.amazon.awssdk.core.checksums.RequestChecksumCalculation;import software.amazon.awssdk.core.checksums.ResponseChecksumValidation;import java.io.File;import java.net.URI;import java.util.concurrent.CompletableFuture;public class Main {public static void main(String[] args) {S3AsyncClient s3AsyncClient = null;S3TransferManager transferManager = null;try {// 专业版应用永久密钥 AccessKeyIdAwsBasicCredentials credentials = AwsBasicCredentials.create("AccessKeyId", // 专业版应用永久密钥 AccessKeyId"SecretAccessKey" // 专业版应用永久密钥 SecretAccessKey);String region = "ap-guangzhou"; // 专业版应用存储桶地域String bucketId = "bucketid1"; // 专业版应用存储桶IDString filePath = "demo.mp4"; // 本地文件路径String key = "upload/demo.mp4"; // 文件在存储桶中的路径String endpointUrl = String.format("https://vodsrc-internal.%s.eovod.com", region); // 桶级别预置域名端点// 使用自定义端点构建S3异步客户端s3AsyncClient = S3AsyncClient.builder().credentialsProvider(StaticCredentialsProvider.create(credentials)) // 设置凭证提供者.endpointOverride(URI.create(endpointUrl)) // 设置端点.region(Region.of("auto")) // 设置区域 auto 自动选择.httpClient(NettyNioAsyncHttpClient.builder().build()) // 设置HTTP客户端.serviceConfiguration(S3Configuration.builder().pathStyleAccessEnabled(false) // 设置路径样式访问, 桶级别需明确禁用 PathStyle 模式.build()).requestChecksumCalculation(RequestChecksumCalculation.WHEN_REQUIRED).responseChecksumValidation(ResponseChecksumValidation.WHEN_REQUIRED).build();// 使用S3异步客户端创建S3TransferManagertransferManager = S3TransferManager.builder().s3Client(s3AsyncClient).build();File fileToUpload = new File(filePath);// 创建上传请求并添加传输监听器用于进度跟踪UploadFileRequest uploadRequest = UploadFileRequest.builder().putObjectRequest(builder -> builder.bucket(bucketId).key(key)).addTransferListener(LoggingTransferListener.create()).source(fileToUpload).build();// 开始上传CompletableFuture<Void> future = transferManager.uploadFile(uploadRequest).completionFuture().thenAccept(response -> {System.out.println("上传成功! ETag: " + response.response().eTag());});// 等待上传完成future.join();System.out.println("上传任务完成");} catch (Exception e) {System.err.println("上传失败: " + e.getMessage());e.printStackTrace();} finally {// 资源释放try {if (transferManager != null) {transferManager.close();}if (s3AsyncClient != null) {s3AsyncClient.close();}System.out.println("资源已释放");} catch (Exception e) {System.err.println("关闭资源时发生错误: " + e.getMessage());}}}}
// 本示例基于 AWS SDK for C++ v1.11.560 实现。// AWS SDK for C++ v1.11.486 及以后版本需禁用 S3 的默认完整性保护。// 具体参考: https://github.com/aws/aws-sdk-cpp/issues/3253#include <aws/core/Aws.h>#include <aws/core/auth/AWSCredentials.h>#include <aws/core/client/ClientConfiguration.h>#include <aws/s3/S3Client.h>#include <aws/transfer/TransferManager.h>#include <iostream>int main(){// AWS SDK 初始化Aws::SDKOptions options;options.loggingOptions.logLevel = Aws::Utils::Logging::LogLevel::Info;Aws::InitAPI(options);{// 定义认证和端点信息const Aws::String accessKeyId = "AccessKeyId"; // 填入点播专业版密钥对中的 AccessKeyIdconst Aws::String secretAccessKey = "SecretAccessKey"; // 填入点播专业版密钥对中的 SecretAccessKeyconst Aws::String region = "ap-guangzhou"; // 存储桶所在地域const Aws::String bucketId = "bucketid1"; // 点播专业版应用中的存储桶 IDconst Aws::String keyName = "upload/demo.mp4"; // 文件在存储桶中的路径const Aws::String filePath = "demo.mp4"; // 本地文件路径// 配置客户端Aws::Client::ClientConfiguration clientConfig;clientConfig.region = "auto"; // 固定填写 autoclientConfig.scheme = Aws::Http::Scheme::HTTPS; // 协议使用 HTTPSclientConfig.enableEndpointDiscovery = false; // 禁用 endpoint discoveryclientConfig.verifySSL = true; // 启用 SSL 证书验证clientConfig.endpointOverride = "vodsrc-internal." + region + ".eovod.com"; // 桶级别预置域名// 禁用完整性校验clientConfig.checksumConfig.requestChecksumCalculation = Aws::Client::RequestChecksumCalculation::WHEN_REQUIRED;clientConfig.checksumConfig.responseChecksumValidation = Aws::Client::ResponseChecksumValidation::WHEN_REQUIRED;// 设置认证信息Aws::Auth::AWSCredentials credentials(accessKeyId, secretAccessKey); // 填入点播专业版永久密钥// 创建 S3 客户端auto s3Client = Aws::MakeShared<Aws::S3::S3Client>("S3Client",credentials,clientConfig,Aws::Client::AWSAuthV4Signer::PayloadSigningPolicy::Never, // 禁用 payload signingtrue // 桶级别预置域名需明确使用 VirtualAddressing);// 创建线程池执行器auto executor = Aws::MakeShared<Aws::Utils::Threading::PooledThreadExecutor>("executor", 10);// 配置 TransferManagerAws::Transfer::TransferManagerConfiguration transferConfig(executor.get());transferConfig.s3Client = s3Client;// 设置分片大小为 10MBtransferConfig.bufferSize = 10 * 1024 * 1024;// 创建 TransferManagerauto transferManager = Aws::Transfer::TransferManager::Create(transferConfig);std::cout << "Starting file upload: " << filePath << " to " << bucketId << "/" << keyName << std::endl;// 执行上传auto uploadHandle = transferManager->UploadFile(filePath, // 本地文件路径bucketId, // 存储桶IDkeyName, // 对象键（存储路径）"application/octet-stream", // 内容类型Aws::Map<Aws::String, Aws::String>() // 元数据);// 等待上传完成uploadHandle->WaitUntilFinished();// 检查上传状态if (uploadHandle->GetStatus() == Aws::Transfer::TransferStatus::COMPLETED){std::cout << "File upload completed successfully!" << std::endl;}else{auto lastError = uploadHandle->GetLastError();std::cerr << "File upload failed: " << lastError.GetMessage() << std::endl;}}// 清理SDK资源Aws::ShutdownAPI(options);return 0;}
#!/usr/bin/env python3# -*- coding: utf-8 -*-"""本示例基于 AWS SDK for Python v1.38.7 实现。Boto3 的 AWS SDK for Python v1.36.0 及以后版本需禁用 S3 的默认完整性保护。具体参考: https://github.com/boto/boto3/issues/4392"""import boto3from botocore.config import Configfrom botocore.exceptions import ClientError# 常量定义REGION = "ap-guangzhou" # 存储桶地域BUCKET_ID = "bucketid1" # 填入点播专业版应用中的存储桶 IDFILE_PATH = "demo.mp4" # 本地文件路径OBJECT_KEY = "upload/demo.mp4" # 文件在存储桶中的路径# 创建 S3 客户端s3_client = boto3.client("s3",aws_access_key_id="AccessKeyId", # 填入密钥对中的 AccessKeyIdaws_secret_access_key="SecretAccessKey", # 填入密钥对中的 SecretAccessKeyendpoint_url=f"https://vodsrc-internal.{REGION}.eovod.com", # 桶级别预置上传域名config=Config(s3={"addressing_style": "virtual"}, # 使用 virtual hosted-stylerequest_checksum_calculation="when_required", # Boto3 的 AWS SDK for Python v1.36.0 及以后版本需禁用 S3 的默认完整性保护。response_checksum_validation="when_required", # Boto3 的 AWS SDK for Python v1.36.0 及以后版本需禁用 S3 的默认完整性保护。),)try:# 上传文件response = s3_client.upload_file(Bucket=BUCKET_ID, # 填入点播专业版应用中的存储桶 IDKey=OBJECT_KEY, # 文件在存储桶中的路径Filename=FILE_PATH, # 本地文件路径)print(response)except ClientError as e:print(f"Error: {e}")
文档反馈