Tablestore データソースを作成することで、Dataphin が Tablestore からビジネスデータを読み取ったり、Tablestore にデータを書き込んだりできるようになります。このトピックでは、Tablestore データソースを作成する方法について説明します。
背景情報
Tablestore は Alibaba Cloud Tablestore です。 Tablestore は、大量の構造化データ向けのサーバーレス テーブル ストレージ サービスを提供し、IoT シナリオ向けに最適化されたワンストップ IoTstore ソリューションを提供します。 Tablestore を使用すると、ミリ秒単位でオンライン データをクエリおよび取得し、保存されているデータに対して多次元分析を実行できます。 Tablestore は、課金、インスタントメッセージ (IM)、モノのインターネット (IoT)、車載インターネット (IoV)、リスク管理、インテリジェントレコメンデーションなどのシナリオに適しています。
Alibaba Cloud Tablestore を使用していて、データ開発のために Dataphin に接続する必要がある場合、または Dataphin データを Tablestore に書き込む必要がある場合は、最初に Tablestore データソースを作成する必要があります。 詳細については、「Tablestore とは」をご参照ください。
権限
データソースの作成 権限を持つカスタム グローバル ロールと、スーパー管理者、データソース管理者、ドメイン設計者、プロジェクト管理者 などのシステム ロールのみが、データソースを作成できます。
手順
Dataphin ホームページの上部ナビゲーションバーで、[管理センター] > [データソース管理] をクリックします。
[データソース] ページで、[+データソースの作成] をクリックします。
[データソースの作成] ページで、[NoSQL] セクションから [Tablestore] を選択します。
最近 Tablestore を使用したことがある場合は、[最近使用したデータソース] セクションから選択することもできます。 また、検索ボックスにキーワードを入力して Tablestore をすばやく検索することもできます。
[Tablestore データソースの作成] ページで、接続パラメータを構成します。
データソースの基本情報を構成します。
パラメーター
説明
[データソース名]
名前は次の要件を満たしている必要があります。
漢字、英字、数字、アンダースコア (_)、ハイフン (-) のみを含めることができます。
長さは 64 文字を超えることはできません。
[データソースコード]
データソースコードを構成した後、
データソースコード.テーブル名またはデータソースコード.スキーマ.テーブル名の形式を使用して、Flink_SQL タスクでデータソース内のテーブルを参照できます。 現在の環境に基づいて対応する環境のデータソースに自動的にアクセスする必要がある場合は、変数形式${データソースコード}.tableまたは${データソースコード}.schema.tableを使用します。 詳細については、「Dataphin データソーステーブル開発方法」をご参照ください。重要データソースコードは、正常に構成された後は変更できません。
データソースコードが正常に構成されると、アセットディレクトリとアセットインベントリのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、現在、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、SelectDB データソースのみがサポートされています。
データソースの説明
データソースの簡単な説明。 128 文字を超えることはできません。
データソースの構成
構成するデータソースを選択します。
ビジネスデータソースが本番データソースと開発データソースを区別する場合は、[本番 + 開発データソース] を選択します。
ビジネスデータソースが本番データソースと開発データソースを区別しない場合は、[本番データソース] を選択します。
[タグ]
タグを使用してデータソースを分類およびタグ付けできます。 タグの作成方法については、「データソースタグの管理」をご参照ください。
データソースと Dataphin 間の接続パラメーターを構成します。
前のステップで [本番 + 開発データソース] を選択した場合、構成ページは次の図のように表示されます。 [本番データソース] を選択した場合は、本番データソースの構成ページのみが表示されます。
説明通常、本番データソースと開発データソースは別々のデータソースとして構成し、環境の隔離を実現し、開発活動が本番に及ぼす影響を軽減する必要があります。 ただし、Dataphin では、同じパラメータ値を持つ同じデータソースとして構成することもサポートされています。
パラメーター
説明
[エンドポイント]
インスタンスアクセスアドレス。 VPC ネットワークインスタンスアクセスアドレスを使用することをお勧めします。 インスタンスアクセスアドレスは、Tablestore コンソールの [インスタンスの詳細] タブにある [インスタンス管理] ページで確認できます。
[アクセス ID]、[アクセス キー]
現在のアカウントの AccessKey ID と AccessKey Secret。 取得方法については、「アクセスキーの作成」をご参照ください。
[インスタンス名]
インスタンスの名前。 インスタンス名は、Tablestore コンソールの [すべてのインスタンス] ページで確認できます。
現在のデータソースに関連するタスク (データベース SQL、オフラインデータベース移行、データプレビューなど) を実行するために使用される [デフォルトリソースグループ] を選択します。
[接続テスト] をクリックするか、[OK] をクリックして保存し、Tablestore データソースの作成を完了します。
[接続テスト] をクリックすると、システムはデータソースが Dataphin に正常に接続できるかどうかをテストします。 [OK] を直接クリックすると、システムは選択したすべてのクラスターの接続を自動的にテストします。 ただし、選択したすべてのクラスターの接続テストが失敗した場合でも、データソースは正常に作成されます。