このトピックでは、このチュートリアルで Ververica Flink 計算ソース、データソース、およびリアルタイムプロジェクトを作成してアタッチするプロセスについて説明します。
ステップ 1:Ververica Flink 計算ソースの作成コンピューティング ソース
Dataphin ホームページに移動し、トップメニューバーの [計画] をクリックします。
以下の画像を参考に、[ververica Flink 新規計算ソース] ページにアクセスします。

[新規計算ソース] ページで、必須パラメーターを入力します。
パラメーター
説明
計算タイプ
計算タイプとして Ververica Flink を選択します。
リージョン
計算ソースを配置するリージョン(中国 (杭州) など)を選択します。
アクセス方法
計算ソースのアクセス方法を選択します。VPC ネットワークが推奨オプションです。
アクセスキー ID、アクセスキーシークレット
フルマネージド Flink プロジェクトへのアクセス権を持つアカウントのアクセスキー ID とアクセスキーシークレットを入力します。
ユーザー情報管理ページからアクセスキー ID とアクセスキーシークレットを取得します。

Flink ワークスペース ID
Ververica Flink 計算ソースに関連付けられている [flink ワークスペース ID] を選択します。通常は flink_dataphin_default です。
Flink プロジェクトスペース
Ververica Flink 計算ソースの [プロジェクトスペース] を選択します。
計算ソース名
計算ソースの名前として flink_dataphin を入力します。
説明
計算ソースの簡単な説明(リアルタイム R&D デモ など)を入力します。
[検証して送信] をクリックします。システムは計算ソースの接続性を検証し、作成に進みます。
ステップ 3:プロジェクトの作成
以下の画像を参考に、[新規プロジェクト] ダイアログボックスにアクセスします。

本番開発タイプ ステップで、[基本モード] を選択し、[次へ] をクリックします。
[新規プロジェクト] ダイアログボックスで、以下のようにプロジェクトの詳細を入力します。
パラメーター
説明
ビジネスユニット
このフィールドは空白のままにします。デフォルト設定は 空 です。
プロジェクトの英語名
プロジェクトの名前として flink_dataphin を入力します。
プロジェクト名
プロジェクト名 flink_dataphin を入力します。
計算ソースタイプ
リアルタイムエンジンをアクティブにし、Ververica Flink 計算ソースを選択します。Flink ストリーム処理計算ソースには、以前に作成した flink_dataphin 計算ソースを選択します。
スペータイプ
[一般レイヤー] を選択します。
セキュリティ設定
デフォルト構成 を採用します。
その他の設定
デフォルト構成 を維持します。
[OK] をクリックして、リアルタイムプロジェクトの作成を完了します。
ステップ 4:データソースの作成
Dataphin ホームページで、トップメニューバーから [管理センター] を選択します。
以下の画像を参考に、[新規データソース] ダイアログボックスに移動します。

[リレーショナルデータソース] セクションで、[mysql] を選択します。
[新規 Mysql データソース] ダイアログボックスで、以下に概説するようにデータソースの詳細を入力します。
パラメーター
説明
データソース名
データソースの名前として flink_dataphin を入力します。
バージョン
バージョンを選択します。たとえば、[mysql8] です。
データソースの説明
データソースの簡単な説明(リアルタイム R&D のソースデータ など)を入力します。
データソース構成
["production" データソース] 構成を選択します。
タグ
デフォルトオプションの [未入力] のままにします。
JDBC URL
jdbc:mysql://host:port/dbnameの形式で JDBC URL を入力します。host:portの詳細は、以下に示すように MySQL インスタンス 製品ページに記載されています。
重要接続の問題を回避するために、Dataphin の IP がデータベースのホワイトリストに追加されていることを確認します。詳細については、
内部ネットワークアドレスを使用する場合は、データベースと Dataphin インスタンスが同じリージョンにあることを確認します。詳細については、
ユーザー名、パスワード
データソースにログインするために必要な ユーザー名 と パスワード を入力します。
SSL 暗号化
MySQL データソースで SSL 暗号化が有効になっている場合は、[有効] を選択し、次に [トラストストア証明書をアップロード] を選択し、安全なデータ転送のために [トラストストア証明書のパスワード] を入力します。
タイプ
タイプとして ApsaraDB を選択します。
説明アクセス方法は、データベースの作成時に選択したネットワークタイプに対応している必要があります。
パブリックネットワークデータベース の場合は、パブリックネットワーク経由でアクセスできるデータベースを選択します。
ApsaraDB は、Alibaba Cloud でホストされているデータベースを指します。
ECS (VPC) 自己管理データベース の場合は、VPC 内の自己管理データベースを選択します。
詳細設定
デフォルト構成 を保持します。
[接続テスト] を選択して、接続性を検証します。
接続テストが成功したら、[OK] をクリックして、データソースの設定を完了します。