Azure EventHub，Logic Apps，以及DataVerse
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的訊息。範例訊息是：
要使用key“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”按鈕。統一客戶資料應用將顯示填充的示例數據。
如果您對設置此內容有任何問題，請隨時聯絡我。乾杯。
