Flink AI サービス (ビルトインモデル) - Realtime Compute for Apache Flink

このトピックでは、Real-Time Compute for Apache Flink の Flink AI 機能（ビルトインモデル）の特徴、使用方法、および制限事項について説明します。

重要

この機能は現在、ホワイトリストによるパブリックプレビューの段階です。ご利用になるには、申請して承認を受ける必要があります。別途の有効化操作は不要です。パブリックプレビュー期間中は、モデル呼び出しに料金はかかりません。このトピックで説明する課金方法およびサービスモデルは、商用リリース後に適用されます。正式なリリース日については、プロダクトアナウンスをご確認ください。

概要

Flink AI 機能（ビルトインモデル）は、Real-Time Compute for Apache Flink で AI モデルを呼び出すためのマネージドサービスを提供します。Flink SQL ジョブおよび Flink Agent 内で API-Key を構成せずにビルトインモデルを呼び出すことができ、ストリーミング型の AI 推論および埋め込み処理が可能です。

主なメリット

特徴	説明
すぐに利用可能	API-Key、エンドポイント、PrivateLink の構成が不要です。
トークン単位での課金	トークン使用量に基づいて課金されるため、コストが明確でコントロールしやすいです。
マルチモデル対応	テキスト生成、視覚理解、翻訳、埋め込みなど、人気のある大規模モデルをサポートしています。
グローバルリージョン対応	中国本土内外の複数リージョンで利用可能で、自動的なクロスリージョンアクセスを実現します。

仕組み

ビルトインモデルとカスタムモデル (BYOK) の比較

ディメンション	項目	ビルトインモデル (推奨)	カスタムモデル (非推奨)
アクセス構成	エンドポイント	不要です。システムが自動的に構成します。	必須です。
	api-key	不要です。システムが管理します。	ユーザーが提供・維持する必要があります。
	サポートモデル	ビルトインモデルリストに含まれるモデルのみ。	OpenAI/DashScope プロトコルと互換性のある任意のモデル。
	前提条件	プライマリアカウントが対象リージョンで Flink AI 機能を有効にする必要があります。	モデルサービスを有効化し、API-Key を取得する必要があります。
ネットワークとセキュリティ	アクセスパス	Alibaba Cloud 内部ネットワーク経由で直接アクセスします。トラフィックは VPC 外に出ません。	パブリックインターネットアクセスが必要です。
	データセキュリティ	高セキュリティ。トラフィックは Alibaba Cloud 内部ネットワーク上でエンドツーエンドで転送されます。	パブリックインターネット経由でデータが転送されます。リスク評価はユーザーの責任となります。
	ネットワーク構成コスト	ゼロ構成。	パブリックインターネットアクセスには NAT Gateway、EIP、またはパブリック IP アドレスが必要です。
パフォーマンス	呼び出し遅延	低遅延。内部接続により、追加のネットワークホップを回避します。	パブリックネットワークの変動により、遅延が大きくなり安定性も低下します。
パフォーマンス	可用性	SLA に基づき、安定したネットワークと低遅延を実現します。	モデルサービスプロバイダーの SLA およびネットワークリンクの安定性に依存します。
課金	モデル呼び出し料金	トークン単位で課金されます。	モデルサービスプロバイダーから直接請求されます。
	ネットワーク料金	追加料金は発生しません。	NAT Gateway、EIP、およびパブリックネットワークトラフィックの料金を支払う必要があります。
	請求統合	Flink の請求書に統合されます。	モデル料金とネットワーク料金は別々に請求されます。
機能範囲	トークン制限	入力は最大 8K、出力は最大 2K です。	モデルサービスプロバイダーによって異なります。

サービスの有効化と無効化

重要

この機能は現在、ホワイトリストによるパブリックプレビューの段階です。ご利用になるには、申請して承認を受ける必要があります。別途の有効化操作は不要です。

前提条件

プライマリアカウントがこの機能を有効にする必要があります。
リージョンで有効化されると、そのリージョン内のすべてのワークスペースで利用可能になります。
この機能は従量課金です。機能の有効化自体には料金はかかりません。課金はモデル呼び出しに対してのみ発生します。詳細については、「モデル構成」をご参照ください。

Real-Time Compute for Apache Flink コンソールにログインします。Flink AI サービスページで、[今すぐ有効化] をクリックします。

サービスの無効化

Flink AI サービスページで [サービスを無効化] をクリックし、以下の点を確認してください。

機能を無効化すると、そのリージョン内のすべてのジョブでビルトインモデルサービスを利用できなくなります。
機能を無効化する前に、ビルトインモデルに依存するジョブがないことを確認してください。

サポートリージョン

Flink AI サービスリージョン	リージョン ID	エンドポイントリージョン	推論実行リージョン
中国 (北京)	cn-beijing	中国 (北京)	中国本土 (動的スケジューリング)
中国 (張家口)	cn-zhangjiakou
中国 (ウランチャブ)	cn-wulanchabu
中国 (上海)	cn-shanghai
中国 (杭州)	cn-hangzhou
中国 (深セン)	cn-shenzhen
中国 (成都)	cn-chengdu
シンガポール	ap-southeast-1	シンガポール	中国本土以外のリージョン (動的スケジューリング)
中国 (香港)	cn-hongkong
マレーシア (クアラルンプール)	ap-southeast-3
インドネシア (ジャカルタ)	ap-southeast-5
日本 (東京)	ap-northeast-1
イギリス (ロンドン)	eu-west-1
ドイツ (フランクフルト)	eu-central-1
UAE (ドバイ)	me-east-1
メキシコ	na-south-1

説明

選択したリージョンがデータアクセスおよび推論の物理的な場所を決定するため、データコンプライアンス要件に基づいてリージョンを選択してください。

エンドポイントリージョン：アクセスポイントおよびデータストレージの場所を決定します。
推論実行リージョン：推論が実行される場所です。定義された範囲内で動的にスケジューリングされます。

ビルトインモデル

推論モデル (chat/completions)

モデル名	ユースケース	入力	出力	サポートリージョン
qwen3.6-plus	視覚理解およびテキスト生成向け。最新のフラッグシップ Qwen モデルです。	テキスト/イメージ/ビデオ	テキスト	すべて
qwen3.6-flash	視覚理解およびテキスト生成向け。コスト効率に優れたモデルです。	テキスト/イメージ/ビデオ	テキスト	すべて
qwen3.5-plus	視覚理解およびテキスト生成向け。高性能モデルです。	テキスト/イメージ/ビデオ	テキスト	すべて
qwen3.5-flash	視覚理解およびテキスト生成向け。高速かつ低コストのモデルです。	テキスト/イメージ/ビデオ	テキスト	すべて

埋め込みモデル (embeddings)

モデル名	ユースケース	入力	出力	サポートリージョン
text-embedding-v4	テキスト埋め込み向け	テキスト	ベクトル	すべて
qwen3-vl-embedding	マルチモーダル埋め込み向け	イメージ/テキスト/ビデオ	ベクトル	中国本土

使用方法

基本構文

ビルトインモデルを使用するには、task パラメーターおよび model パラメーターを CREATE MODEL 文で指定します。endpoint パラメーターおよび api-key パラメーターは指定しないでください。

CREATE MODEL model_name
INPUT (column_name STRING)
OUTPUT (column_name {STRING | ARRAY<FLOAT>})
WITH (
  'provider' = 'openai-compact',
  'task' = 'chat/completions | embeddings',
  'model' = '<model-name>'
);

詳細については、「モデル構成」をご参照ください。

カスタムモデルとの関係

シナリオ	エンドポイント	api-key	動作
ビルトインモデルを使用	未指定	未指定	Flink が管理するモデルサービスを自動的に使用します。
カスタムモデルを使用	指定済み	指定済み	カスタムモデルサービス (BYOK モード) を使用します。

ビルトインモデルを使用するには、プライマリアカウントが事前に Flink AI 機能を有効にしておく必要があります。有効化されていない場合、endpoint パラメーターおよび api-key パラメーターを省略したジョブは失敗します。

制限事項

項目	制限	説明
最大入力トークン数	8K	システムのデフォルト制限です。`max-context-size` を指定した場合、小さい方の値が適用されます。
最大出力トークン数	2K	システムのデフォルト制限です。`max-tokens` を指定した場合、小さい方の値が適用されます。
モデル範囲	ビルトインモデルリスト	リストに含まれるモデルのみサポートされます。他のモデルを指定するとエラーになります。

ユースケース

シナリオ	推奨モデル	説明
リアルタイムテキスト分類およびタグ付け	qwen3.5-flash / qwen3.6-flash	ストリーミングデータに対してリアルタイムで感情分析および分類タグ付けを実行します。
リアルタイム情報抽出	qwen3.5-plus / qwen3.6-plus	非構造化テキストから構造化情報を抽出します。
リアルタイム埋め込み	text-embedding-v4	ストリーミングデータから類似検索用の埋め込みを生成します。
マルチモーダル埋め込み	qwen3-vl-embedding	イメージ、テキスト、ビデオに対して統一された埋め込みを生成します。