將自定義端點來源新增至 eventstream

如果您想要將自己的應用程式與 eventstream 連線，您可以新增自訂端點（也就是標準功能中的自定義應用程式）來源。 然後，您可以使用顯示為自訂端點的連接端點，從自己的應用程式將數據傳送至事件串流（也就是標準功能的自定義應用程式）。 本文說明如何將自定義端點（亦即標準功能的自定義應用程式）來源新增至事件串流。

注意

如果您想要使用處於預覽狀態的增強功能，請選取 頂端的 [增強功能 ]。 否則，請選取 [ 標準功能]。 如需預覽中增強功能的相關信息，請參閱 Fabric 事件串流簡介。

必要條件

• 具有參與者或更高許可權的網狀架構進階工作區存取權。

重要

Fabric 事件數據流的增強功能目前為預覽狀態。

注意

一個事件數據流的來源和目的地數目上限為 11。

將自訂端點數據新增為來源

請遵循下列步驟來新增自訂端點來源：

1. 若要建立新的事件串流，請從 [首頁] 畫面選取 [Eventstream]。 請確定 [增強功能][預覽] 選項已啟用。

   

2. 若要新增自定義端點來源，請在 [開始使用] 頁面上，選取 [ 使用自定義端點]。

   

   或者，如果您已經有已發佈的事件串流，而且想要將自定義端點數據新增為來源，請切換至 [編輯 ] 模式。 然後選取 功能區中的 [新增來源 ]，然後選取 [ 自定義端點]。

   

3. 在 [ 自定義端點 ] 畫面上，於 [來源名稱] 下 輸入自定義來源的名稱，然後選取 [ 新增]。

   

4. 建立自訂端點來源之後，您會在 [編輯] 模式的畫布上看到它已新增至您的事件串流。 若要實作這個新增的自定義應用程式源數據，請選取 [ 發佈]。

   

完成這些步驟之後，自定義端點數據就可用於即時檢視中的視覺效果。

取得 連接字串和範例程序代碼

在 [即時檢視 詳細數據 ] 窗格中，您可以看到三個類別： 基本、 索引鍵和 範例程序代碼。 您也可以從三個通訊協定索引標籤中選取： 事件中樞、 AMQP 和 Kafka。 金鑰和範例程式代碼資訊會因通訊協定而異。

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

金鑰會顯示自訂端點的 連接字串，您可以複製並貼到您的應用程式中。

連接字串 是事件中樞相容的字串，您可以在應用程式中用來接收來自這個事件數據流的事件。 事件中樞格式是 連接字串的預設格式，且與 Azure 事件中樞 SDK 相容。 您可以使用此格式，透過事件中樞通訊協定連線到事件串流。

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

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

範例程式代碼示範範例程式代碼 ，您可以參考或複製並貼到您的應用程式中，以推送或提取事件數據到這個事件數據流或從中提取。

除了事件中樞以外，您可以在 [詳細數據] 窗格中選取的其他兩個通訊協定格式索引標籤是AMQP和 Kafka。

• AMQP 格式與AMQP 1.0通訊協定相容，這是支援不同平臺和語言之間互操作性的標準傳訊通訊協定。 您可以使用這個格式來使用 AMQP 通訊協定連線到事件數據流。

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

您可以選擇符合應用程式需求和喜好設定的通訊協定格式。 在 [ 詳細數據 ] 窗格中選取這些索引標籤，以取得自定義 的密鑰 和 範例程式代碼。 將 [金鑰] 區段的 連接字串 複製並貼到您的應用程式中。 請參閱或複製所提供的範例程式代碼，以使用不同的通訊協議來傳送或接收事件。

相關內容

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

• Amazon Kinesis 數據流
• Azure Blob 儲存體 事件
• Azure Cosmos DB
• Azure 事件中樞
• Azure IoT 中樞
• Azure SQL 資料庫 異動數據擷取 （CDC）
• Confluent Kafka
• 網狀架構工作區事件 
• Google Cloud Pub/Sub
• 我的 SQL 資料庫 CDC
• Postgre SQL 資料庫 CDC
• 範例資料

必要條件

開始之前，您必須完成下列必要條件：

• 取得具有事件串流所在之參與者或更高許可權的進階工作區的存取權。

注意

一個事件數據流的來源和目的地數目上限為 11。

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

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

1. 在主編輯器畫布中選取功能區或 “+” 上的 [新增來源]，然後選取 [自定義應用程式]。

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

   

3. 成功建立自訂應用程式來源之後，您可以在下方窗格中的 [詳細數據] 索引標籤中切換並檢視下列資訊：

   

   • 基本：顯示自定義應用程式的名稱、描述、類型和狀態。
   • 機碼：顯示自定義應用程式的 連接字串，您可以複製並貼到您的應用程式中。
   • 範例程式代碼：顯示範例程式代碼，您可以參考或複製此程式碼，以將事件數據推送至此事件數據流，或從這個事件數據流提取事件數據。

   針對每個索引標籤 （基本 / 金鑰 / 範例程式代碼），您也可以切換三個通訊協定索引標籤：Eventhub、AMQP 和 Kafka，以存取不同的通訊協定格式資訊：

   連接字串 是與事件中樞相容的 連接字串，您可以在應用程式中使用它從事件串流接收事件。 連接字串 具有多種通訊協定格式，您可以在 [金鑰] 索引標籤中切換並選取。下列範例顯示事件中樞格式 連接字串 的外觀：

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

   事件中樞格式是 連接字串的預設格式，且與 Azure 事件中樞 SDK 相容。 您可以使用此格式，使用事件中樞通訊協定連線到事件串流。

   

   其他兩種通訊協定格式是 AMQP 和 Kafka，您可以按下 [金鑰] 索引標籤中的對應索引標籤來選取。

   AMQP 格式與AMQP 1.0通訊協定相容，這是支援不同平臺與語言之間互操作性的標準傳訊通訊協定。 您可以使用此格式，使用AMQP通訊協定連線到事件串流。

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

   您可以選擇符合應用程式需求和喜好設定的通訊協定格式，並將 連接字串 複製並貼到您的應用程式中。 您也可以參考或複製我們在 [範例程序代碼] 索引標籤中提供的範例程式代碼，其中顯示如何使用不同的通訊協定傳送或接收事件。

相關內容

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

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