AnalyticDB:Kettle を使用したオンプレミスデータのインポート

前提条件

• Kettle がインストールされていること。

• AnalyticDB for MySQL に送信先のデータベースとテーブルが作成済みであること。

• Kettle をインストールしているマシンの IP アドレスが、AnalyticDB for MySQL クラスターのホワイトリストに追加済みであること。

• インターネット経由でご利用の AnalyticDB for MySQL クラスターに接続する必要がある場合は、パブリックエンドポイントを申請してください。

操作手順

1. Kettle を開きます。メニューバーから、File > 新規作成 > 変換 をクリックして、新しい変換を作成します。

2. メニューバーから、File > 新規作成 > データベースの接続 をクリックして、新しいデータベース接続を作成します。

   パラメーター	説明
   接続名	接続を識別するための名前を入力します。
   接続タイプ	MySQL を選択します。
   暗号化	Native (JDBC) を選択します。
   ホスト名	ご利用の AnalyticDB for MySQL クラスター のエンドポイントです。このエンドポイントは、AnalyticDB for MySQL コンソールの クラスター情報 ページで確認できます。
   データベース名	ご利用の AnalyticDB for MySQL 内のデータベース名です。
   ポート番号	3306
   ユーザー名	AnalyticDB for MySQL クラスターにアクセスするためのアカウントです。次のいずれかのアカウントタイプを使用できます。 特権アカウント 標準アカウント
   パスワード	指定されたユーザーアカウントのパスワードです。

   説明

   Use Result Streaming Cursor チェックボックスは選択しないでください。

3. 上記のパラメーター構成を完了したら、テスト をクリックします。データベース接続テスト ダイアログボックスが表示されたら、プロンプトに従って AnalyticDB for MySQL データベースへの接続を確認し、テストが成功したら 確認 をクリックします。

4. 左側の Core objects パネルで、入力 フォルダを展開し、Excel Input ステップをメインワークスペースにドラッグします。

5. ワークスペース内の Excel Input をダブルクリックし、表示される Excel Input ダイアログボックスで、参照 をクリックしてインポートする Excel テーブルをアップロードし、その後 追加 をクリックして Selected files に追加します。

   Sheets、コンテンツ、および フィールド タブで設定を構成します。Preview records をクリックして、データが正しく読み取られていることを確認します。

6. Core objects パネルで、出力 フォルダを展開し、Table output ステップをワークスペースにドラッグします。

7. Excel Input ステップから Table output ステップへ向かってホップ (接続線) を作成します。

8. Table output ステップをダブルクリックして Table output ダイアログボックスを開き、以下の設定を行います。

   • Target schema：ご利用の AnalyticDB for MySQL データベース名を入力します。

   • ターゲットテーブル：ご利用の AnalyticDB for MySQL データベース内の送信先テーブル名を入力します。

   • Specify database fields チェックボックスをオンにします。

   • Use batch insert チェックボックスをオンにします。

   Table Output の Database Fields タブで、Get Fields および Input Field Mapping をクリックして、Excel の列と AnalyticDB for MySQL テーブルのカラム名とのマッピングを構成します。

9. Run アイコン (緑色の三角形) をクリックして変換を開始します。ウィンドウ下部の Log パネルで実行ログとステータスを監視します。

   データがインポートされた後は、AnalyticDB for MySQL で分析クエリを実行できます。