メインコンテンツまでスキップ

Import

Importモジュールは、データ統合のための統一されたビジュアルインターフェースを提供します。外部ソースからVeloDB Cloudウェアハウスにデータをシームレスに取り込むことができ、バッチローディングと自動テーブル作成による継続的な取り込みの両方をサポートしています。

左ナビゲーションのWork with dataグループからImportを開き、右上角の**+ Add Import Job**をクリックして新しいタスクを開始します。

サポートされているデータソース​

Importは現在3つのカテゴリのソースをサポートしています：

カテゴリソース
データベースMySQL、PostgreSQL
オブジェクトストレージAmazon S3（およびS3互換ストレージ）
イベントストリームConfluent Cloud、Apache Kafka、Amazon MSK

インポートジョブの作成​

設定の詳細はソースタイプによって異なりますが、すべてのソースで同じ4ステップウィザードと継続的な管理ビューを使用します。以下のチュートリアルでは、例としてデータベースソース（PostgreSQL）を使用します。

1. データソースの選択​

ImportページでE**+ Add Import Job**をクリックし、必要なカテゴリからソースカード（例：PostgreSQL）を選択します。

import-select-source

2. ソース接続の設定​

VeloDB Cloudがソースに到達できるよう、ウィザードが要求するフィールドを入力します：

  • Job Name：ジョブの一意で説明的な名前。
  • Connection credentials：ソースに応じて、ホスト、ポート、データベース、ユーザー名、パスワード、またはAK/SK。オプションでSSLを有効にします。

Nextをクリックします。ウィザードがバックグラウンドでネットワーク接続性と認証情報を検証します。

import-configure-connection

3. テーブルの設定​

ターゲットデータベースと読み取るデータを定義します：

  • Target Database：既存のデータベースに書き込むか、新しいデータベースを作成します。
  • Sync Type：Full + IncrementalまたはIncrementalのみ。
  • Tables to migrate
    • データベース： 同期するスキーマとテーブルを選択します。テーブルを展開してColumn Settingsでカラムレベルのフィルタリングを適用します。
    • イベントストリーム： 消費するトピックと開始オフセットを指定します。
    • オブジェクトストレージ： バケットパスとファイルマッチングパターンを指定します。

import-sync-scope

4. 設定​

ジョブの実行方法を調整します：

  • Sync Interval：データの取得頻度（秒単位；デフォルトは60）。
  • Strict Mode：インポート中に厳密なカラムタイプ変換を強制します。

import-settings

5. 確認と承認​

事前チェックが自動的に実行されます：ネットワーク到達可能性、ソース側権限（例：CDCに必要なWAL/binlogアクセス）、およびターゲット側のテーブル作成と書き込み権限。

すべての項目がSucceededと表示されたら、Startをクリックしてジョブを開始します。

import-verify

6. 管理と監視​

開始後、Importジョブリストに戻ります。ここで各ジョブのステータス（Running、Paused、Failedなど）と作成時刻を追跡できます。ジョブの横にある...メニューを使用して、Pause、Resume、Edit、またはDeleteを実行します。

import-manage