SAP レプリケーション フローを使用して SAP Datasphere データを Eventstream Kafka エンドポイントにレプリケートする

このチュートリアルでは、SAP Datasphere Replication Flow を使用して、SAP Datasphere から Eventstream のソース カスタム エンドポイントにある Kafka エンドポイントにデータをレプリケートする方法について説明します。 Eventstream に到着したデータは、アラート、レポート、または Fabric のさらに処理または分析のさまざまな宛先にルーティングするために使用できます。

このチュートリアルでは、次のことを行います。

[前提条件]

• Eventstream が配置されている共同作成者以上のアクセス許可を持つワークスペースへのアクセス権を取得します。
• "Premium Outbound" がサポートされている SAP Datasphere アカウント。

イベントストリームを作成する

1. Fabric ポータルに移動します。

2. 左側のナビゲーション バーで [ マイ ワークスペース ] を選択します。

3. [ マイ ワークスペース ] ページで、コマンド バーの [ + 新しい項目 ] を選択します。

4. [新しい項目] ページで [Eventstream] を検索し、[Eventstream] を選択します。

   

5. [新しいイベントストリーム] ウィンドウで、イベントストリームの [名前] を入力し、[作成] を選択します。

   

6. ワークスペースで新しいイベントストリームを作成するには、数秒かかることがあります。 イベント ストリームが作成されると、メイン エディターに移動し、イベント ストリームへのソースの追加を開始できます。

   

追加されたカスタム エンドポイント ソースから Kafka エンドポイント情報を取得する

イベントストリームから Kafka トピック エンドポイント情報を取得するには、カスタム エンドポイント ソースを eventstream に追加します。 その後、Kafka 接続エンドポイントがすぐに使用でき、カスタム エンドポイント ソース内で公開されます。

1. カスタム エンドポイント ソースを追加するには、開始ページで、「カスタム エンドポイントを使用 」を選択します。

   

2. [カスタム エンドポイント] ダイアログで、[ソース名] にカスタム ソースの名前を入力し、[追加] を選択します。

   

3. カスタム エンドポイント ソースを作成すると、編集モードでキャンバス上の eventstream に追加されます。 新しく追加されたカスタム エンドポイント ソースを有効にするには、[発行] を選択 します。

   

4. イベントストリームを正常に発行したら、後で SAP Datasphere で Kafka 接続を構成するために必要な Kafka エンドポイントに関する詳細情報を取得できます。

   キャンバス上のカスタム エンドポイント ソース タイルを選択します。 次に、カスタム エンドポイント ソース ノードの下部ウィンドウで、[ Kafka ] タブを選択します。 [SAS キー認証 ] ページでは、次の重要な Kafka エンドポイント情報を取得できます。

   • ブートストラップ サーバー
   • トピック名
   • 接続文字列 (プライマリまたはセカンダリ)
   • セキュリティ プロトコル = SASL_SSL
   • SASL メカニズム = PLAIN

   

   この情報は、SAP Datasphere Kafka 接続を構成するときに、次の手順で使用されます。

SAP Datasphere で Kafka 接続を作成する

SAP Datasphere でレプリケーション フローを定義するには、最初に Eventstream のカスタム エンドポイント ソースからの Kafka エンドポイント情報を使用して Kafka 接続を作成する必要があります。

1. SAP Datasphere 領域の [接続管理] タブで、接続作成ウィザードで Apache Kafka 接続の種類を選択します。

   

2. ウィザードの 2 番目の手順で、Eventstream のカスタム エンドポイント ソースからの Kafka 情報を使用して接続プロパティを構成します。

   • Kafka Brokers: Eventstream のソース カスタム エンドポイントの ブートストラップ サーバー です。
   • 認証の種類: [ユーザー名とパスワード] を選択します。
   • Kafka SASL ユーザー名: 定数値 "$ConnectionString" を使用します。
   • Kafka SASL パスワード: Eventstream のソース カスタム エンドポイントの 接続文字列-主キー 値または 接続文字列-セカンダリ キー 値のいずれかを指定できます。
   • レプリケーション フロー: "有効"。

   必要なすべての情報を入力した後に作成されたこの新しい Kafka 接続を取得するには、[ 保存] を選択します 。

   

Kafka 接続をターゲットとして使用してレプリケーション フローを作成する

レプリケーション フローを使用すると、SAP のソースからターゲットにデータをレプリケートできます。 Kafka 接続は、レプリケーション フローでサポートされているターゲットの 1 つです。 レプリケーション フローの詳細については、「レプリケーション フローの作成 」 を参照してください。SAP ヘルプ ポータル。

Kafka 接続ターゲットを使用してレプリケーション フローを作成するには、次の手順に従います。

1. 左側のナビゲーションで [データ ビルダー ] を選択し、[ 新しいレプリケーション フロー ] を選択してエディターを開きます。

   

2. ソース接続とソース コンテナーを選択し、ソース オブジェクトを追加します。 サポートされているソース オブジェクトは、 レプリケーション フローの作成 |SAP ヘルプ ポータル。

   

3. ターゲット構成で、前の手順で作成した Kafka 接続をターゲット接続として選択します。

   

4. 重要: 既定では、ターゲット オブジェクト名はソース オブジェクト名に従って自動的に割り当てられます。 ターゲット オブジェクト名は、ソース オブジェクトからデータを作成して受信する Kafka トピックの名前です。 Eventstream のデータを受信するための Kafka トピックは既に存在するため、 Eventstream のソース カスタム エンドポイントに表示される 'トピック名' にターゲット オブジェクト名の名前を変更することが重要です。

   

   注

   ターゲット オブジェクト設定で [読み込む前にすべて削除] を選択しないでください。 この設定が選択されている場合は、"次のエラーが発生したためターゲットセットアップに失敗しました: トピックを削除できませんでした: kafka サーバー: クライアントがこのトピックにアクセスする権限がありません。 CorrelationId: xxxx.".

   

レプリケーション フローのデプロイとアクティブ化

レプリケーション フローは、適切なソース オブジェクトとターゲット オブジェクトを使用して作成および構成された後、リボンのコマンド ボタンを使用してデプロイおよびアクティブ化できます。 SAP Datasphere の監視環境で状態を確認できます。

Eventstream を介してエンドツーエンドのフローを確認して、データが受信されているかどうかを確認できるようになりました。 Fabric ポータルで eventstream を開き、イベントストリームに存在するデータをプレビューするために、イベントストリームの名前を表示する中央ノードとして表示される既定のストリーム ノードを選択します。

関連コンテンツ

このチュートリアルでは、レプリケーション フローを使用して、Eventstream のソース カスタム エンドポイントを介して SAP Datasphere から eventstream にデータを転送する方法について説明しました。 データが eventstream に到達したら、それを処理し、分析、アラート、レポートのためにさまざまな宛先にルーティングできます。 以下は、さらに参照するために役立つリソースです。

• Microsoft Fabric Eventstreams の概要
• イベントストリームの送信先を追加および管理する
• イベント処理エディターを使用してイベント データを処理する
• SQL 演算子を使用してイベントを処理する