Airbyte ELT パイプラインで Access のデータに接続
Airbyte は、データウェアハウス、データレイク、データベースなど、あらゆるデータストアにデータをロードできる強力なツールです。CData Connect AI と組み合わせることで、Airbyte ユーザーはリアルタイムの Access のデータ から直接 Extract, Load, Transform(ELT)パイプラインを作成できます。本記事では、Connect AI を通じて Access に接続し、Airbyte 内で Access のデータ の ELT パイプラインを構築する手順を説明します。
CData Connect AI は Access 専用の SQL Server インターフェースを提供し、ネイティブデータベースへのデータレプリケーションを行うことなくデータをクエリできます。最適化されたデータ処理機能を内蔵しており、フィルタや JOIN を含むサポート対象のすべての SQL 操作を Access に直接転送します。これにより、サーバーサイド処理を活用して目的の Access のデータ を高速に取得できます。
Airbyte 用に Access への接続を構成
Airbyte から Access への接続は、CData Connect AI を介して実現します。Airbyte で Access のデータ を利用するには、まず Access 接続を作成・設定します。
- Connect AI にログインし、Sources をクリックして、 Add Connection をクリックします
- Add Connection パネルから「Access」を選択します
-
Access に接続するために必要な認証プロパティを入力します。
Access接続の設定方法
ローカルファイルへの接続設定
ローカル環境からAccess への接続は非常にシンプルです。ConnectionType をLocal に設定することで、CRUD 操作(SELECT、INSERT、UPDATE、DELETE)をすべて実行できます。接続にはDataSource プロパティに以下のようなAcces sデータベースファイルのフルパスを指定します。
C:\Users\Public\Documents\MyDatabase.accdb
詳細な接続手順については、ヘルプドキュメントの「はじめに」セクションをご参照ください。
クラウドストレージ上のAccess ファイルへの接続設定
各種クラウドストレージに保存されているAccess ファイルへのアクセスにも対応しています。ただし、クラウド上のファイルに対するデータ操作は、INSERT、UPDATE、DELETE に制限されますのでご注意ください。
S3、Google Driver、OneDrive など、各種クラウドストレージ内のAccess ファイルへの接続方法はこちらの記事をご確認ください。
クラウド上のファイルを更新したい場合は、以下の手順で実施いただけます。
- 対応するCData ドライバーを利用し、クラウドサービスからAccess ファイルをダウンロード
- Access ドライバーを使用して、ローカル環境でファイルを編集
- クラウドサービス用ドライバーのストアドプロシージャを使用して、更新ファイルをアップロード
具体例として、SharePoint 上のファイルを更新する場合の手順をご紹介します。
- CData SharePoint ドライバーのDownloadDocument プロシージャを使用してファイルを取得
- CData Access ドライバーでファイルの更新を実施
- SharePoint ドライバーのUploadDocument プロシージャで更新内容を反映
DataSource 接続プロパティの設定について補足いたします。接続先のクラウドストレージを識別するための一意の接頭辞を指定し、続けて目的のファイルパスまたはフォルダパスを記述します。フォルダを指定した場合は1ファイルが1テーブルとして、単一ファイルの場合は単一テーブルとして扱われます。
- Save & Test をクリックします
-
Add Access 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 から Access のデータ に接続する準備が整いました。
Airbyte から Access に接続
Airbyte から CData Connect AI への接続を確立するには、以下の手順に従います。
- Airbyte アカウントにログインします
- 左側のパネルで Sources をクリックし、Add New Source をクリックします
- Source Type を MSSQL Server に設定して TDS エンドポイントに接続します
- Source Name を設定します
- Host URL を tds.cdata.com に設定します
- Port を 14333 に設定します
- Database を事前に設定した接続名(例:Access1)に設定します
- 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 をクリックしてデータソースを作成します。
Access のデータ用の ELT パイプラインを作成
Access のデータ を新しい同期先に接続するには、Sources をクリックし、Set Up Connection をクリックして同期先に接続します。上記で作成したソースと目的の同期先を選択し、Airbyte の処理が完了するまで待ちます。完了すると、接続が使用可能になります。
CData Connect AI の入手
Airbyte から 300 以上の SaaS、ビッグデータ、NoSQL ソースへのリアルタイムデータアクセスを実現するには、 CData Connect AI をぜひお試しください!