Airbyte ELT パイプラインで SingleStore のデータに接続
Airbyte は、データウェアハウス、データレイク、データベースなど、あらゆるデータストアにデータをロードできる強力なツールです。CData Connect AI と組み合わせることで、Airbyte ユーザーはリアルタイムの SingleStore のデータ から直接 Extract, Load, Transform（ELT）パイプラインを作成できます。本記事では、Connect AI を通じて SingleStore に接続し、Airbyte 内で SingleStore のデータ の ELT パイプラインを構築する手順を説明します。
CData Connect AI は SingleStore 専用の SQL Server インターフェースを提供し、ネイティブデータベースへのデータレプリケーションを行うことなくデータをクエリできます。最適化されたデータ処理機能を内蔵しており、フィルタや JOIN を含むサポート対象のすべての SQL 操作を SingleStore に直接転送します。これにより、サーバーサイド処理を活用して目的の SingleStore のデータ を高速に取得できます。
Airbyte 用に SingleStore への接続を構成
Airbyte から SingleStore への接続は、CData Connect AI を介して実現します。Airbyte で SingleStore のデータ を利用するには、まず SingleStore 接続を作成・設定します。
- Connect AI にログインし、Sources をクリックして、 Add Connection をクリックします
- Add Connection パネルから「SingleStore」を選択します
-
SingleStore に接続するために必要な認証プロパティを入力します。
データに接続するには、次の接続プロパティが必要です。
- Server：SingleStore データベースをホスティングしているサーバーのホスト名またはIP アドレス。
- Port：SingleStore データベースをホスティングしているサーバーのポート。
また、オプションで以下を設定することもできます。
- SingleStore：SingleStore Server に接続する場合のデフォルトデータベース。設定されていない場合、すべてのデータベースのテーブルが返されます。
標準認証
標準認証で認証するには、次を設定します。
- User：SingleStore サーバーに認証する際に使われるユーザー。
- Password：SingleStore サーバーに認証する際に使われるパスワード。
統合セキュリティを使用した接続
標準のユーザー名とパスワードを提供する代わりに、Windows 認証を介して信頼されたされたユーザーをサーバーに認証できます。
SSL 認証
SSL 認証を活用してセキュアなセッションを介してSingleStore データに接続できます。次の接続プロパティを設定し、データに接続します。
- SSLClientCert：クライアント証明書のための証明書ストア名に設定。クライアントとサーバーの両方のマシンでトラストストアとキーストアが保持される2-way SSL の場合に使用されます。
- SSLClientCertPassword：クライアント証明書ストアがパスワードで保護されている場合、この値をストアのパスワードに設定します。
- SSLClientCertSubject：TLS/SSL クライアント証明書のサブジェクト。ストア内の証明書を検索するために使用されます。
- SSLClientCertType：クライアントストアの証明書タイプ。
- SSLServerCert：サーバーが受け入れ可能な証明書。
SSH 認証
SSH を使用して、セキュアにリモートマシンにログインできます。SingleStore データにSSH 経由でアクセスするには、次の接続プロパティを設定します。
- SSHClientCert：クライアント証明書のための証明書ストア名に設定。
- SSHClientCertPassword：クライアント証明書ストアがパスワードで保護されている場合、この値をストアのパスワードに設定します。
- SSHClientCertSubject：TLS/SSL クライアント証明書のサブジェクト。ストア内の証明書を検索するために使用されます。
- SSHClientCertType：クライアントストアの証明書タイプ。
- SSHPassword：SSH サーバーに認証するためのパスワード。
- SSHPort：SSH 操作に使用するポート。
- SSHServer：認証しようとしているSSH 認証サーバー。
- SSHServerFingerPrint：接続先のホストの検証に使用するSSH サーバーのフィンガープリント。
- SSHUser：SSH サーバーに認証するためのユーザー名。
- Save & Test をクリックします
-
Add SingleStore Connection ページの Permissions タブに移動し、ユーザーベースの権限を更新します。
パーソナルアクセストークンの追加
REST API、OData API、または仮想 SQL Server を介して Connect AI に接続する際、パーソナルアクセストークン（PAT）を使用して Connect AI への接続を認証します。アクセスの粒度を維持するために、サービスごとに個別の PAT を作成することをお勧めします。
- Connect AI アプリの右上にある歯車アイコン（）をクリックして設定ページを開きます。
- Settings ページで Access Tokens セクションに移動し、 Create PAT をクリックします。
-
PAT に名前を付けて Create をクリックします。
- パーソナルアクセストークンは作成時にのみ表示されます。必ずコピーして、将来の使用に備えて安全な場所に保存してください。
接続の設定と PAT の生成が完了したら、Airbyte から SingleStore のデータ に接続する準備が整いました。
Airbyte から SingleStore に接続
Airbyte から CData Connect AI への接続を確立するには、以下の手順に従います。
- Airbyte アカウントにログインします
- 左側のパネルで Sources をクリックし、Add New Source をクリックします
- Source Type を MSSQL Server に設定して TDS エンドポイントに接続します
- Source Name を設定します
- Host URL を tds.cdata.com に設定します
- Port を 14333 に設定します
- Database を事前に設定した接続名（例：SingleStore1）に設定します
- Username を Connect AI のユーザー名に設定します
- SSL Method を Encrypted (trust server certificate) に設定し、Replication Method は標準のまま、SSH Tunnel Method を No Tunnel に設定します
- （オプション）Schema にソースに適用したい値を設定します
- Password を Connect AI の PAT に設定します
- （オプション）必要な JDBC URL パラメータを入力します
- Test and Save をクリックしてデータソースを作成します。
SingleStore のデータ用の ELT パイプラインを作成
SingleStore のデータ を新しい同期先に接続するには、Sources をクリックし、Set Up Connection をクリックして同期先に接続します。上記で作成したソースと目的の同期先を選択し、Airbyte の処理が完了するまで待ちます。完了すると、接続が使用可能になります。
CData Connect AI の入手
Airbyte から 300 以上の SaaS、ビッグデータ、NoSQL ソースへのリアルタイムデータアクセスを実現するには、 CData Connect AI をぜひお試しください！