ローカルデータベースからインクリメンタルデータをインポートする

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

インクリメンタルデータフェッチは、データ元から新規または更新済みデータをインポートする際に使用する手法です。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ページが開き、トランスフォームの適用を開始できます。ステージを右クリックして、Prepare dataオプションを選択し、DataPrep Studioページでデータを準備することも可能です。トランスフォームの詳細についてはこちらをクリックしてください。

12. データフローの作成および各ステージで必要なトランスフォームを適用し終えたら、ステージを右クリックして出力先を追加してデータフローを完了できます。

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

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

ローカルデータベースからデータをインポートする際に、テーブルを選択 オプションを利用すると、下記のインポート設定を使ってローカルデータベースからデータをどのようにインポート・取得するかを設定できます。インポート設定の例を以下に示します。

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

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

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

このオプションを選択すると、実行ごとに利用可能なすべてのデータがインポートされます。

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

インクリメンタルデータインポートするは、新規または更新済みデータを特定のデータ期間内でインポートする際に使用される方法です。

重要: データをクエリ差出人データベースからインポートする場合、このインクリメンタルフェッチオプションは利用不可です。

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

最終インポート日時以降の更新済みおよび新規データをインポートするには、ドロップダウンから更新済みおよび新規データのみオプションを選択します。

フェッチ基準: データを並べ替えてインポートする基準となる日付-時間列名を入力できます。

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

インクリメンタルインポートする際に、

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

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

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

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

増分同期の仕組み

インポート設定を利用して、データ元から増分データを取得することができます。インポート設定オプションを使用して、増分データのインポートが可能です。増分データのインポートは、新規または更新済みデータを特定のデータ間隔で取り込む方法です。

増分ファイル取得では、パイプライン実行時に、テーブル内の日付・時間列を基準として新規または更新済みデータが取得されます。例えば、インポート設定で「更新済みまたは新規データのみを取得」と指定した場合、ローカルデータベース内の指定した時間範囲にあるテーブルの新規または更新済みデータがインポートされます。新規データが存在しない場合は、データがインポートされないか、または以前に取得したデータが再度インポートされることがあります（インポート設定による）。以降の各間隔でも、その期間内の新規または更新済みデータが順次取得されます。