ローカルデータベースからの増分データのインポート

お知らせ：当社は、お客様により充実したサポート情報を迅速に提供するため、本ページのコンテンツは機械翻訳を用いて日本語に翻訳しています。正確かつ最新のサポート情報をご覧いただくには、本内容の英語版を参照してください。

インクリメンタルデータフェッチは、データ元から新規または更新済みデータをインポートする際に使用される手法です。Zoho DataPrepでは、Zoho Databridgeを利用して、以下のローカルデータベースからインクリメンタルデータのインポートが可能です。

MySQL
MS SQL Server
Oracle
PostgreSQL
Maria DB
Pervasive SQL
Sybase
DB2
Exasol
Sqlite
Actian Vector
Greenplum
Denodo
Progress OpenEdge
YugabyteDB
Microsoft Access
SAP Hana
JDBC URL 接続

インポート開始手順

1. 既存のパイプラインを開くか、パイプラインを作成します。ホームページ、Pipelinesタブ、またはWorkspacesタブから操作し、データを追加オプションをクリックしてください。

情報: データをインポート

アイコンをパイプラインビルダー画面上部でクリックすることでも、複数のソースからデータをパイプラインに取り込むことができます。

2. 次の画面で、必要なデータベースを選択するか、左ペインのDatabasesカテゴリをクリックしてください。

3. 新しい外部連携をConnectionドロップダウンから選択します。既存の外部連携がある場合は、Connectionドロップダウンから必要な接続を選択できます。

4. 接続にConnection 名前欄で名前を付けます。

5. Zoho Databridgeはローカルデータベースからデータをインポートするためのツールです。ローカルネットワークからデータをインポートする場合、Databridgeが必要です。

メモ: 初めてDatabridgeをダウンロードする場合、インストール方法はこちらをご参照ください。

6. Databridgeをマシンにインストールしたら、DatabridgeドロップダウンからDatabridgeを選択します。

メモ: データをインポートしたいデータベースと同じネットワーク内にインストールされているDatabridgeを選択してください。

7. Database 種類を選択し、Database server host 名前とPort番号を入力します。

8. Database 名前を入力し、認証が必要な場合はユーザー名とパスワードを入力します。

9. データベースの設定を保存し、接続を使用してデータベースに接続します。

メモ: 接続設定は今後データベースからインポートする際に自動的に保存されます。認証情報は安全に暗号化され保存されます。

10. インポートしたいテーブルを選択し、インポートする ボタンをクリックします。

データベースからクエリを使用してデータをインポートする場合、増分取得オプションは利用できません。

11. データのインポートが完了すると、Pipeline builder ページが開き、ここから変換の適用を開始できます。ステージを右クリックして、データの準備オプションを選択し、DataPrep Studio ページでデータを整形することも可能です。変換機能の詳細についてはこちらをクリックしてください。

12. データフローの作成や各ステージで必要な変換を適用し終えたら、ステージを右クリックして宛先を追加し、データフローを完了できます。

メモ: パイプラインに宛先を追加した後は、まず手動実行でパイプラインが正常に動作するか確認できます。手動実行が問題なければ、スケジュールを設定し、自動化することが可能です。実行タイプの詳細についてはこちらをご覧ください。

ローカルデータベースのインポート設定

ローカルデータベースからデータをインポートする際、テーブルを選択 オプションを使用すると、下記のインポート設定でローカルデータベースからのインポート方法や増分データの取得方法を設定できます。インポート設定です。

以下はスケジュール設定画面のスナップショットです。

データ元からデータをインポートする方法ドロップダウンからデータのインポート方法を選択します - すべてのデータをインポート、増分ファイル取得、データをインポートしないのいずれかを選択します。

すべてのデータをインポート

このオプションを選択すると、利用可能なすべてのデータが設定した頻度でインポートされます。

インクリメンタルデータフェッチ

Incremental data インポートするとは、特定のデータ期間内の新規または更新済みデータをインポートするための方法です。

重要：このインクリメンタルフェッチオプションは、データベースからクエリを使用してデータをインポートする場合は利用できません。

更新済みおよび新規データのみ

最終インポート日時から更新済みおよび新規データをインポートするには、更新済みおよび新規データのみをドロップダウンから選択してください。

取得元の指定: データの並べ替えやインポートを行う日付・時刻列の名前を入力できます。

新規データが利用できない場合に以前インポートしたデータを使用する:

増分インポート中に、

チェックボックスがオンの場合: データ元に新規データがない場合、最後に取得したデータが再度インポートされます。

チェックボックスがオフの場合: データ元に新規データがない場合、インポートは失敗し、ファイルはインポートされません。その結果、パイプラインジョブ全体が失敗します。

データをインポートしない

データは一度だけインポートされます。2回目以降は同じデータに対してルールが適用され、エクスポート済みとなります。

インクリメンタル同期の仕組み

インポートする設定を使用して、データ元からインクリメンタルデータを取得できます。インポートする構成オプションを利用すると、インクリメンタルデータのインポートは、新規または更新済みデータを指定したデータ間隔で取り込む方法です。

インクリメンタルファイル取得では、パイプライン実行時にテーブル内の新規または更新済みデータを日付・時間列に基づいて取得します。例えば、インポートする設定で更新済みまたは新規データのみを取得するように指定した場合、ローカルデータベース内で指定した時間間隔内の新規または更新済みデータがインポートされます。新たなデータが存在しない場合は、データがインポートされないか、または以前に取得したデータが再度インポートされます（インポートする設定によります）。以降の間隔でも、その期間内の新規または更新済みデータが適宜取得されます。