AnalyticDB:IMPORT FOREIGN SCHEMA

前提条件

開始する前に、以下を確認してください。

• V3.2.2.0 以降で実行されている AnalyticDB for MySQL クラスター

  マイナーバージョンを表示および更新するには、AnalyticDB for MySQL コンソール にログインし、[クラスター情報] ページの [設定情報] セクションに移動します。

• クラスターで Elastic Network Interface (ENI) が有効になっていること

  重要

  ENI を有効化するには、AnalyticDB for MySQL コンソール にログインし、クラスターの詳細ページに移動して、左側のナビゲーションウィンドウで [クラスターマネジメント] > [クラスター情報] を選択します。 [ネットワーク情報] セクションで ENI を有効化します。 ENI の有効化または無効化により、約 2 分間データベース接続が中断されます。 この期間中は、読み取りまたは書き込み操作を実行できません。

• ご利用の AnalyticDB for MySQL クラスターと同じリージョンに MaxCompute プロジェクトがあること

• ご利用のクラスターが存在する virtual private cloud (VPC) の CIDR ブロックが、MaxCompute プロジェクトの IP アドレスホワイトリストに追加されていること

  CIDR ブロックを確認するには、AnalyticDB for MySQL コンソールの[クラスター情報]VPC コンソールで該当の VPC を検索します。MaxCompute でのホワイトリストの設定方法については、「IP アドレスホワイトリストの管理」をご参照ください。

• クラスター用に外部サーバーが作成されていること — このトピックの「外部サーバーの作成」をご参照ください。

クイックスタート

以下のエンドツーエンドの例は、外部サーバーを作成し、外部テーブルをインポートする完全なワークフローを示しています。

ステップ 1: 外部サーバーの作成

CREATE SERVER maxcompute_server
TYPE = 'ODPS'
SERVER_PROPERTIES = '{
    "endpoint":"http://service.cn-hangzhou-vpc.maxcompute.aliyun-inc.com/api",
    "accessid":"STS.****************",
    "accesskey":"yourAccessKeySecret"
}';

ステップ 2: MaxCompute プロジェクトからすべてのテーブルをインポートします。

IMPORT FOREIGN SCHEMA my_project
FROM maxcompute_server
INTO my_adb_schema;

これにより、my_project 内のすべてのテーブルに対して AnalyticDB for MySQL に外部テーブルが作成されます。

構文

IMPORT FOREIGN SCHEMA odps_project
[LIMIT TO (table_name[, ...])]
FROM server_name
INTO adb_schema
[OPTIONS (
  if_table_exist 'error|ignore|update',
  if_type_unsupport 'error|ignore',
  table_prefix 'table_prefix',
  table_suffix 'table_suffix')]

パラメーター

例

IMPORT FOREIGN SCHEMA my_project
FROM maxcompute_server
INTO my_adb_schema;

IMPORT FOREIGN SCHEMA my_project
LIMIT TO (customer, order)
FROM maxcompute_server
INTO my_adb_schema
OPTIONS (
    if_table_exist 'update',
    if_type_unsupport 'ignore',
    table_prefix 'pre_',
    table_suffix '_suf'
);

外部サーバーの管理

外部サーバーは、MaxCompute プロジェクトの接続構成を保存します。IMPORT FOREIGN SCHEMA を実行する前に作成してください。

CREATE SERVER <server_name>
TYPE = 'ODPS'
SERVER_PROPERTIES = '{
    "endpoint":"<endpoint>",
    "accessid":"<accesskey_id>",
    "accesskey":"<accesskey_secret>"
}'

CREATE SERVER maxcompute_server
TYPE = 'ODPS'
SERVER_PROPERTIES = '{
    "endpoint":"http://service.cn-hangzhou-vpc.maxcompute.aliyun-inc.com/api",
    "accessid":"STS.****************",
    "accesskey":"yourAccessKeySecret"
}';

SHOW SERVER

SHOW SERVER WHERE SERVER_NAME='<server_name>';

SHOW SERVER WHERE SERVER_NAME='maxcompute_server';

SHOW SERVER WHERE SERVER_TYPE='<server_type>';

SHOW SERVER WHERE SERVER_TYPE='ODPS';

ALTER SERVER <server_name> RENAME <new_server_name>

ALTER SERVER maxcompute_server RENAME mc_server;

DROP SERVER <server_name>

DROP SERVER maxcompute_server;