SSIS を使ってElasticsearch のデータをSQL Server にインポート

古川えりか
コンテンツスペシャリスト
最終更新日：2022-07-10

この記事で実現できるElasticsearch 連携のシナリオ

こんにちは！ドライバー周りのヘルプドキュメントを担当している古川です。

SQL Server に基幹業務データのバックアップを保管しておくことは、ビジネス上のセーフティネットとなります。また、ユーザーはSQL Server のバックアップデータからレポーティングや分析を簡単に行うことができます。

ここでは、SQL サーバー SSIS ワークフロー内でCData SSIS Tasks for Elasticsearch を使用して、Elasticsearch のデータをMicrosoft SQL Server データベースに転送する方法を説明します。

開始するには、新しいElasticsearch ソースとSQL Server ADO.NET 転送先を新しいデータフロータスクに追加します。

以下のステップに従って、接続マネジャーでElasticsearch 接続プロパティを保存します。

Connection Manager ウィンドウで、右クリックで［New Connection］を選択します。Add SSIS Connection Manager ダイアログが表示されます。
［Connection Manager type］メニューでElasticsearch を選択します。CData Elasticsearch Connection Manager が表示されます。
接続プロパティを構成します。
Elasticsearch 接続プロパティの取得・設定方法

接続するには、Server およびPort 接続プロパティを設定します。認証には、User とPassword プロパティ、PKI (public key infrastructure)、またはその両方を設定します。 PKI を使用するには、SSLClientCert、SSLClientCertType、SSLClientCertSubject、およびSSLClientCertPassword プロパティを設定します。

CData 製品は、認証とTLS/SSL 暗号化にX-Pack Security を使用しています。TLS/SSL で接続するには、Server 値に'https://' を接頭します。Note: PKI を使用するためには、TLS/SSL およびクライアント認証はX-Pack 上で有効化されていなければなりません。

接続されると、X-Pack では、設定したリルムをベースにユーザー認証およびロールの許可が実施されます。

以下のステップに従って、Elasticsearch の抽出に使用するクエリを指定します。

Elasticsearch ソースをダブルクリックしてソースコンポーネントエディタを開きます。
［Connection Manager］メニューで、以前作成した接続マネジャーを選択します。
データの書き出しに使用するクエリを指定します。例： SELECT Orders.Freight, Customers.ContactName FROM Customers INNER JOIN Orders ON Customers.CustomerId=Orders.CustomerId
Elasticsearch Source コントロールを閉じて、ADO.NET Destination に接続します。

以下のステップに従って、Elasticsearch をロードするSQL サーバーテーブルを指定します。

プロジェクトを実行できるようになりました。SSIS Task の実行が完了すると、データベースにElasticsearch のデータが入力されます。

30日間無償トライアルで、CData のリアルタイムデータ連携をフルにお試しいただけます。記事や製品についてのご質問があればお気軽にお問い合わせください。

無償トライアルへ

お問い合わせ