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

コンソール (推奨)

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

   1. Realtime Compute for Apache Flink コンソールにログインし、管理するワークスペースの[操作]列で[コンソール]をクリックします。

   2. 左側のナビゲーションペインで、[データ管理] をクリックします。

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

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

   重要

   これらの設定パラメータは、作成後に変更できません。変更を行うには、カタログを削除して再作成する必要があります。

   パラメータ	説明	必須
   catalogname	MySQL カタログの名前。	はい
   hostname	MySQL データベースの IP アドレスまたはホスト名。 説明 異なる VPC 間または インターネット 経由で接続するには、ネットワーク接続を確立する必要があります。詳細については、「ネットワーク接続」をご参照ください。	はい
   port	MySQL データベースのポート番号。デフォルト： 3306。	いいえ
   default-database	デフォルトの MySQL データベースの名前。	はい
   username	MySQL データベースのユーザー名。	はい
   password	MySQL データベースのパスワード。 シークレットをプレーンテキストで公開しないように、変数の使用を推奨します。この例では、mysqlpw という名前の変数を使用しています。詳細については、「変数の作成」をご参照ください。	はい

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

   作成されたカタログは、左側の[カタログ] エリアに表示されます。

SQL コマンド

1. [Scripts] ページに移動します。

   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 データベースのパスワード。 シークレットをプレーンテキストで公開しないように、変数の使用を推奨します。この例では、mysqlpw という名前の変数を使用しています。詳細については、「変数の作成」をご参照ください。	はい
   property-version	カタログのプロパティスキーマのバージョン。0 または 1 (推奨) に設定します。 バージョンによって、サポートされるプロパティとデフォルト値が異なる場合があります。詳細については、プロパティの説明をご参照ください。 説明 VVR 8.0.6 以降でのみサポートされています。 VVR 11.1 以降では、デフォルト値は 1 です。それ以前のバージョンでは、デフォルト値は 0 です。	いいえ
   catalog.table.metadata-columns	テーブルをクエリする際に、テーブルスキーマに追加する MySQL CDC ソーステーブルのメタデータ列を指定します。デフォルトでは、メタデータ列は追加されません。 複数のメタデータ列はセミコロン (;) で区切ります。例： op_ts;table_name;database_name 説明 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 です。 説明 VVR 8.0.4 以降でのみサポートされています。 MySQL で TinyInt(1) を 0 と 1 以外の値を格納するために使用することは推奨しません。適切な型マッピングを選択してください。詳細については、「型マッピング」をご参照ください。	いいえ

4. CREATE CATALOG ステートメントを選択し、左側の行番号の横にある[実行]をクリックします。

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

   エディター内の SQL ステートメント CREATE CATALOG myCatalog には、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 などの設定パラメーターがあります。

コンソール (推奨)

[データ管理] ページでは、[カタログリスト] で、作成されたカタログの [名前] と [タイプ] を表示できます。

• 表示： カタログの[操作]列で、[表示]をクリックすると、カタログ内のデータベースとテーブルが表示されます。

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

• 削除: カタログの [アクション] 列で、[削除] をクリックします。

  この操作では、カタログのみが削除され、関連するサービス内の基盤となるテーブルは削除されません。カタログのテーブルを使用している実行中のデプロイメントには影響しません。ただし、これらのデプロイメントを再デプロイまたは再起動すると、テーブルが見つからないためエラーが報告されます。慎重に実行してください。

SQL コマンド

1. [Scripts] ページのエディタで、次のコマンドを入力します。

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

   説明

   この操作では、カタログのみが削除され、関連するサービス内の基盤となるテーブルは削除されません。カタログのテーブルを使用している実行中のデプロイメントには影響しません。ただし、デプロイメントを再デプロイまたは再起動すると、テーブルが見つからないためエラーが報告されます。慎重に実行してください。

2. コマンドを選択して右クリックし、[実行] を選択します。

   DESCRIBE ステートメントを実行すると、orderkey、custkey、order_status、total_price などのフィールドとそのデータ型およびプロパティを含む、テーブルのスキーマが返されます。