各製品の資料を入手。
詳細はこちら →
SSAS でKafka のデータに連携するOLAP Cube を作成
Kafka のデータプロバイダーを利用してAnalysis Services プロジェクト内のKafka に接続し、アナリティクスやレポーティングなどで使えるOLAP キューブを構築します。
最終更新日：2022-04-10
この記事で実現できるKafka 連携のシナリオ
こんにちは！ウェブ担当の加藤です。マーケ関連のデータ分析や整備もやっています。
SQL Server Analysis Services (SSAS) は、意思決定支援やビジネスアナリティクスで使われる解析エンジンです。ビジネスレポートおよび、Power BI やExcel、 Reporting Services レポート、その他のデータ可視化ツールのようなクライアントアプリケーションに、エンタープライズレベルのセマンティックデータを提供します。Kafka 用のCData ADO.NET プロバイダーと合わせれば、Kafka を使って、より深く速いデータ分析のためのキューブを作成できます。
この記事では、Analysis Services プロジェクトをVisual Studio で作成し、Kafka の多次元モデルを構築および配置する方法を説明します。これには、アクセス可能なSSAS インスタンスと、ADO.NET プロバイダーのインストールが必要です。
Kafka 用のJDBC データソースの設定
まず、Visual Studio で新しい多元的なAnalysis Service とデータマイニングプロジェクトを作成します。次に、プロジェクト内でKafka 用のデータソースを作成します。
- ［Solution Explorer］ の［Data Source］ を右クリックし、［New Data Source］ を選択します。
- 既存または新規の接続に基づいて、データソースを作成することを選択し、［New］ をクリックします。
- ［Connection Manager］ のKafka 用CData ADO.NET プロバイダーを選択し、必要な接続プロパティに入力後、［Next］ をクリックします。
Apache Kafka 接続プロパティの取得・設定方法
.NET ベースのエディションは、Confluent.Kafka およびlibrdkafka ライブラリに依存して機能します。 これらのアセンブリはインストーラーにバンドルされ、自動的に本製品と一緒にインストールされます。 別のインストール方法を利用する場合は、NuGet から依存関係のあるConfluent.Kafka 2.6.0 をインストールしてください。
Apache Kafka サーバーのアドレスを指定するには、BootstrapServers パラメータを使用します。
デフォルトでは、本製品はデータソースとPLAINTEXT で通信し、これはすべてのデータが暗号化なしで送信されることを意味します。 通信を暗号化するには：
- UseSSL をtrue に設定し、本製品がSSL 暗号化を使用するように構成します。
- SSLServerCert およびSSLServerCertType を設定して、サーバー証明書をロードします。
Apache Kafka への認証
Apache Kafka データソースは、次の認証メソッドをサポートしています：- Anonymous
- Plain
- SCRAM ログインモジュール
- SSL クライアント証明書
- Kerberos
Anonymous
Apache Kafka の特定のオンプレミスデプロイメントでは、認証接続プロパティを設定することなくApache Kafka に接続できます。 こうした接続はanonymous（匿名）と呼ばれます。
匿名認証を行うには、このプロパティを設定します。
- AuthScheme：None。
その他の認証方法については、ヘルプドキュメントを参照してください。
接続を構成する際に、Max Rows プロパティを定めることも可能です。これによって戻される行数を制限するため、可視化・レポートのデザイン設計時のパフォーマンスを向上させるのに役立ちます。
- インパーソネーションを［Inherit］ に設定し、［Next］ をクリックします。
- データソースに名称(CData Kafka Source) を入力し、［Finish］ をクリックします。
データソースビューの作成
データソースの次に、データソースビューを作成します。
- ［Solution Explorer］ で［Data Source Views］ を右クリックし、［New Data Source View］ を選択します。
- 先ほど作成したデータソース(CData Kafka Source) を選択し、［Next］ をクリックします。
- 基になるデータソースのパターンに一致する外部キーを選択し、［Next］ をクリックします。
- Kafka の表を選択、ビューに追加し、［Next］ をクリックします。
- ビューに名前を付け、［Finish］ をクリックします。
スキームに一致する外部キーに基づいて、基礎的なデータとのリレーションが検出されます。［Data Source View］ をダブルクリックすることで、これらのリレーションを確認・編集することができます。
［Data Source View］ へのセカンダリデータソースの追加はサポートされないことに注意してください。複数のデータソースを利用する場合、SSAS は、すべてのソースがADO.NET プロバイダーでは使用できないOpenRowset 経由のリモートクエリをサポートすることを必要とします。
Kafka 用のキューブを作成する
プロジェクトを処理してKafka をSSAS に展開するための最後のステップはキューブの作成です。
- ［Solution Explorer］ の［Cubes］ を右クリックし、［New Cube］ を選択します。
- ［Use existing tables］ を選択し、［Next］ をクリックします。
- メジャーグループテーブルに使用するテ－ブルを選択し、［Next］ をクリックします。
- キューブに含ませたいメジャーを選択し、［Next］ をクリックします。
- 使用可能なテーブルに基づいて作成するディメンションを選択し、［Next］ をクリックします。
- すべての選択内容を確認し、［Finish］ をクリックします。
プロジェクトを処理する
データソースと、データソースビュー、キューブを作成すると、SSASにキューブを展開する準備が完了します。ターゲットサーバーとデータベースを構成するために、プロジェクトを右クリックしプロパティを選択します。デプロイメントに移動し、ターゲットセクションでサーバーとデータベースのプロパティを設定します。
ターゲットサーバーとデータベースを構成した後、プロジェクトを右クリックして［Process］ を選択します。このステップの一部として、プロジェクトの構成・デプロイが必要となる場合があります。プロジェクトを構成・デプロイし、［Process Database］ウィザードにある［Run］ をクリックします。
SSAS インスタンスにKafka 用のOLAP キューブが作成され、分析、レポート、表示の準備が完了します。Kafka 用のCData ADO.NET プロバイダーの30日の無償評価版をダウンロードして、SSAS データをご利用ください。
関連コンテンツ
