DataWorks で Flink タスクを開発および管理するには、まず、Realtime Compute for Apache Flink クラスターをフルマネージド Flink 計算リソースとしてアタッチする必要があります。クラスターがアタッチされると、DataWorks ワークスペースでデータ開発に使用できます。
前提条件
Realtime Compute for Apache Flink クラスターを有効化していること。
説明フルマネージド Flink 計算リソースを作成する DataWorks ワークスペースと同じ [リージョン] で Flink クラスターを購入することをお勧めします。リージョンが一致しない場合、クラスターを計算リソースとしてワークスペースにアタッチすることはできません。
DataWorks ワークスペースを作成していること。この操作を実行する Resource Access Management (RAM) ユーザーがワークスペースに追加され、ワークスペース管理者ロールが割り当てられていること。
重要この機能は、[Data Studio (新バージョン) を使用] に設定されているワークスペースでのみサポートされます。
Serverless リソースグループを作成し、ターゲットワークスペースにアタッチしていること。
制限事項
利用可能なリージョン: この機能は、次のリージョンでのみ利用可能です: 中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深圳)、中国 (成都)、中国 (香港)、日本 (東京)、シンガポール、マレーシア (クアラルンプール)、インドネシア (ジャカルタ)、ドイツ (フランクフルト)、イギリス (ロンドン)、米国 (シリコンバレー)、および米国 (バージニア)。
権限:
オペレーター
必要な権限
Alibaba Cloud アカウント
追加の権限は必要ありません。
Resource Access Management (RAM) ユーザー/RAM ロール
DataWorks 管理権限: O&M または Workspace Administrator ロールを持つワークスペースメンバー、または
AliyunDataWorksFullAccess権限を持つメンバーのみが計算リソースを作成できます。権限付与の詳細については、「ユーザーにワークスペース管理者の権限を付与する」をご参照ください。Flink サービス権限:
AliyunStreamFullAccessアクセスポリシー。そうでない場合、フルマネージド Flink 計算リソースを構成できません。Realtime Compute for Apache Flink クラスター内のプロジェクトに対する管理権限。詳細については、「プロジェクトの権限付与」をご参照ください。
計算リソースリストページに移動
DataWorks コンソールにログインします。ターゲットリージョンに切り替えます。左側のナビゲーションウィンドウで、 を選択します。ドロップダウンリストからワークスペースを選択し、[管理センターへ移動] をクリックします。
左側のナビゲーションウィンドウで、[計算リソース] をクリックします。
フルマネージド Flink 計算リソースのアタッチ
計算リソースページで、フルマネージド Flink 計算リソースを構成してアタッチできます。
アタッチする計算リソースのタイプを選択します。
[計算リソースのアタッチ] をクリックして、[計算リソースのアタッチ] ページに移動します。
[計算リソースのアタッチ] ページで、計算リソースタイプを [フルマネージド Flink] に設定すると、[フルマネージド Flink 計算リソースのアタッチ] 構成ページが開きます。
フルマネージド Flink 計算リソースを構成します。
[フルマネージド Flink 計算リソースのアタッチ] ページで、次の表の説明に従ってパラメーターを構成します。
パラメーター
説明
Flink ワークスペース
有効化された Realtime Compute for Apache Flink クラスターを選択します。ドロップダウンメニューで [作成] をクリックして新しいクラスターを作成することもできます。詳細については、「Realtime Compute for Apache Flink クラスターを有効化する」をご参照ください。
説明ワークスペースを作成したときに本番環境と開発環境を分離することを選択した場合、本番環境と開発環境の両方に Flink ワークスペースを選択する必要があります。
Flink プロジェクト
Realtime Compute for Apache Flink クラスターを有効化したときに生成されたデフォルトの Flink プロジェクトを選択します。ドロップダウンメニューで [作成] をクリックして Flink プロジェクトを作成することもできます。詳細については、「プロジェクトの管理」をご参照ください。
デフォルトのデプロイメントターゲット
Realtime Compute for Apache Flink クラスターを有効化したときに生成されたデフォルトのキューを選択します。ドロップダウンメニューで [作成] をクリックしてキューを作成することもできます。詳細については、「リソースキューの管理」をご参照ください。
デフォルトのアクセスID
デフォルト値は [Executor] です。
計算リソースインスタンス名
計算リソースのカスタム名を入力します。実行時に、この名前に基づいてタスクの計算リソースを選択できます。
[確認] をクリックして構成を完了します。
次のステップ
フルマネージド Flink 計算リソースをアタッチした後、それを使用してデータ開発でノードタスクを開発できます。詳細については、「Flink SQL ストリーミングノード」および「Flink SQL バッチノード」をご参照ください。