ADO.NET 経由でTIBCO Spotfire でKafka のデータに連携してをビジュアライズ

TIBCO Spotfire のダッシュボードにKafka のデータの連携が驚くほど簡単に。

加藤龍彦
デジタルマーケティング

最終更新日:2022-09-16

こんにちは!ウェブ担当の加藤です。マーケ関連のデータ分析や整備もやっています。

この記事では、CData ADO.NET Provider for ApacheKafka をTIBCO Spotfire で使う方法を説明します。接続を確立して、簡単なダッシュボードを作成していきます。

  1. [Add Data Tables]をクリックして、CData ADO.NET データソースを追加します。
  2. [Add]>[Database]をクリックします。
  3. プロバイダーを選択して[Configure]をクリックします。
  4. 接続設定を定義します。一般的な接続文字列は次のとおりです。

    User=admin;Password=pass;BootStrapServers=https://localhost:9091;Topic=MyTopic;

    Apache Kafka 接続プロパティの取得・設定方法

    .NET ベースのエディションは、Confluent.Kafka およびlibrdkafka ライブラリに依存して機能します。 これらのアセンブリはインストーラーにバンドルされ、自動的に本製品と一緒にインストールされます。 別のインストール方法を利用する場合は、NuGet から依存関係のあるConfluent.Kafka 2.6.0 をインストールしてください。

    Apache Kafka サーバーのアドレスを指定するには、BootstrapServers パラメータを使用します。

    デフォルトでは、本製品はデータソースとPLAINTEXT で通信し、これはすべてのデータが暗号化なしで送信されることを意味します。 通信を暗号化するには:

    1. UseSSLtrue に設定し、本製品がSSL 暗号化を使用するように構成します。
    2. SSLServerCert およびSSLServerCertType を設定して、サーバー証明書をロードします。

    Apache Kafka への認証

    Apache Kafka データソースは、次の認証メソッドをサポートしています:

    • Anonymous
    • Plain
    • SCRAM ログインモジュール
    • SSL クライアント証明書
    • Kerberos

    Anonymous

    Apache Kafka の特定のオンプレミスデプロイメントでは、認証接続プロパティを設定することなくApache Kafka に接続できます。 こうした接続はanonymous(匿名)と呼ばれます。

    匿名認証を行うには、このプロパティを設定します。

    • AuthSchemeNone

    その他の認証方法については、ヘルプドキュメントを参照してください。

    Connection properties in the Configure Data Source Connection dialog. (Salesforce is shown.)
  5. ダッシュボードに追加したいテーブルを選択します。この例ではSampleTable_1 を使います。SQL クエリも指定できます。ドライバーは標準SQL シンタックスをサポートしています。 Tables and columns selected in the tree or specified by an SQL query. (Salesforce is shown.)
  6. リアルタイムデータを使いたい場合は、[Keep Data Table External]オプションをクリックします。このオプションは、データの変更をリアルタイムでダッシュボードに反映します。

    データをメモリにロードしてローカルで処理したい場合は、[Import Data Table]オプションをクリックします。このオプションは、オフラインでの使用、またはスローなネットワーク接続によりダッシュボードがインタラクティブでない場合に使用します。

  7. テーブルを追加すると[Recommended Visualizations]ウィザードが表示されます。テーブルを選択すると、Spotfire はカラムのデータ型を使ってnumber、time、category カラムを検出します。この例ではNumbers セクションでColumn1 を、Categories セクションでId を使用しています。Recommended visualizations for the imported data table. (Salesforce is shown.)

[Recommended Visualizations]ウィザードでいくつかビジュアライズしたら、ダッシュボードにその他の修正を加えられます。例えば、ページにフィルタを適用することで、高確率なopportunities にズームインできます。フィルタを追加するには、[Filter]ボタンをクリックします。各クエリで利用可能なフィルタは、[Filters]ペインに表示されます。

A simple dashboard with a global filter. (Salesforce is shown.)

関連コンテンツ

トライアル・お問い合わせ

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