Wan - 開始フレームと終了フレームからの動画生成 API リファレンス (2.2)

import os
import dashscope
from dashscope.v2 import DashScopeError

# 以下はシンガポールリージョンの設定です。リージョンによって region の値は異なります。呼び出し時は、{WorkspaceId} をお使いのワークスペース ID に置き換えてください。
client = dashscope.Client(
    # 環境変数が設定されていない場合は、api_key = "sk-xxx" に置き換えてください
    # API キーはリージョンによって異なります。API キーの取得：https://www.alibabacloud.com/help/model-studio/get-api-key
    api_key=os.getenv("DASHSCOPE_API_KEY"),
    workspace="{WorkspaceId}",
    region="ap-southeast-1",
)

"""
Requirements:
    dashscope python SDK >= 2.0.1
Install/Upgrade the SDK:
    pip install -U dashscope
"""

# ========== 画像入力方法 (いずれかを選択) ==========
# [方法 1] パブリック画像 URL を使用
first_frame_url = "https://wanx.alicdn.com/material/20250318/first_frame.png"
last_frame_url = "https://wanx.alicdn.com/material/20250318/last_frame.png"

# [方法 2] ローカルファイルパスを使用 (file:// + ファイルパス)
# 絶対パスを使用：
# first_frame_url = "file://" + "/path/to/your/first_frame.png"  # Linux/macOS
# last_frame_url = "file://" + "C:/path/to/your/last_frame.png"  # Windows
# または相対パスを使用：
# first_frame_url = "file://" + "./first_frame.png"              # 実際のパスを使用してください。
# last_frame_url = "file://" + "./last_frame.png"                # 実際のパスを使用してください。

def sample_async_call_kf2v():
    # 非同期呼び出しは task_id を返します
    # first_frame_url / last_frame_url は input セクションのフィールドで、名前付きシグネチャに含まれないため、extra_input 経由で渡します
    try:
        job = client.videos.jobs.create(model="wan2.2-kf2v-flash",
                                        prompt="リアルなスタイル、小さな黒猫が好奇心旺盛に空を見上げ、カメラが目線の高さから徐々に上昇し、最終的にトップダウンの視点からその好奇心に満ちた視線を捉える。",
                                        extra_input={'first_frame_url': first_frame_url,
                                                     'last_frame_url': last_frame_url},
                                        resolution="720P",
                                        prompt_extend=True)
        print(job)
        print("task_id: %s" % job.task_id)
    except DashScopeError as e:
        print(f"HTTP status code: {e.status_code}")
        print(f"Error code: {e.code}")
        print(f"Error message: {e.message}")
        print("See the documentation: https://www.alibabacloud.com/help/ja/model-studio/developer-reference/error-code")
        return

    # 非同期タスクのステータスを取得します
    try:
        snapshot = client.videos.jobs.fetch(job.task_id)
        print(snapshot.status)  # タスクのステータスを確認
    except DashScopeError as e:
        print(f"HTTP status code: {e.status_code}")
        print(f"Error code: {e.code}")
        print(f"Error message: {e.message}")
        print("See the documentation: https://www.alibabacloud.com/help/ja/model-studio/developer-reference/error-code")

    # 非同期タスクの完了を待ちます（指数バックオフによるポーリング、デフォルトの合計待機時間は 24 時間）
    try:
        done = client.videos.jobs.wait(job)
        print(done)
        print(done.video_url)
    except DashScopeError as e:
        print(f"HTTP status code: {e.status_code}")
        print(f"Error code: {e.code}")
        print(f"Error message: {e.message}")
        print("See the documentation: https://www.alibabacloud.com/help/ja/model-studio/developer-reference/error-code")

if __name__ == '__main__':
    sample_async_call_kf2v()

// Copyright (c) Alibaba, Inc. and its affiliates.

// DashScope SDK >= 2.20.1
import com.alibaba.dashscope.aigc.videosynthesis.VideoSynthesis;
import com.alibaba.dashscope.aigc.videosynthesis.VideoSynthesisParam;
import com.alibaba.dashscope.aigc.videosynthesis.VideoSynthesisResult;
import com.alibaba.dashscope.exception.ApiException;
import com.alibaba.dashscope.exception.InputRequiredException;
import com.alibaba.dashscope.exception.NoApiKeyException;
import com.alibaba.dashscope.utils.Constants;
import com.alibaba.dashscope.utils.JsonUtils;
import java.util.HashMap;
import java.util.Map;

public class Kf2vAsync {

    static {
        Constants.baseHttpApiUrl = "https://{WorkspaceId}.ap-southeast-1.maas.aliyuncs.com/api/v1";
    }

    // 環境変数から DashScope API キー (Model Studio API キー) を取得します。
    static String apiKey = System.getenv("DASHSCOPE_API_KEY");

    /**
     * 画像入力方法 (いずれかを選択)：
     *
     * [方法 1] パブリック URL
     */
    static String firstFrameUrl = "https://wanx.alicdn.com/material/20250318/first_frame.png";
    static String lastFrameUrl = "https://wanx.alicdn.com/material/20250318/last_frame.png";

    /**
     * [方法 2] ローカルファイルパス (file://+絶対パス または file:///+絶対パス)
     */
    // static String firstFrameUrl = "file://" + "/your/path/to/first_frame.png";   // Linux/macOS
    // static String lastFrameUrl = "file:///" + "C:/path/to/your/img.png";        // Windows

    public static void asyncCall(){

        // パラメーターを設定します。
        Map<String, Object> parameters = new HashMap<>();
        parameters.put("prompt_extend", true);
        parameters.put("resolution", "720P");

        VideoSynthesis videoSynthesis = new VideoSynthesis();
        VideoSynthesisParam param =
                VideoSynthesisParam.builder()
                        .apiKey(apiKey)
                        .model("wan2.2-kf2v-flash")
                        .prompt("リアルなスタイル、小さな黒猫が好奇心旺盛に空を見上げ、カメラが目線の高さから徐々に上昇し、最終的にトップダウンの視点からその好奇心に満ちた視線を捉える。")
                        .firstFrameUrl(firstFrameUrl)
                        .lastFrameUrl(lastFrameUrl)
                        .parameters(parameters)
                        .build();
        VideoSynthesisResult result = null;
        try {
            // 非同期呼び出しを行います。
            result = videoSynthesis.asyncCall(param);
        } catch (ApiException | NoApiKeyException e){
            throw new RuntimeException(e.getMessage());
        } catch (InputRequiredException e) {
            throw new RuntimeException(e);
        }
        System.out.println(JsonUtils.toJson(result));

        String taskId = result.getOutput().getTaskId();

        System.out.println("taskId=" + taskId);

        try {
            result = videoSynthesis.wait(taskId, apiKey);
        } catch (ApiException | NoApiKeyException e){
            throw new RuntimeException(e.getMessage());
        }
        System.out.println(JsonUtils.toJson(result));
        System.out.println(JsonUtils.toJson(result.getOutput()));
    }

    public static void main(String[] args){
        asyncCall();
    }
}