Google Data Fusion で Short.io に連携した ETL プロセスを作成

Google Data Fusion を使用すると、セルフサービス型のデータ連携を行い、異なるデータソースを統合できます。CData API Driver for JDBC をアップロードすることで、Google Data Fusion のパイプライン内から Short.io のデータ にリアルタイムでアクセスできるようになります。CData JDBC Driver を使用すると、Short.io のデータ を Google Data Fusion でネイティブにサポートされている任意のデータソースにパイプできますが、この記事では、Short.io から Google BigQuery へデータをパイプする方法を説明します。

CData API Driver for JDBC を Google Data Fusion にアップロード

CData API Driver for JDBC を Google Data Fusion インスタンスにアップロードして、Short.io のデータ にリアルタイムでアクセスしましょう。Google Data Fusion では JDBC ドライバーの命名規則に制限があるため、JAR ファイルを driver-version.jar という形式に合わせてコピーまたはリネームしてください。例：cdataapi-2020.jar

1. Google Data Fusion インスタンスを開きます
2. をクリックしてエンティティを追加し、ドライバーをアップロードします
3. "Upload driver" タブで、リネームした JAR ファイルをドラッグまたは参照します。
4. "Driver configuration" タブで以下を設定します：
   • Name: ドライバーの名前（cdata.jdbc.api）を作成し、メモしておきます
   • Class name: JDBC クラス名を設定します：（cdata.jdbc.api.APIDriver）
   
5. "Finish" をクリックします

Google Data Fusion で Short.io のデータ に接続

JDBC Driver をアップロードしたら、Google Data Fusion のパイプラインで Short.io のデータ にリアルタイムでアクセスできます。

1. Pipeline Studio に移動して、新しいパイプラインを作成します
2. "Source" オプションから "Database" をクリックして、JDBC Driver 用のソースを追加します
3. Database ソースの "Properties" をクリックしてプロパティを編集します

   NOTE：Google Data Fusion で JDBC Driver を使用するには、ライセンス（製品版またはトライアル）とランタイムキー（RTK）が必要です。ライセンス（またはトライアル）の取得については、CData までお問い合わせください。

   • Label を設定します
   • Reference Name を将来の参照用の値に設定します（例：cdata-api）
   • Plugin Type を "jdbc" に設定します
   • Connection String を Short.io の JDBC URL に設定します。例：
     
     jdbc:api:RTK=5246...;Profile=C:\profiles\ShortIo.apip;AuthScheme=APIKey;ProfileSettings='APIKey=your_api_key';

     API キー認証の設定

     Short.io は API キー認証を使用します。API キーを取得するには、以下のステップで進めます：

     1. Short.io アカウントにログインします
     2. Settings > Integrations & API > API に移動します
     3. Create API Key をクリックして API キーをコピーします

     API キーを取得したら、接続を確立できます：

     • AuthScheme：APIKey に設定します。
     • APIKey：Settings > Integrations & API > API から取得した Short.io の API キーに設定します。

     接続文字列の例：

     Profile=C:\profiles\ShortIo.apip;AuthScheme=APIKey;ProfileSettings='APIKey=your_api_key';
     

     利用可能なテーブル

     Short.io プロファイルでは、以下のテーブルにアクセスできます：

     • Domains - 認証済みアカウントに関連付けられた Short.io ドメイン
     • Links - ドメインの短縮リンク
     • LinkExpand - ドメインとパスから短縮リンクを展開
     • LinksByOriginalUrl - 指定した元の宛先 URL に一致する複数の短縮リンクを取得
     • Folders - 特定のドメイン内のリンクフォルダー
     • LinkPermissions - ドメイン内の特定のリンクの権限レコード
     • CountryTargeting - 特定の短縮リンクの国別リダイレクトターゲティングルール
     • RegionTargeting - 特定の短縮リンクの地域別リダイレクトターゲティングルール
     • Regions - 指定した国コードに対する利用可能な地域／州の一覧
     • DomainStatistics - Short.io ドメインのクリック数とトラフィックの集計統計
     • LinkStatistics - 特定の Short.io リンクのクリック数とトラフィックの集計統計

     ビルトイン接続文字列デザイナー

     JDBC URL の作成には、Short.io JDBC Driver に組み込まれている接続文字列デザイナーを使用できます。JAR ファイルをダブルクリックするか、コマンドラインから JAR ファイルを実行してください。

           java -jar cdata.jdbc.api.jar
           

     接続プロパティを入力し、接続文字列をクリップボードにコピーします。

     
   • Import Query を Short.io から取得したいデータを抽出する SQL クエリに設定します。例：
     SELECT * FROM Domains
   
4. "Sink" タブから、同期先シンクを追加します（この例では Google BigQuery を使用します）
5. BigQuery シンクの "Properties" をクリックしてプロパティを編集します
   • Label を設定します
   • Reference Name を api-bigquery のような値に設定します
   • Project ID を特定の Google BigQuery プロジェクト ID に設定します（またはデフォルトの "auto-detect" のままにします）
   • Dataset を特定の Google BigQuery データセットに設定します
   • Table を Short.io のデータ を挿入するテーブル名に設定します
   

Source と Sink を設定すると、Short.io のデータ を Google BigQuery にパイプする準備が整います。パイプラインを保存してデプロイしてください。パイプラインを実行すると、Google Data Fusion が Short.io からリアルタイムデータをリクエストし、Google BigQuery にインポートします。

これはシンプルなパイプラインの例ですが、変換、分析、条件などを使用してより複雑な Short.io パイプラインを作成できます。CData API Driver for JDBC の 30日間の無償トライアルをダウンロードして、今すぐ Google Data Fusion で Short.io のデータ をリアルタイムで活用しましょう。