Realtime Compute for Apache Flink を使用するには、ワークスペースを有効化する必要があります。各ワークスペースには、独立した計算リソースと開発コンソールがあります。このトピックでは、Flink ワークスペースを有効化する方法と、そのプロセスにおける重要な考慮事項について説明します。
前提条件
Alibaba Cloud アカウントが必要です。まだお持ちでない場合は、まずアカウントを登録してください。
Resource Access Management (RAM) ユーザーまたは RAM ロールを使用してサービスにアクセスする場合、Realtime Compute コンソールに必要な権限が必要です。詳細については、「権限管理」をご参照ください。
重要事項
-
Flink ワークスペースの作成には、VPC、OSS、モニタリング関連サービスなど、他のクラウドサービスが関わります。料金の詳細については、「課金項目」をご参照ください。
-
Realtime Compute for Apache Flink は、ストレージ・コンピューティング分離アーキテクチャを採用していますOSS バケットをバインドする際は、以下の点にご注意ください:
-
OSS をまだ有効化していない場合は、「OSS の有効化」を参照して開始してください。OSS バケットは、Flink ワークスペースと同じリージョンにあり、ストレージクラスとして 標準 を使用する必要があります。
-
バインドされた OSS バケットには、バージョン管理やコンプライアンス保持などのポリシーを適用しないでください。これらのポリシーは、Flink ジョブの正常な実行を妨げる可能性があります。
OSS バケットでバージョン管理が有効になっている場合、過剰な削除マーカーによってリスト操作が遅くなることがあります。バージョン管理を有効にする場合は、ライフサイクルルールを設定して、削除マーカーや不要な過去のバージョンを定期的に消去してください。これにより、ストレージコストが削減され、OSS のパフォーマンスが向上します。削除マーカーの消去方法については、「バージョン管理で最終更新時間に基づくライフサイクルルールを使用してストレージコストを削減する」をご参照ください。
警告OSS バケットでバージョン管理が無効になっており、ライフサイクルルールを設定する場合、Flink 関連のディレクトリ (artifacts、flink-jobs、flink-savepoints、sql-artifacts、plan、flink-sessionclusters を含む) に消去ポリシーを適用しないでください。消去ポリシーを適用すると、重要な Flink ファイルが削除され、ジョブの失敗を引き起こす可能性があります。
-
ワークスペースの有効化時にストレージタイプとして OSS バケットを選択する場合、バインドするバケットがゾーン冗長ストレージを使用していることを確認してください。これにより、Flink ワークスペースのゾーンレベルの高可用性を実現できます。(設定手順については、「バケットのストレージ冗長タイプを変更する」をご参照ください。) そうしないと、ゾーンが利用できなくなった場合にステートデータに正常にアクセスできず、Flink はステートフルジョブの回復を保証できません。
説明ワークスペースにゾーン冗長とシングルゾーンのプロジェクトスペースが混在している場合、バインドされたバケットをゾーン冗長ストレージにアップグレードすると、ストレージコストが増加する可能性があります。コストと信頼性のバランスを取るには、ゾーン冗長ワークロード専用の別のワークスペースを作成し、それをゾーン冗長 OSS バケットにバインドしてください。OSS のストレージ料金の詳細については、「ストレージ料金」をご参照ください。
-
ストレージタイプとして OSS バケットを選択する場合、Security Center で悪意のあるファイルの検出が無効になっていることを確認してください。この機能を有効にすると、OSS のトラフィック制限がトリガーされ、初期化中に Flink ジョブが停止する可能性があります。詳細については、「悪意のあるファイルの検出」をご参照ください。
-
サブスクリプションワークスペースの有効化
-
Realtime Compute 管理コンソールにログインします。
-
Stream Processing Flink の横にある [今すぐ購入] をクリックします。
-
初回購入時に、Flink が必要なクラウドリソースにアクセスするための権限を付与します。
[RAM に移動して権限を付与] をクリックします。クラウドリソースアクセス権限ページで、[権限付与に同意] をクリックします。これにより、自動的に権限が付与され、必要なクラウドサービスへのアクセスが許可されます。
-
購入ページで、構成詳細を入力します。

カテゴリ
構成項目
説明
例
基本構成
課金方法
サブスクリプションを選択します。課金の詳細については、「サブスクリプション」をご参照ください。
サブスクリプション
期間
必要なサブスクリプション期間を選択します。
1 か月
自動更新
[有効化] をチェックしない場合、後で Alibaba Cloud 管理コンソールの で更新ポリシーを変更できます。
-
プロセッサアーキテクチャ
要件に応じて、Intel X86 と YiTian ARM アーキテクチャから選択します。
説明YiTian ARM アーキテクチャは現在、中国 (北京)、中国 (ウランチャブ)、中国 (杭州) のサブスクリプションワークスペースでのみ利用可能です。利用可能性は、コンソールの購入ページに表示される内容に準じます。
Intel X86 アーキテクチャ
リージョン
アップストリームおよびダウンストリームのストレージシステムと同じ リージョン を選択することを推奨します。
北京
ネットワーク構成
デプロイモード
このオプションは、特定のリージョンの Intel X86 ワークスペースで、サブスクリプション課金方法の場合にのみ利用可能です。サポートされている デプロイモード は次のとおりです:
-
シングルゾーン (コスト効率が高い):Flink は選択されたリージョンで最適な計算ゾーンを自動的に割り当て、ゾーン間で在庫をプールし、リソースをシームレスにスケジュールして弾性的な負荷容量を向上させます。
-
クロスゾーン (高可用性):ゾーンレベルの高可用性を実現します。クロスゾーンのプロジェクトスペースをホストしているゾーンで障害が発生した場合、ジョブは同じリージョン内の別の安定したゾーンに自動的に再スケジュールされます。これにより、単一ゾーンの障害によるサービス中断を防ぎ、ジョブの継続性と高可用性を確保します。
重要-
エンドツーエンドの高可用性を実現するには、アップストリームおよびダウンストリームのシステムも高可用性をサポートしている必要があります。
-
サービスの有効化時に デプロイモード で クロスゾーン を選択しなかった場合でも、後で他の方法で同一リージョン内高可用性を有効にできますが、ワークスペースに十分なクロスゾーン CU リソースがあることを確認する必要があります。詳細については、「同一リージョン内高可用性」のメソッド 2 と 3 をご参照ください。
-
-
CU 情報
-
デプロイモードが シングルゾーン の場合:シングルゾーン の計算リソースのみを構成する必要があります。
-
デプロイモードが マルチゾーン の場合、必要に応じて シングルゾーンハイブリッド購入を有効にする オプションの選択を解除できます。
-
選択しない場合:クロスゾーン の計算リソースのみを構成します。
-
選択した場合:シングルゾーン と クロスゾーン の 計算リソースクォータ を個別に設定します。
-
説明各 Realtime Compute 開発コンソールとその必須コンポーネントには、2 CU の管理リソースが必要です。これらは自動的に構成され、手動での操作は不要です。詳細については、「課金項目」をご参照ください。
-
Virtual Private Cloud (VPC)
ターゲットリージョン内の VPC を選択します。有効化後に VPC を変更することはできません。VPC を作成するには、「VPC と vSwitch の作成」をご参照ください。
-
アップストリームまたはダウンストリームのストレージが VPC 内にある場合、Flink ワークスペースも同じ VPC を使用する必要があります。
-
RFC 標準のプライベート CIDR ブロック 192.168.0.0/16、172.16.0.0/12、10.0.0.0/8 およびそのサブネットのみがサポートされています。
flink-test-vpc
仮想スイッチ
デプロイモード が クロスゾーン の場合、異なるゾーンにある 2 つの vSwitch を選択します。
各ワークスペースには 2〜3 個の IP アドレスが必要です。ゾーンごとに少なくとも 1 つの vSwitch を選択してください。Flink ジョブの規模に基づいて CIDR ブロックを計画してください。
説明-
ターゲット VPC 内の既存の vSwitch と Flink がサポートするゾーンのみが表示されます。有効化後、「vSwitch の変更」が可能です。
-
選択したスイッチのゾーンは、ジョブが実行されるゾーンとは無関係です。これらはネットワーク接続のためだけに使用され、ジョブがネットワークリソースにアクセスできるようにします。
-
これらのスイッチ構成を任意に変更または削除しないでください。ネットワーク接続やジョブの実行が中断される可能性があります。
flinktest
ワークスペース構成
ワークスペース名
小文字で始め、小文字、数字、ハイフン (-) のみを使用してください。ハイフンで終わらないでください。長さは 1〜60 文字である必要があります。
重要ワークスペース名は、(他のユーザーが作成したワークスペースを含め) グローバルで一意である必要があります。名前が既に存在する場合、システムは ワークスペース名は既に存在します と表示します。それに応じて名前を変更してください。有効化が成功した後、ワークスペース名を変更することはできません。
flinktestnamespace
ストレージ構成
OSS ストレージ
OSS バケットには、ジョブのチェックポイント、スナップショット、ログ、JAR パッケージ、その他のデータが保存されます。ディレクトリの詳細については、「ファイル管理」をご参照ください。
重要-
OSS バケットをバインドする際は、「重要事項」をご確認ください。
-
デプロイモード が クロスゾーン の場合、システムは OSS 構成を検証し、ゾーン冗長ストレージを持つバケットのみを表示します。
-
Flink ワークスペースの作成後に OSS バケットを変更することはできません。
flink-test-oss
タグキーとタグ値
タグはタグキーとタグ値で構成され、クラウドリソースの識別子として機能します。これにより、共通の特性を持つリソースをさまざまなディメンションで分類、検索、集約でき、リソース管理が簡素化されます。タグ管理でタグを一元管理します。
-
モニタリングサービス
モニタリングサービス
無料モニタリングサービス または 従量課金 Prometheus モニタリングサービス を選択します (機能の違いについては、「Cloud Monitor と ARMS アラート機能の比較」をご参照ください):
-
無料モニタリングサービス:Flink ワークスペースを作成後、Cloud Monitor が基本的なモニタリングとアラート機能を提供します。詳細については、「無料使用量」をご参照ください。
-
Prometheus モニタリングサービス:Flink ワークスペースを作成後、ARMS が自動的に有効化され、商用グレードの Prometheus モニタリングとアラート機能を提供します。課金の詳細については、「Prometheus の課金」をご参照ください。
無料モニタリングサービス
-
-
[利用規約] を選択し、[今すぐ購入] をクリックして支払いを完了し、サービスを有効化します。
支払い後、[管理コンソール] をクリックして作成中のワークスペースを表示します。ワークスペースの作成は、通常、支払い後 5〜10 分で完了します。
従量課金ワークスペースの有効化
一度に 1,000 CU を超えて有効化するには、を送信してください。
-
Realtime Compute 管理コンソールにログインします。
-
Stream Processing Flink の横にある [今すぐ購入] をクリックします。
-
(オプション) 初回購入時に、Flink が必要なクラウドリソースにアクセスするための権限を付与します。
[RAM に移動して権限を付与] をクリックします。クラウドリソースアクセス権限ページで、[権限付与に同意] をクリックします。これにより、自動的に権限が付与され、必要なクラウドサービスへのアクセスが許可されます。
説明これが初回購入でない場合は、このステップをスキップしてください。
-
購入ページで、構成詳細を入力します。
ワークスペース名 (作成後に変更不可。各ワークスペースには独立した計算リソースと開発コンソールがあります)、クォータ制限 (例:1,000 CU)、ストレージタイプ (ジョブのチェックポイント、ログ、JAR パッケージ、その他のデータを保存するための OSS バケット または 完全管理ストレージ) を構成します。

カテゴリ
構成項目
説明
例
基本構成
課金方法
従量課金を選択します。課金の詳細については、「従量課金」をご参照ください。
従量課金
リージョン
アップストリームおよびダウンストリームのストレージシステムと同じ リージョン を選択することを推奨します。
北京
ネットワーク構成
Virtual Private Cloud (VPC)
ターゲットリージョン内の VPC を選択します。有効化後に VPC を変更することはできません。VPC を作成するには、「VPC と vSwitch の作成」をご参照ください。
-
アップストリームまたはダウンストリームのストレージが VPC 内にある場合、Flink ワークスペースも同じ VPC を使用する必要があります。
-
RFC 標準のプライベート CIDR ブロック 192.168.0.0/16、172.16.0.0/12、10.0.0.0/8 およびそのサブネットのみがサポートされています。
flink-test-vpc
仮想スイッチ
デプロイモード が クロスゾーン の場合、異なるゾーンにある 2 つの vSwitch を選択します。
各ワークスペースには 2〜3 個の IP アドレスが必要です。ゾーンごとに少なくとも 1 つの vSwitch を選択してください。Flink ジョブの規模に基づいて CIDR ブロックを計画してください。
説明-
ターゲット VPC 内の既存の vSwitch と Flink がサポートするゾーンのみが表示されます。有効化後、「vSwitch の変更」が可能です。
-
選択したスイッチのゾーンは、ジョブが実行されるゾーンとは無関係です。これらはネットワーク接続のためだけに使用され、ジョブがネットワークリソースにアクセスできるようにします。
-
これらのスイッチ構成を任意に変更または削除しないでください。ネットワーク接続やジョブの実行が中断される可能性があります。
flinktest
ワークスペース構成
ワークスペース名
小文字で始め、小文字、数字、ハイフン (-) のみを使用してください。ハイフンで終わらないでください。長さは 1〜60 文字である必要があります。
重要ワークスペース名は、(他のユーザーが作成したワークスペースを含め) グローバルで一意である必要があります。名前が既に存在する場合、システムは ワークスペース名は既に存在します と表示します。それに応じて名前を変更してください。有効化が成功した後、ワークスペース名を変更することはできません。
flinktestnamespace
コンピューティングリソースのクォータ制限
デフォルトのクォータは 1,000 CU です。最大 9,999,999 まで変更できます。
説明各 Realtime Compute 開発コンソールとその必須コンポーネントには、2 CU の管理リソースが必要です。これらは自動的に構成され、手動での操作は不要です。詳細については、「課金項目」をご参照ください。
100
ストレージ構成
OSS ストレージ
OSS バケットには、ジョブのチェックポイント、スナップショット、ログ、JAR パッケージ、その他のデータが保存されます。ディレクトリの詳細については、「ファイル管理」をご参照ください。
重要-
OSS バケットをバインドする際は、「重要事項」をご確認ください。
-
デプロイモード が クロスゾーン の場合、システムは OSS 構成を検証し、ゾーン冗長ストレージを持つバケットのみを表示します。
-
Flink ワークスペースの作成後に OSS バケットを変更することはできません。
flink-test-oss
タグキーとタグ値
タグはタグキーとタグ値で構成され、クラウドリソースの識別子として機能します。これにより、共通の特性を持つリソースをさまざまなディメンションで分類、検索、集約でき、リソース管理が簡素化されます。タグ管理でタグを一元管理します。
-
モニタリングサービス
モニタリングサービス
無料モニタリングサービス または 従量課金 Prometheus モニタリングサービス を選択します (機能の違いについては、「Cloud Monitor と ARMS アラート機能の比較」をご参照ください):
-
無料モニタリングサービス:Flink ワークスペースを作成後、Cloud Monitor が基本的なモニタリングとアラート機能を提供します。詳細については、「無料使用量」をご参照ください。
-
Prometheus モニタリングサービス:Flink ワークスペースを作成後、ARMS が自動的に有効化され、商用グレードの Prometheus モニタリングとアラート機能を提供します。課金の詳細については、「Prometheus の課金」をご参照ください。
無料モニタリングサービス
-
-
[利用規約] を選択し、[今すぐ購入] をクリックして支払いを完了し、サービスを有効化します。
支払い後、[管理コンソール] をクリックして作成中のワークスペースを表示します。ワークスペースの作成は、通常、支払い後 5〜10 分で完了します。
次のステップ
Flink ワークスペースを有効化した後、必要に応じて以下のタスクを実行します。
|
機能 |
アクセスパス |
|
ワークスペース詳細の表示 |
Realtime Compute 管理コンソールで、対象のワークスペースの [その他] > [ワークスペース詳細] をクリックして、ワークスペース名、ワークスペース ID、OSS バケット、VPC 名と ID、vSwitchを表示します。 |
|
弾性計算リソースの有効化と使用 |
サブスクリプションプランに加えて、弾性計算リソースを構成できます。このハイブリッド課金モデルは、従量課金の柔軟性とサブスクリプションプランのコスト効率を組み合わせたものです。詳細については、「ハイブリッド課金」をご参照ください。 |
|
Realtime Compute for Apache Flink の基本概念の階層を理解し、ジョブ開発、デプロイメント、運用保守、セキュリティ管理の指針とします。 |
|
|
RAM ユーザーと RAM ロールが Flink コンソールにアクセスするには、RAM 権限 (例:ワークスペースの表示と購入) とプロジェクトスペース権限 (例:ジョブ開発と運用保守) が必要です。 |
|
|
プロジェクトスペースは、Flink ジョブを管理するための基本単位です。すべての構成、ジョブ、権限は単一のプロジェクトスペース内に存在します。ワークスペース作成後、デフォルトのプロジェクトスペース (接尾辞 "default" が付く) が生成されます。 |
|
|
対象のワークスペースの [操作] 列にある [コンソール] をクリックして、Realtime Compute 開発コンソールに入ります。ここでジョブ開発と運用保守タスクを実行します。 このサービスには、さまざまなアップストリームおよびダウンストリームシステム用の組み込みコネクタが含まれています。詳細については、「サポートされているコネクタ」をご参照ください。 |
|
|
ワークスペースとプロジェクトスペースのリソースを調整します。 |
|
|
従量課金とサブスクリプションの課金方法を切り替えます。 |
|
|
IP アドレス不足によるジョブ起動の失敗を解決するために vSwitch を変更します。 |
|
|
リソースのリリース |
対象のワークスペースの [その他] > [リソースのリリース] をクリックします。リリース後、Flink ワークスペースは課金されなくなり、関連する ARMS リソースも同時にリリースされます。 |