Visual Studio でチャートコントロールと Kafka をデータバインド

データバインドによって、UI コントロールからデータに接続できます。 CData ADO.NET Provider for ApacheKafka を使って、Visual Studio 上でWindows Forms およびWeb Forms とKafka をデータバインドできます。この記事で、Kafka を、ウィザードから変更をリアルタイムで反映するチャートにデータバインドする方法を説明します。 Code Walk-through セクションではチャートはほんの10行のコードで作成します。

チャートへのデータバインド

データバインドは３つのステップから構成されます。コントロールのインスタンス作成、データソースの設定、最後にデータバインドです。

接続を設定してデータベースオブジェクトを選択

下の手続きにより、データソース構成ウィザードを使ってチャートコントロールとKafka との接続を作成します。ウィザード上でデータバインドをするKafka エンティティを使います。

1. Windows Forms プロジェクトでは、チャートコントロールをツールボックスからフォーム上にドラグ＆ドロップします。チャートプロパティのデータセクションで DataSource を選択し、メニューからプロジェクトデータソースの追加を選択します。
2. 出てくるデータソース構成ウィザードでデータベース -> データセットを選択します。
3. データ接続ステップで、「新しい接続」をクリックします。

4. データ接続の選択ダイアログで、「変更」をクリックして、CData Kafka のデータソースを選択して、接続プロパティを入力します。下は代表的な接続文字列ですです。:

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

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

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

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

   デフォルトでは、CData 製品はデータソースとPLAINTEXT で通信しており、これはすべてのデータが暗号化なしで送信されることを意味します。 通信を暗号化したい場合は、以下の設定を行ってください：

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

   Apache Kafka への認証

   続いて、認証方法を設定しましょう。Apache Kafka データソースでは、以下の認証方法をサポートしています：

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

   Anonymous 認証

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

   匿名認証を行うには、以下のプロパティを設定してください。

   • AuthScheme：None

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


5. 使用するデータソースオブジェクトを選択します。例は SampleTable_1 テーブルです。

DataBind

データソースの追加とデータベースオブジェクトを選択したら、チャートにオブジェクトをバインドします。この例では、X軸に Id をY軸に Column1 を設定します。

1. チャートプロパティで、Series プロパティをクリックし、Series コレクション エディター を開きます。
2. Series プロパティでX軸、Y軸に設定するカラムを選択します：XValueMember および YValueMember プロパティにメニューからカラムを選びます。

チャートはこれでKafka にデータバインドされました。チャートを実行して最新のデータを表示させましょう。

コード Walk-through

Kafka へのデータバインドはほんの数行のコードのみが必要で、３つの簡単なステップで完了できます。

1. Kafka に接続します。
2. ApacheKafkaDataAdapter を作成して、クエリを作成し、結果を入れるデータセットを作成します。
3. 結果セットとチャートをデータバインドします。

下に完全なコードを示します:

ApacheKafkaConnection conn = new ApacheKafkaConnection("User=admin;Password=pass;BootStrapServers=https://localhost:9091;Topic=MyTopic;");
ApacheKafkaCommand comm = new ApacheKafkaCommand("SELECT Id, Column1 FROM SampleTable_1 WHERE Column2 = '100'", conn);
ApacheKafkaDataAdapter da = new ApacheKafkaDataAdapter(comm);
DataSet dataset = new DataSet();
da.Fill(dataset);

chart1.DataSource = dataset;
chart1.Series[0].XValueMember = "Id";
chart1.Series[0].YValueMembers = "Column1";
// Insert code for additional chart formatting here.
chart1.DataBind();