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

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

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

注意

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

必要條件

開始之前，您必須取得具有參與者或更高許可權的網狀架構進階工作區的存取權。

注意

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

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

1. 建立新的 eventstream：

   1. 在 [ 首頁] 頁面上，選取 [Eventstream]。

   2. 在 [ 新增事件串流 ] 對話框中，輸入名稱，確定 已選取 [增強功能][預覽] 選項，然後選取 [ 建立]。

      

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

   

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

   

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

   

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

   

取得 [詳細數據] 窗格上的端點詳細數據以傳送事件

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

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

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

金鑰 提供連接金鑰的相關信息。 範例程式代碼會提供範例程序代碼 ，其中包含內嵌的對應索引鍵，可用來將事件串流至事件串流。 這些頁面上的資訊會因通訊協議而異。

事件中樞

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

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

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

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

[事件中樞] 索引標籤上的 [範例代碼] 頁面提供現成可用的程序代碼，其中包含事件中樞中聯機密鑰的必要資訊。 只要將它複製並貼到您的應用程式以供使用。

Kafka

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

Kafka 索引標籤上的 [範例代碼] 頁面提供現成的程式代碼，包括 Kafka 格式的必要連線密鑰。 只要複製它以供您使用。

AMQP

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

AMQP 索引標籤上的 [範例代碼] 頁面會以 AMQP 格式提供現成可用的程式代碼與連線金鑰資訊。

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

相關內容

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

• Amazon Kinesis 資料流
• Azure Blob 儲存體事件
• Azure Cosmos DB
• Azure 事件中樞
• Azure IoT 中樞
• Azure SQL 資料庫異動資料擷取 (CDC)
• Confluent Kafka
• Fabric 工作區事件
• Google Cloud Pub/Sub
• MySQL 資料庫 CDC
• PostgreSQL 資料庫 CDC
• 範例資料

必要條件

開始之前，您必須取得具有事件串流所在之參與者或更高許可權的進階工作區的存取權。

注意

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

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

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

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

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

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

   

取得 [詳細數據] 窗格上的端點詳細數據以傳送事件

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

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

[基本 ] 會顯示自訂應用程式的名稱、類型和狀態。

金鑰 提供連接金鑰的相關信息。 範例程式代碼會提供範例程序代碼 ，其中包含內嵌的對應索引鍵，可用來將事件串流至事件串流。 這些頁面上的資訊會因通訊協議而異。

事件中樞

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

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

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

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

[事件中樞] 索引標籤上的 [範例代碼] 頁面提供現成可用的程序代碼，其中包含事件中樞中聯機密鑰的必要資訊。 只要將它複製並貼到您的應用程式以供使用。

Kafka

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

Kafka 索引標籤上的 [範例代碼] 頁面提供現成的程式代碼，包括 Kafka 格式的必要連線密鑰。 只要複製它以供您使用。

AMQP

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

AMQP 索引標籤上的 [範例代碼] 頁面會以 AMQP 格式提供現成可用的程式代碼與連線金鑰資訊。

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

相關內容

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

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