MPS Java SDK を使用して動画をトランスコードする - ApsaraVideo Media Processing

トランスコーディングとは、オーディオファイルまたはビデオファイルを 1 つ以上のオーディオファイルまたはビデオファイルに変換して、さまざまなネットワーク帯域幅、端末デバイス、およびユーザーニーズに適応させることです。ApsaraVideo Media Processing（MPS）[コンソール] で作成されたトランスコーディングジョブとワークフローがビジネス要件を満たせない場合は、SubmitJobs オペレーションを呼び出してトランスコーディングジョブを送信できます。このトピックでは、MPS Java SDK V2.0 を使用して、トランスコーディングジョブの送信、トランスコーディングジョブのキャンセル、トランスコーディングジョブのクエリ、およびすべてのトランスコーディングジョブの走査を行う方法の例を示します。

前提条件

SDK クライアントが作成されます。詳細については、「クライアントの初期化」をご参照ください。

トランスコーディングジョブの送信

SubmitJobs を呼び出して、トランスコーディングジョブを送信できます。

説明

SDK を使用してトランスコーディングジョブを送信する場合、オブジェクトに対して URL エンコーディングを実行する必要があります。そうしないと、トランスコーディングジョブは失敗します。詳細については、「URL エンコーディング」をご参照ください。
命名規則に準拠したオブジェクト名を指定する必要があります。そうしないと、オブジェクトが見つからず、トランスコーディングジョブは失敗します。詳細については、「パラメータの詳細」をご参照ください。
送信するトランスコーディングジョブの ID を記録することをお勧めします。これにより、後続のクエリと走査操作が容易になります。

package com.aliyun.sample;

import com.aliyun.tea.*;

public class Sample {

    /**
     * <b>説明</b> :
     * <p>AccessKey ペアを使用してクライアントを初期化します。</p>
     * @return Client
     * 
     * @throws Exception
     */
    public static com.aliyun.mts20140618.Client createClient() throws Exception {

        com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が構成されていることを確認します。
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が構成されていることを確認します。
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
        config.endpoint = "mts.cn-hangzhou.aliyuncs.com"; // エンドポイントのリージョンは、入力の Location の値と同じである必要があります。
        return new com.aliyun.mts20140618.Client(config);
    }

    public static void main(String[] args_) throws Exception {
        java.util.List<String> args = java.util.Arrays.asList(args_);
        com.aliyun.mts20140618.Client client = Sample.createClient();
        com.aliyun.mts20140618.models.SubmitJobsRequest submitJobsRequest = new com.aliyun.mts20140618.models.SubmitJobsRequest()
                // ジョブ入力。
                .setInput("{\"Bucket\":\"exampleBucket\",\"Location\":\"oss-cn-hangzhou\",\"Object\":\"example.flv\",\"Referer\": \"ホットリンク保護機能を有効にするために Object Storage Service (OSS) コンソールで設定したパラメータ\"}")
                // ジョブ出力構成。
                .setOutputs("[{\"OutputObject\":\"exampleOutput.mp4\",\"TemplateId\":\"6181666213ab41b9bc21da8ff5ff****\",\"WaterMarks\":[{\"InputFile\":{\"Bucket\":\"exampleBucket\",\"Location\":\"oss-cn-hangzhou\",\"Object\":\"image_01.png\"},\"WaterMarkTemplateId\":\"9b772ce2740d4d55876d8b542d47****\"}],\"UserData\":\"testid-001\"}]")
                // 出力ファイルが格納される OSS バケット。
                .setOutputBucket("exampleBucket")
                // OSS バケットが存在するリージョン。
                .setOutputLocation("oss-cn-hangzhou")
                // パイプラインの ID。
                .setPipelineId("dd3dae411e704030b921e52698e5****");
        com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
        try {
            // 必要に応じて、API オペレーションのレスポンスを表示するための独自のコードを記述します。
            client.submitJobsWithOptions(submitJobsRequest, runtime);
        } catch (TeaException error) {
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、例外は参照用にのみ提供されています。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // トラブルシューティング用の URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        } catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、例外は参照用にのみ提供されています。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // トラブルシューティング用の URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        }        
    }
}

トランスコーディングジョブのクエリ

QueryJobList オペレーションを呼び出して、トランスコーディングジョブに関する情報をクエリできます。

package com.aliyun.sample;

import com.aliyun.tea.*;

public class Sample {

    /**
     * <b>説明</b> :
     * <p>AccessKey ID と AccessKey シークレットを使用してクライアントを初期化します。</p>
     * @return Client
     * 
     * @throws Exception
     */
    public static com.aliyun.mts20140618.Client createClient() throws Exception {

        com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が構成されていることを確認します。
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が構成されていることを確認します。
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
        config.endpoint = "mts.cn-qingdao.aliyuncs.com";
        return new com.aliyun.mts20140618.Client(config);
    }

    public static void main(String[] args_) throws Exception {
        java.util.List<String> args = java.util.Arrays.asList(args_);
        com.aliyun.mts20140618.Client client = Sample.createClient();
        com.aliyun.mts20140618.models.QueryJobListRequest queryJobListRequest = new com.aliyun.mts20140618.models.QueryJobListRequest()
                // トランスコーディングジョブの ID。
                .setJobIds("bb558c1cc25b45309aab5be44d19****,d1ce4d3efcb549419193f50f1fcd****");
        com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
        try {
            // 必要に応じて、API オペレーションのレスポンスを表示するための独自のコードを記述します。
            client.queryJobListWithOptions(queryJobListRequest, runtime);
        } catch (TeaException error) {
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ表示されます。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // 対応するエラー診断ページの URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        } catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ表示されます。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // 対応するエラー診断ページの URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        }        
    }
}

トランスコーディングジョブのキャンセル

CancelJob オペレーションを呼び出して、トランスコーディングジョブをキャンセルできます。

package com.aliyun.sample;

import com.aliyun.tea.*;

public class Sample {

    /**
     * <b>説明</b> :
     * <p>AccessKey ID と AccessKey シークレットを使用してクライアントを初期化します。</p>
     * @return Client
     * 
     * @throws Exception
     */
    public static com.aliyun.mts20140618.Client createClient() throws Exception {

        com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が構成されていることを確認します。
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が構成されていることを確認します。
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
        config.endpoint = "mts.cn-qingdao.aliyuncs.com";
        return new com.aliyun.mts20140618.Client(config);
    }

    public static void main(String[] args_) throws Exception {
        java.util.List<String> args = java.util.Arrays.asList(args_);
        com.aliyun.mts20140618.Client client = Sample.createClient();
        com.aliyun.mts20140618.models.CancelJobRequest cancelJobRequest = new com.aliyun.mts20140618.models.CancelJobRequest()
                // キャンセルするトランスコーディングジョブの ID。
                .setJobId("d1ce4d3efcb549419193f50f1fcd****");
        com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
        try {
            // 必要に応じて、API オペレーションのレスポンスを表示するための独自のコードを記述します。
            client.cancelJobWithOptions(cancelJobRequest, runtime);
        } catch (TeaException error) {
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ表示されます。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // 対応するエラー診断ページの URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        } catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ表示されます。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // 対応するエラー診断ページの URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        }        
    }
}

すべてのトランスコーディングジョブの走査

ListJob オペレーションを呼び出して、すべてのトランスコーディングジョブを走査できます。

package com.aliyun.sample;

import com.aliyun.tea.*;

public class Sample {

    /**
     * <b>説明</b> :
     * <p>AccessKey ID と AccessKey シークレットを使用してクライアントを初期化します。</p>
     * @return Client
     * 
     * @throws Exception
     */
    public static com.aliyun.mts20140618.Client createClient() throws Exception {

        com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が構成されていることを確認します。
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // 必須。 ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が構成されていることを確認します。
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
        config.endpoint = "mts.cn-qingdao.aliyuncs.com";
        return new com.aliyun.mts20140618.Client(config);
    }

    public static void main(String[] args_) throws Exception {
        java.util.List<String> args = java.util.Arrays.asList(args_);
        com.aliyun.mts20140618.Client client = Sample.createClient();
        com.aliyun.mts20140618.models.ListJobRequest listJobRequest = new com.aliyun.mts20140618.models.ListJobRequest()
                // トランスコーディングジョブの状態。
                .setState("All")
                // 走査するトランスコーディングジョブが作成された時間範囲の開始。
                .setStartOfJobCreatedTimeRange("2014-01-10T12:00:00Z")
                // 走査するトランスコーディングジョブが作成された時間範囲の終了。
                .setEndOfJobCreatedTimeRange("2014-01-11T12:00:00Z")
                // MPS キューの ID。
                .setPipelineId("88c6ca184c0e424d5w5b665e2a12****")
                // 新しい結果ページを取得するために次のリクエストで使用されるページネーショントークン。
                .setNextPageToken("16f01ad6175e4230ac42bb5182cd****")
                // 各ページで返すメディアワークフロー実行インスタンスの最大数。
                .setMaximumPageSize(10L);
        com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
        try {
            // 必要に応じて、API オペレーションのレスポンスを表示するための独自のコードを記述します。
            client.listJobWithOptions(listJobRequest, runtime);
        } catch (TeaException error) {
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ表示されます。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // 対応するエラー診断ページの URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        } catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
            // 実際のビジネスシナリオでは、例外を慎重に処理し、プロジェクトで例外を無視しないでください。この例では、エラーメッセージは参照用にのみ表示されます。
            // エラーメッセージ。
            System.out.println(error.getMessage());
            // 対応するエラー診断ページの URL。
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        }        
    }
}

ApsaraVideo Media Processing:トランスコーディングジョブの管理

前提条件

トランスコーディングジョブの送信

トランスコーディングジョブのクエリ

トランスコーディングジョブのキャンセル

すべてのトランスコーディングジョブの走査

関連情報