將自訂端點或自訂應用程式來源新增至事件串流

如果您想要將自己的應用程式與 eventstream 連線，您可以將自訂端點或自定義應用程式新增為來源。 然後，您可以使用自定義應用程式或自定義端點上公開的連接端點，將即時事件從您自己的應用程式傳送至事件流。 此外，您可以使用 Apache Kafka 通訊協定作為自定義端點或自定義應用程式的選項，使用 Apache Kafka 通訊協定來傳送即時事件。

本文說明如何在 Microsoft fabric 事件數據流中，將自定義端點來源或自定義應用程式來源新增至 eventstream。

注意

當您立即建立 Eventstream 時，預設會啟用增強功能。 如果您有使用標準功能建立的事件串流，這些事件串流將會繼續運作。 您仍然可以像往常一樣編輯並使用它們。 建議您建立新的 Eventstream 來取代標準事件串流，以便利用增強事件串流的其他功能和優點。

必要條件

開始之前，請確定您可以存取事件串流所在的工作區。 工作區必須處於 Fabric 系統容量 或 試用版 模式。

• 要編輯事件流以新增自定義端點來源，需具備參與者或更高的權限。
• 如果您想要使用 Entra ID 驗證 來連線應用程式，則需要 Member 或更高的許可權。

如果您使用 Entra ID 驗證，您也必須確定自定義端點的受控識別具有必要的許可權。 若要這樣做，請在 管理入口網站中設定必要的設定：

1. 選取右上角的 [設定 ] （齒輪圖示）。

2. 選取 管理後台 在 治理與深入解析 區段底下。

   

3. 啟用下列租用戶設定，將網狀架構 API 的存取權授與服務主體，以建立工作區、連線或部署管線：

   • 在 [ 租用戶設定 ] 頁面上的 [ 開發人員設定 ] 區段中，展開 [服務主體可以使用網狀架構 API] 選項。
   • 切換至 [已啟用]。
   • 套用至 整個組織。
   • 選取 ，然後套用。

   

4. 啟用此選項以存取所有其他 API（預設為新租使用者啟用）：

   • 仍在 [ 承租人設定 ] 頁面上，展開 [ 允許服務主體建立和使用設定檔 ] 選項。
   • 切換至 [已啟用]。
   • 套用至 整個組織。
   • 選取 ，然後套用。

注意

一個 Eventstream 的來源和目的地數目上限為 11。

將自訂端點資料新增為來源

1. 若要新增自定義端點來源，請在 [開始使用] 頁面上，選取 [ 使用自定義端點]。 或者，如果您已經有已發佈的事件串流，而且想要將自定義端點數據新增為來源，請切換至編輯模式。 在功能區上，選取 新增來源>自訂端點。

   

2. 在 [ 自定義端點] 對話框中，於 [來源名稱] 下 輸入自定義來源的名稱，然後選取 [ 新增]。

   

3. 在您建立自訂端點來源之後，它將被新增至編輯模式下的畫布上的事件流中。 若要從自定義應用程式來源實作新加入的數據，請選取 [ 發佈]。

   

注意

一個 Eventstream 的來源和目的地數目上限為 11。

在 [詳細數據] 窗格上取得端點詳細數據

建立自定義端點來源之後，其數據就可用於即時檢視中的視覺效果。

[ 詳細數據 ] 窗格有三個通訊協定索引標籤： 事件中樞、 AMQP 和 Kafka。 每個通訊協定索引標籤都有三個頁面： 基本 和 SAS 金鑰驗證。 這些頁面會提供端點詳細數據，以及用於連線的對應通訊協定。

[基本 ] 會顯示您自定義端點的名稱、類型和狀態。

SAS 金鑰驗證頁面提供連線金鑰的相關信息，以及範例程式代碼的連結，內嵌對應的金鑰，可用來將事件串流至事件串流。 [金鑰] 頁面上的資訊會因通訊協定而異。

事件中樞

在 事件中樞 索引標籤上的 SAS 金鑰驗證 頁面包含與事件中樞的連接字串相關的資訊。 此資訊包括事件中樞名稱、共用存取金鑰名稱、主要金鑰、次要金鑰、連接字串-主要金鑰、連接字串-次要金鑰。

事件中樞格式是 連接字串的預設值，且適用於 Azure 事件中樞 SDK。 此格式可讓您透過事件中樞通訊協定連線到事件串流。

下列範例顯示事件中樞格式 連接字串 的外觀：

Endpoint=sb：//eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

如果您選取 [ 顯示範例程式代碼 ] 按鈕，您會看到現成可用的 Java 程式代碼，其中包含事件中樞中連線金鑰的必要資訊。 複製並貼到您的應用程式以供使用。

進階訊息佇列通訊協定 (AMQP)

AMQP 格式與AMQP 1.0通訊協定相容，這是支援各種平臺和語言之間互操作性的標準傳訊通訊協定。 您可以使用這個格式，透過AMQP通訊協定連線到您的事件資料流。

當您選取 [ 顯示範例程式代碼 ] 按鈕時，您會看到現成可用的 Java 程式代碼與 AMQP 格式的連接金鑰資訊。

卡 夫 卡

Kafka 格式與 Apache Kafka 通訊協定相容，這是支援高輸送量和低延遲數據處理的熱門分散式串流平臺。 您可以使用 Kafka 通訊協定格式的 SAS 金鑰驗證 資訊，連線到您的事件串流並串流事件。

當您選取 [ 顯示範例程式代碼 ] 按鈕時，您會看到現成可用的 Java 程式代碼，包括 Kafka 格式的必要連線金鑰。 複製它以供您使用。

如需使用 Kafka 通訊協定和自定義端點的完整指南，請參閱此教學課程 。 它提供使用自定義端點搭配 Kafka 通訊協定串流和取用事件的詳細步驟。

注意

• 您可以選擇符合應用程式需求和喜好設定的通訊協定格式，然後將 連接字串 複製並貼到您的應用程式中。 您也可以參考或複製 範例程式代碼，示範如何使用各種通訊協定傳送或接收事件。

• 若要結束範例程式代碼檢視，請選取 [ 隱藏範例程序代碼]。

相關內容

如需支援的來源清單，請參閱 在 Eventstream 中新增事件來源

必要條件

• 在 Fabric 容量授權模式或試用版授權模式中，存取具有參與者或更高權限的工作區。
• 如果您沒有 eventstream， 請建立 eventstream。

將自訂應用程式新增為來源

如果您想要將自己的應用程式與 eventstream 連線，您可以新增自訂應用程式來源。 然後，使用自定義應用程式中公開的連接端點，從您自己的應用程式將數據傳送至 eventstream。

若要新增自訂應用程式來源：

1. 選取功能區上的新增來源，或主要編輯器創作區中的 + 號 (+)，然後選取自訂應用程式。

2. 在 [ 自定義應用程式 ] 窗格中，輸入自定義應用程式的來源名稱，然後選取 [ 新增]。

   

在 [詳細] 窗格中取得端點資訊以傳送事件

成功將自定義應用程式建立為來源之後，您可以在 [詳細數據] 窗格上檢視資訊。

[ 詳細數據 ] 窗格有三個通訊協定索引標籤： 事件中樞、 AMQP 和 Kafka。 每個通訊協定索引標籤都包含三個頁面： 基本、 SAS 金鑰驗證和 Entra ID 驗證。 這些頁面提供所選通訊協定特定的端點資訊。

• [ 基本] 頁面會顯示您自定義端點的名稱、類型和狀態。

• SAS 金鑰驗證 和 Entra ID 驗證 是連線到應用程式的兩種支援驗證方法：
  • SAS 金鑰驗證 提供使用共用存取簽章（SAS） 金鑰產生和使用 Eventstream 資料所需的資訊。
  • Entra ID Authentication 可讓安全性主體（例如使用者或服務主體）使用 Microsoft Entra ID 驗證來取用 Eventstream 數據。

如需使用 Entra ID 驗證的步驟，請參閱 在 Eventstream 中為應用程式啟用 Entra ID Authentication。
下一節說明如何使用 SAS 金鑰驗證連線到自定義端點目的地。

事件中樞

[事件中樞] 索引標籤上的 [金鑰] 頁面包含與事件中樞 連接字串 相關的資訊。 此資訊包括 事件中樞名稱、 共用存取金鑰名稱、 主鍵和 連接字串-主鍵。

事件中樞格式是 連接字串的預設值，且適用於 Azure 事件中樞 SDK。 此格式可讓您透過事件中樞通訊協定連線到事件串流。

下列範例顯示事件中樞格式 連接字串 的外觀：

Endpoint=sb：//eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

選取 [事件中樞] 頁面上的 [顯示範例程序代碼] 按鈕，以取得現成可用的程序代碼，其中包含事件中樞中聯機密鑰的必要資訊。 只要將它複製並貼到您的應用程式以供使用。

卡 夫 卡

Kafka 格式與 Apache Kafka 通訊協定相容，這是支援高輸送量和低延遲數據處理的熱門分散式串流平臺。 您可以使用 Kafka 通訊協定格式的金鑰 和 範例程式代碼 資訊，連線到您的事件串流並串流事件。

選取 [Kafka] 頁面上的 [顯示範例程式代碼] 按鈕，以取得現成的程式代碼，包括 Kafka 格式的必要連線密鑰。 只要複製它以供您使用。

AMQP（高級訊息佇列協定）

AMQP 格式與AMQP 1.0通訊協定相容，這是支援各種平臺和語言之間互操作性的標準傳訊通訊協定。 您可以使用這個格式，透過AMQP通訊協定連線到您的事件資料流。

選取 [AMQP] 頁面上的 [顯示範例程式代碼] 按鈕，以使用AMQP格式取得聯機密鑰資訊的現成程式代碼。

您可以選擇符合應用程式需求和喜好設定的通訊協定格式，然後將 連接字串 複製並貼到您的應用程式中。 您也可以參考或複製範例程式代碼頁面上的範例程序代碼，其中顯示如何使用各種通訊協定傳送或接收事件。

相關內容

若要瞭解如何將其他來源新增至事件串流，請參閱下列文章：

• Azure 事件中樞
• Azure IoT 中樞
• 範例資料