ApsaraVideo VOD:OSS SDKを使用したメディアファイルのアップロード

手順2: OSS SDKのインストール

1. aliyun-OSS-PHP-SDKページからoss sdk for phpの最新のソースコードパッケージをダウンロードします。

2. パッケージを解凍し、解凍したフォルダをaliyun-php-sdkフォルダにコピーします。

   たとえば、aliyun-oss-php-sdk-2.4.3.zipをダウンロードして解凍すると、解凍されたフォルダはaliyun-oss-php-sdk-2.4.3になります。 詳細については、「インストール」をご参照ください。

ステップ3: メディアファイルのアップロード

<?php
// 1. Reference the files of ApsaraVideo VOD and OSS in the code. 
  // In this example, your source code file is in the aliyun-php-sdk folder. 
require_once './aliyun-php-sdk/aliyun-php-sdk-core/Config.php';   
require_once './aliyun-php-sdk/aliyun-oss-php-sdk-2.4.3/autoload.php';
use vod\Request\V20170321 as vod;
use OSS\OssClient;
use OSS\Core\OssException;
// 2. Initialize an ApsaraVideo VOD client by using an AccessKey pair. 
function init_vod_client($accessKeyId, $accessKeySecret) {
  // Specify the region in which ApsaraVideo VOD is activated. Example: cn-shanghai.
    $regionId = 'cn-shanghai';     
    $profile = DefaultProfile::getProfile($regionId, $accessKeyId, $accessKeySecret);
    return new DefaultAcsClient($profile);
}
// 3. Obtain an upload URL and an upload credential.
function create_upload_video($vodClient) {
    $request = new vod\CreateUploadVideoRequest();
    $request->setTitle("Video title");        // Required. The title of the video.
    $request->setFileName("File name.mov"); // Required. The name of the source video file, which must contain a file name extension.
    $request->setDescription("Video description");  // Optional. The description of the source video file.
  // CoverURL example: http://example.alicdn.com/tps/TB1qnJ1PVXXXXXCXXXXXXXXXXXX-700-****.png.
    $request->setCoverURL("<URL of the video thumbnail>"); // Optional. The URL of the custom video thumbnail.
    $request->setTags("Tag 1,Tag 2"); // Optional. The tags of the video. Separate multiple video tags with commas (,).
    return $vodClient->getAcsResponse($request);
}

// 4. Use the upload URL and credential to initialize an OSS client with an STS token. 
function init_oss_client($uploadAuth, $uploadAddress) {
    $ossClient = new OssClient($uploadAuth['AccessKeyId'], $uploadAuth['AccessKeySecret'], $uploadAddress['Endpoint'],
        false, $uploadAuth['SecurityToken']);
  // The request timeout period. Unit: seconds. Default value: 5184000. We recommend that you set the parameter to a large value because the upload of large files takes a long time.
    $ossClient->setTimeout(86400*7);  
  // The connection timeout period. Unit: seconds. Default value: 10.
    $ossClient->setConnectTimeout(10);  
    return $ossClient;
}
// 5. Upload a video file. 
function upload_local_file($ossClient, $uploadAddress, $localFile) {
    return $ossClient->uploadFile($uploadAddress['Bucket'], $uploadAddress['FileName'], $localFile);
}

// The AccessKey pair of an Alibaba Cloud account has permissions on all API operations. We recommend that you use a RAM user to call API operations or perform routine O&M. 
// We recommend that you do not include your AccessKey pair (AccessKey ID and AccessKey secret) in your project code. Otherwise, the AccessKey pair may be leaked and the security of all resources within your account may be compromised. 
// In this example, ApsaraVideo VOD reads the AccessKey pair from the environment variables to implement identity verification for API access. Before you run the sample code, configure the environment variables ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET. 
$accessKeyId = getenv('ALIBABA_CLOUD_ACCESS_KEY_ID'); // Your AccessKey ID.
$accessKeySecret = getenv('ALIBABA_CLOUD_ACCESS_KEY_SECRET'); // Your AccessKey secret.
$localFile = '/Users/aligame/Downloads/****.mp4';   // The full path of the local video file to be uploaded to ApsaraVideo VOD.
try {
    // Initialize the ApsaraVideo VOD client and obtain the upload URL and credential.
    $vodClient = init_vod_client($accessKeyId, $accessKeySecret);
    $createRes = create_upload_video($vodClient);
    // If the execution is successful, VideoId, UploadAddress, and UploadAuth are returned. Decode the Base64-encoded upload URL and upload credential. 
    $videoId = $createRes->VideoId;
    $uploadAddress = json_decode(base64_decode($createRes->UploadAddress), true);
    $uploadAuth = json_decode(base64_decode($createRes->UploadAuth), true);
    // Use the obtained upload URL and upload credential to initialize an OSS client.
    $ossClient = init_oss_client($uploadAuth, $uploadAddress);
    // Upload a video file. Take note that multiple parts are uploaded in parallel. The system starts to upload the next file only when all parts of the current file have been uploaded. The consumed time depends on the file size and upstream bandwidth.
    $result = upload_local_file($ossClient, $uploadAddress, $localFile);
    printf("Succeed, VideoId: %s", $videoId);
} catch (Exception $e) {
    // var_dump($e);
    printf("Failed, ErrorMessage: %s", $e->getMessage());
}
                

手順2: OSS SDKのインストール

1. go getまたはglideコマンドを実行して、Alibaba Cloud SDK for Goをインストールします。

   • go getコマンドを実行して、Alibaba Cloud SDK for Goをインストールします。

     go get -u github.com/aliyun/alibaba-cloud-sdk-go/sdk

     説明

     • インストール中にメッセージが表示されません。 インストールプロセスが完了するまでに数分かかります。 インストールがタイムアウトした場合は、コマンドを再度実行します。

     • sr c/github.com/aliyun/alibaba-cloud-sdk-go/services/vodサブフォルダがGOPATH変数で指定されたフォルダに表示される場合、SDKがインストールされます。

   • glideコマンドを実行して、Alibaba Cloud SDK for Goをインストールします。

     glide get github.com/aliyun/alibaba-cloud-sdk-go

2. OSS SDKをインストールします。 詳細については、「インストール」をご参照ください。

ステップ3: メディアファイルのアップロード

 package main

import (
    "encoding/base64"
    "encoding/json"
    "fmt"
    "github.com/aliyun/alibaba-cloud-sdk-go/sdk"
    "github.com/aliyun/alibaba-cloud-sdk-go/sdk/auth/credentials"
    "github.com/aliyun/alibaba-cloud-sdk-go/services/vod"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
    "os"
)

func InitVodClient(accessKeyId string, accessKeySecret string) (client *vod.Client, err error) {
    // Specify the storage region of ApsaraVideo VOD.
    regionId := "cn-shanghai"
    // Create an object for authorization.
    credential := &credentials.AccessKeyCredential{
        accessKeyId,
        accessKeySecret,
    }
    // The custom configuration parameters.
    config := sdk.NewConfig()
    config.AutoRetry = true     // Specifies whether to automatically reconnect to the network if a connection fails.
    config.MaxRetryTime = 3     // The maximum number of retry attempts.
    config.Timeout = 3000000000 // The connection timeout period. Unit: nanoseconds. Default value: 3000000000.
    // Create a vodClient instance.
    return vod.NewClientWithOptions(regionId, config, credential)
}

func MyCreateUploadVideo(client *vod.Client) (response *vod.CreateUploadVideoResponse, err error) {
    request := vod.CreateCreateUploadVideoRequest()
    request.Title = "Sample Video Title"
    request.Description = "Sample Description"
    request.FileName = "/opt/video/sample/video_file.mp4"
    //request.CateId = "-1"
    // Sample URL of the video thumbnail: example:http://example.alicdn.com/tps/TB1qnJ1PVXXXXXCXXXXXXXXXXXX-700-****.png.
    request.CoverURL = "<your CoverURL>"
    request.Tags = "tag1,tag2"
    request.AcceptFormat = "JSON"
    return client.CreateUploadVideo(request)
}

func InitOssClient(uploadAuthDTO UploadAuthDTO, uploadAddressDTO UploadAddressDTO) (*oss.Client, error) {
    client, err := oss.New(uploadAddressDTO.Endpoint,
        uploadAuthDTO.AccessKeyId,
        uploadAuthDTO.AccessKeySecret,
        oss.SecurityToken(uploadAuthDTO.SecurityToken),
        oss.Timeout(86400*7, 86400*7))
    return client, err
}

func UploadLocalFile(client *oss.Client, uploadAddressDTO UploadAddressDTO, localFile string) {
    // Obtain a storage location. 
    bucket, err := client.Bucket(uploadAddressDTO.Bucket)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // Upload the local file. 
    err = bucket.PutObjectFromFile(uploadAddressDTO.FileName, localFile)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
}

type UploadAuthDTO struct {
    AccessKeyId     string
    AccessKeySecret string
    SecurityToken   string
}
type UploadAddressDTO struct {
    Endpoint string
    Bucket   string
    FileName string
}

func main() {
    // The AccessKey pair of an Alibaba Cloud account has permissions on all API operations. We recommend that you use a RAM user to call API operations or perform routine O&M. 
    // We recommend that you do not include your AccessKey pair (AccessKey ID and AccessKey secret) in your project code. Otherwise, the AccessKey pair may be leaked and the security of all resources within your account may be compromised. 
    // In this example, ApsaraVideo VOD reads the AccessKey pair from the environment variables to implement identity verification for API access. Before you run the sample code, configure the environment variables ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET. 
    var accessKeyId string=os.Getenv ('ALIBABA_CLOUD_ACCESS_KEY_ID'); // Your AccessKey ID.
    var accessKeySecret string=os.Getenv ('ALIBABA_CLOUD_ACCESS_KEY_SECRET); // Your AccessKey secret.
    var localFile string = "/opt/video/sample/video_file.mp4"     // The full path of the local video file to be uploaded to ApsaraVideo VOD.
    // Initialize the ApsaraVideo VOD client and obtain the upload URL and credential.
    var vodClient, initVodClientErr = InitVodClient(accessKeyId, accessKeySecret)
    if initVodClientErr != nil {
        fmt.Println("Error:", initVodClientErr)
        return
    }
    // Obtain an upload URL and an upload credential.
    var response, createUploadVideoErr = MyCreateUploadVideo(vodClient)
    if createUploadVideoErr != nil {
        fmt.Println("Error:", createUploadVideoErr)
        return
    }
    // If the execution is successful, VideoId, UploadAddress, and UploadAuth are returned.
    var videoId = response.VideoId
    var uploadAuthDTO UploadAuthDTO
    var uploadAddressDTO UploadAddressDTO
    var uploadAuthDecode, _ = base64.StdEncoding.DecodeString(response.UploadAuth)
    var uploadAddressDecode, _ = base64.StdEncoding.DecodeString(response.UploadAddress)
    json.Unmarshal(uploadAuthDecode, &uploadAuthDTO)
    json.Unmarshal(uploadAddressDecode, &uploadAddressDTO)
    // Use the obtained upload URL and upload credential to initialize an OSS client.
    var ossClient, _ = InitOssClient(uploadAuthDTO, uploadAddressDTO)
    // Upload a video file. Take note that multiple parts are uploaded in parallel. The system starts to upload the next file only when all parts of the current file have been uploaded. The consumed time depends on the file size and upstream bandwidth.
    UploadLocalFile(ossClient, uploadAddressDTO, localFile)
    //MultipartUploadFile(ossClient, uploadAddressDTO, localFile)
    fmt.Println("Succeed, VideoId:", videoId)
}
                

ステップ3。 メディアファイルのアップロード

import com.alibaba.fastjson.JSONObject;
import com.aliyun.oss.OSSClient;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.vod.model.v20170321.CreateUploadVideoRequest;
import com.aliyuncs.vod.model.v20170321.CreateUploadVideoResponse;
import org.apache.commons.codec.binary.Base64;

import java.io.File;

/**
 * descript
 */
public class UploadDemo {

    public static DefaultAcsClient initVodClient(String accessKeyId, String accessKeySecret) throws ClientException {
        // Specify the region in which ApsaraVideo VOD is activated. Example: cn-shanghai. For more information about other regions, see Overview. 
        String regionId = "cn-shanghai";
        DefaultProfile profile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
        DefaultAcsClient client = new DefaultAcsClient(profile);
        return client;
    }

    public static CreateUploadVideoResponse createUploadVideo(DefaultAcsClient vodClient) throws ClientException {
        CreateUploadVideoRequest request = new CreateUploadVideoRequest();
        request.setFileName("vod_test.mp4");
        request.setTitle("this is title");
        //request.setDescription("this is desc");
        //request.setTags("tag1,tag2");
        // Sample URL of the video thumbnail: http://example.aliyundoc.com/test_cover_****.jpg.
        //request.setCoverURL("<your CoverURL>");
        //request.setCateId(-1L);
        //request.setTemplateGroupId("");
        //request.setWorkflowId("");
        //request.setStorageLocation("");
        //request.setAppId("app-1000000");
        // The request timeout period.
        request.setSysReadTimeout(1000);
        request.setSysConnectTimeout(1000);
        return vodClient.getAcsResponse(request);
    }

    public static OSSClient initOssClient(JSONObject uploadAuth, JSONObject uploadAddress) {
        String endpoint = uploadAddress.getString("Endpoint");
        String accessKeyId = uploadAuth.getString("AccessKeyId");
        String accessKeySecret = uploadAuth.getString("AccessKeySecret");
        String securityToken = uploadAuth.getString("SecurityToken");
        return new OSSClient(endpoint, accessKeyId, accessKeySecret, securityToken);
    }

    public static void uploadLocalFile(OSSClient ossClient, JSONObject uploadAddress, String localFile) {
        String bucketName = uploadAddress.getString("Bucket");
        String objectName = uploadAddress.getString("FileName");
        File file = new File(localFile);
        ossClient.putObject(bucketName, objectName, file);
    }

    public static void main(String[] argv) {
        // The AccessKey pair of an Alibaba Cloud account has permissions on all API operations. We recommend that you use a RAM user to call API operations or perform routine O&M. 
        // We recommend that you do not include your AccessKey pair (AccessKey ID and AccessKey secret) in your project code. Otherwise, the AccessKey pair may be leaked and the security of all resources within your account may be compromised. 
        // In this example, ApsaraVideo VOD reads the AccessKey pair from the environment variables to implement identity verification for API access. Before you run the sample code, configure the environment variables ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET. 
        // Specify your AccessKey ID.
        String accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
        // Specify your AccessKey secret.
        String accessKeySecret = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
        // Specify the full path of the local file that you want to upload to ApsaraVideo VOD. The file name extension must be included in the path.
        String localFile = "/Users/yours/Video/testVideo.flv";
        try {
            // Initialize the ApsaraVideo VOD client and obtain the upload URL and credential.
            DefaultAcsClient vodClient = initVodClient(accessKeyId, accessKeySecret);
            CreateUploadVideoResponse createUploadVideoResponse = createUploadVideo(vodClient);
            // If the execution is successful, VideoId, UploadAddress, and UploadAuth are returned.
            String videoId = createUploadVideoResponse.getVideoId();

            JSONObject uploadAuth = JSONObject.parseObject(decodeBase64(createUploadVideoResponse.getUploadAuth()));
            JSONObject uploadAddress = JSONObject.parseObject(decodeBase64(createUploadVideoResponse.getUploadAddress()));

            // Use the obtained upload URL and upload credential to initialize an OSS client.
            OSSClient ossClient = initOssClient(uploadAuth, uploadAddress);
            // Upload a video file. Take note that multiple parts are uploaded in parallel. The system starts to upload the next file only when all parts of the current file have been uploaded. The consumed time depends on the file size and upstream bandwidth.
            uploadLocalFile(ossClient, uploadAddress, localFile);
            System.out.println("Put local file succeed, VideoId : " + videoId);
        } catch (Exception e) {
            System.out.println("Put local file fail, ErrorMessage : " + e.getLocalizedMessage());
        }
    }

    private static String decodeBase64(String data) {
        return new String(Base64.decodeBase64(data));
    }
}
                

public static DefaultAcsClient InitVodClient(string accessKeyId, string accessKeySecret)
{
    // Specify the region in which ApsaraVideo VOD is activated. Example: cn-shanghai.
    string regionId = "cn-shanghai";
    IClientProfile profile = DefaultProfile.GetProfile(regionId, accessKeyId, accessKeySecret);
    return new DefaultAcsClient(profile);
}