Kafka訊息可以從Microsoft Cloud for Financial Services (FSI）導出並導入到此雲端服務。這種雲端解決方案提供了各種組件，包括用於管理客戶數據的統一客戶資料。它還具有儲存個人可識別資訊（PII）的能力。數據可以從Kafka流向Azure EventHub，然後從那裡，Logic Apps可以將數據同步到DataVerse，FSI可以使用。下圖顯示了這一工作流程：

按照以下步驟設定此連接：

1. 向Azure EventHub發送事件

例如，您可以使用以下的Python代碼發送三個簡單的事件訊息到Azure EventHub。

import time
import os
import json
from azure.eventhub import EventHubProducerClient, EventData
from azure.eventhub.exceptions import EventHubError

# Replace placeholders with your EventHub name and connection string
EVENTHUB_NAME = "REPLACE_WITH_EVENTHUB_NAME"
CONNECTION_STR = "Endpoint=sb://REPLACE_WITH_CONNECTION_STRING.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=REPLACE_WITH_SHARED_ACCESS_KEY"

body = json.dumps({"id": "something"})

def send_event_data_batch(producer, i):
    event_data_batch = producer.create_batch()
    event_data_batch.add(EventData(body))
    producer.send_batch(event_data_batch)

producer = EventHubProducerClient.from_connection_string(
    conn_str=CONNECTION_STR,
    eventhub_name=EVENTHUB_NAME
)

start_time = time.time()
with producer:
    for i in range(3):
        send_event_data_batch(producer, i)

print("Sent messages in {} seconds.".format(time.time() - start_time))

替換EventHub名稱和連接字符串的佔位符。如果信息發送成功，您將看到類似於“在1.730254888534546秒內發送了信息。”的輸出。

如果您遇到“Authentication Put-Token failed. Retries exhausted.”錯誤，請再次檢查佔位符的值，確保它們是正確的。

2. 將Azure EventHub連接到Logic Apps

導航至Azure portal並搜索Logic Apps。創建一個新的自動化工作流程。EventHub的事件將作為觸發器，DataVerse將是輸出。選擇“Consumption”作為計劃類型，此為初級開發者適用。

創建Logic App後，轉到Development Tools並訪問Logic App designer。此過程涉及三個步驟：

2.1 EventHub触发器

首個步驟是將EventHub連接為觸發器。對於開發目的，請將檢查間隔設定為3秒。

2.2 初始化變量

下一步是解析來自EventHub的訊息。範例訊息是：

{
  "id": "something"
}

要使用key“id”提取值，您可以使用以下表達式：

json(decodeBase64(triggerBody()['ContentData']))['id']

2.3 向DataVerse添加一行

最後一步是使用數據庫連接器向對應DataVerse表添加一行新的資料。如果表還不存在，轉到https://make.powerapps.com/，選擇DataVerse，然後選擇Tables來創建一個。使用在步驟2中初始化的變量填充字段。

完成後，保存工作流程。

3. DataVerse

DataVerse作為一個數據庫，用於在表格中儲存資料。如果在添加新事件時成功觸發了Logic App，您將在DataVerse表中看到一行新的資料。

最後，一旦所有數據都同步到Azure FSI，您可以導航至Microsoft Cloud Solution Center在https://solutions.microsoft.com/選擇您希望使用的組件。例如，您可以選擇統一客戶資料來管理客戶數據。

要啟動Dynamics 365沙箱，導航至Solution Center並單擊“Launch”按鈕。統一客戶資料應用將顯示填充的示例數據。

如果您對設置此內容有任何問題，請隨時聯絡我。乾杯。