Realtime Compute for Apache Flink:MySQL カタログの管理

UI (推奨)

1. Data Management ページに移動します。

   1. Realtime Compute for Apache Flink コンソールにログインします。対象のワークスペースを見つけ、[操作] 列の [コンソール] をクリックします。

   2. 左側のナビゲーションウィンドウで、[Data Management] をクリックします。

2. [カタログの作成] をクリックします。[MySQL] を選択し、[次へ] をクリックします。

3. パラメーターを設定します。

   重要

   カタログは作成後に以下の構成を変更することはできません。変更するには、カタログを削除して新しいカタログを作成する必要があります。

   

   パラメータ	説明	必須
   catalogname	MySQL カタログのカスタム名。	はい
   hostname	MySQL データベースの IP アドレスまたはホスト名。 説明 VPC 間またはインターネット経由でインスタンスにアクセスするには、ネットワーク接続を確立する必要があります。詳細については、「ネットワーク接続性」をご参照ください。	はい
   port	MySQL データベースサービスのポート番号。デフォルト値は 3306 です。	いいえ
   default-database	デフォルトの MySQL データベースの名前。	はい
   username	MySQL データベースサービスのユーザー名。	はい
   password	MySQL データベースサービスのパスワード。 プレーンテキストの AccessKey などのリスクを回避するには、パスワードを変数として指定します。画像内の例では、mysqlpw という名前の変数を使用しています。詳細については、「変数を作成する」をご参照ください。	はい

4. [確認] をクリックします。

   カタログリストページの左側にある [カタログ] ペインで、作成したカタログを表示できます。

SQL コマンド

1. [データクエリ] ページに移動します。

   1. Realtime Compute for Apache Flink コンソールにログインします。目的のワークスペースを見つけ、[操作] 列の [コンソール] をクリックします。

   2. 左側のナビゲーションウィンドウで、[開発] > [スクリプト] をクリックします。

2. をクリックし、次に [クエリ スクリプトの作成] をクリックします。[ファイル名] と [ストレージの場所] を入力し、[保存] をクリックします。

3. 次のコードを入力します。

   CREATE CATALOG YourCatalogName WITH(
     'type' = 'mysql',
     'hostname' = 'rm-bp1gcn0q0j0******.mysql.rds.aliyuncs.com',
     'port' = '3306',
     'username' = 'usertest',
     'password' = '${secret_values.mysqlpw}',
     'default-database' = 'flinktest',
     'catalog.table.metadata-columns'='table_name'
   );

   パラメーター	説明	必須
   YourCatalogName	MySQL カタログのカスタム名。	はい
   type	タイプ。値を mysql に設定します。	はい
   hostname	MySQL データベースの IP アドレスまたはホスト名。 説明 VPC 間またはインターネット経由でインスタンスにアクセスするには、ネットワーク接続を確立する必要があります。詳細については、「ネットワーク接続性」をご参照ください。	はい
   port	MySQL データベースサービスのポート番号。デフォルト値は 3306 です。	いいえ
   default-database	デフォルトの MySQL データベースの名前。	はい
   username	MySQL データベースサービスのユーザー名。	はい
   password	MySQL データベースサービスのパスワード。 プレーンテキストの AccessKey などのリスクを回避するには、パスワードを変数として指定します。この例では、mysqlpw という名前の変数を使用しています。詳細については、「変数を作成する」をご参照ください。	はい
   property-version	カタログパラメーターのバージョン。有効な値は 0 (デフォルト) と 1 (推奨) です。 使用可能なパラメーターとそのデフォルト値は、バージョンによって異なる場合があります。違いについては、特定のパラメーターの説明で説明されています。 説明 VVR 8.0.6 以降のみがこのパラメーターをサポートします。 VVR 11.1 以降では、デフォルト値は 1 です。	いいえ
   catalog.table.metadata-columns	データテーブルを取得する際に、MySQL CDC ソーステーブルからテーブルスキーマに追加するメタデータ列を指定します。デフォルトでは、メタデータ列は追加されません。 複数のメタデータ列はセミコロン (;) で区切ります。例: op_ts;table_name;database_name。 説明 Ververica Runtime (VVR) 6.0.5 以降のみがこのパラメーターをサポートします。 このパラメーターが構成されている場合、返されるテーブルスキーマには指定されたメタデータ列が含まれます。これらの列は MySQL CDC ソーステーブルにのみ適用されます。したがって、このカタログによって返されるテーブルは、ソーステーブルとしてのみ使用でき、結果テーブルやディメンションテーブルとしては使用できません。	いいえ
   catalog.table.treat-tinyint1-as-boolean	テーブルスキーマを取得する際に、MySQL の TinyInt(1) 型と Boolean 型を Flink の Boolean 型にマッピングするかどうかを指定します。有効な値: true: Boolean 型にマッピングします。 false: TINYINT 型にマッピングします。 デフォルト値: property-version が 0 の場合、デフォルト値は true です。 property-version が 1 の場合、デフォルト値は false です。 説明 Ververica Runtime (VVR) 8.0.4 以降のみがこのパラメーターをサポートします。 MySQL の TinyInt(1) フィールドに 0 と 1 以外の値を格納することはお勧めしません。マッピングには適切なデータの型を選択してください。詳細については、「タイプのマッピング」をご参照ください。	いいえ

4. カタログ作成のコードを選択し、左側の行番号の横にある [実行] をクリックします。

   The following statement has been executed successfully! というメッセージは、カタログが正常に作成されたことを示します。

   

UI (推奨)

[Data Management] ページでは、[カタログリスト] に作成したカタログの [カタログ名] と [タイプ] が表示されます。

• カタログの表示: 目的のカタログの [操作] 列にある [表示] をクリックして、そのデータベースとテーブルを表示します。

  フィールドのコメント情報は、テーブルスキーマの詳細には表示されません。

• 対象カタログの [操作] 列で、[削除] をクリックします。

  この操作はカタログのみを削除します。対応するサービス内のテーブルは削除されません。削除されたカタログのテーブルを使用している実行中のジョブは影響を受けません。ただし、テーブルが見つからないため、ジョブを再デプロイまたは再起動するとエラーが発生します。この操作は注意して実行してください。

SQL コマンド

1. [データクエリ] ページのテキストエディターに、次のコマンドを入力します。

   -- Flink に対応するカタログ内のテーブルのスキーマ情報を表示します。フィールドのコメント情報は表示されません。
   DESCRIBE `<catalogname>`.`<dbname>`.`<tablename>`;
   
   -- カタログを削除します。
   DROP CATALOG `<catalogname>`;

   説明

   この操作はカタログのみを削除します。対応するサービス内のテーブルは削除されません。削除されたカタログのテーブルを使用している実行中のジョブは影響を受けません。ただし、テーブルが見つからないため、ジョブを再デプロイまたは再起動するとエラーが発生します。この操作は注意して実行してください。

2. コマンドを右クリックし、ショートカットメニューから [実行] を選択します。