Azure EventHub, LogicApp 및 DataVerse

Kafka 메시지는 Microsoft Cloud for Financial Services(FSI)로 내보내고 가져올 수 있습니다. 통합 고객 프로필과 같은 다양한 구성 요소를 제공하여 고객 데이터를 관리하고 개인 식별 정보(PII) 데이터를 저장하는 데 사용할 수 있습니다. 연결할 수 있습니다. Kafka에서 Azure EventHub로 데이터가 흐르는 경우 LogicApp을 사용하여 데이터를 DataVerse에 추가로 동기화합니다. FSI는 아래 다이어그램과 같이 사용할 수 있습니다.



이 연결을 설정하려면 아래 단계를 따르십시오.

Azure EventHub에 이벤트를 보냅니다.

예를 들어 아래의 Python 스크립트는 Azure EventHub에 세 가지 간단한 이벤트 메시지를 보내는 데 사용할 수 있습니다.

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

EVENTHUB_NAME = "REPLACE_WITH_EVENTHUB_NAME"
CONNECTION_STR = "Endpoint=sb://REPLEASE_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):
    # Without specifying partition_id or partition_key
    # the events will be distributed to available partitions via round-robin.
    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("Send messages in {} seconds.".format(time.time() - start_time))

이벤트 허브 이름 및 연결 문자열의 자리 표시자를 바꿉니다. 메시지가 성공적으로 전송되면 1.730254888534546초 후에 메시지 보내기와 같은 메시지가 표시됩니다.

"Authentication Put-Token failed."오류가 발생하는 경우 재시도 소진", 자리 표시자 값을 다시 확인하고 올바른지 확인합니다.

Azure Eventhub에서 LogicApp으로

Azure Portal로 이동하여 LogicApp을 검색하고 새로 만듭니다. EventHub 이벤트를 트리거로, DataVerse를 출력으로 하는 자동화된 워크플로로 사용할 수 있습니다. 웹 양식을 작성하여 논리 앱을 만듭니다. 초급 개발 목적에 가장 적합한 계획 유형을 소비로 선택할 수 있습니다.



LogicApp이 생성되면 Logic app 디자이너용 개발 도구로 이동합니다. 우리는 그 과정에서 세 단계를 만들 것입니다.

2.1 EventHub 트리거
워크플로의 첫 번째 단계에서는 트리거로 EventHub에 연결합니다. 개발 목적으로 항목 확인 시간을 3초로 줄이십시오. UI에 따라 기존 EventHub 이름을 선택하고 아래에 표시된 예와 연결합니다.



2.2. 변수 초기화
다음 단계에서는 이벤트 허브 메시지를 구문 분석합니다. 위에서 보낸 예시 메시지는 다음과 같습니다.

{
    "id": "something"
}

"id"키를 사용하여 값을 가져오려는 경우 표현식을 통해 수행할 수 있습니다.

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

2.3 Data Verse에 행 추가
마지막으로 세 번째 단계는 데이터베이스 커넥터를 사용하는 것입니다. 해당 Dataverse 테이블에 연결하여 새 행을 추가할 수 있습니다. 아직 테이블이 없으면 https://make.powerapps.com/으로 이동하여 Dataverse, Tables를 선택하여 테이블을 생성합니다. 해당 필드는 2단계 초기화 변수를 사용하여 채울 수 있습니다.



완료되면 워크플로의 저장을 클릭합니다.

3.데이터버스

Dataverse는 테이블로 데이터를 저장하기 위한 데이터베이스입니다. 새 이벤트가 추가될 때 LogicApp이 성공적으로 트리거되면 DataVerse 테이블에 새 행이 추가되는 것을 볼 수 있습니다.



마지막으로 모든 Vault 데이터가 Azure FSI에 동기화되면 통합 고객 프로필과 같은 구성 요소가 이를 사용하여 고객 데이터를 관리할 수 있습니다.

계정 자격 증명을 사용하여 Microsoft 클라우드 솔루션 센터https://solutions.microsoft.com/로 이동하여 구성 요소를 선택합니다.



Dynamic 365 샌드박스를 시작하려면 솔루션 센터를 탐색하고 "시작"버튼을 클릭하십시오.



다음과 같이 통합 고객 프로필 앱에 대해 채워진 샘플 데이터가 있습니다.



이 문제를 설정하는 데 질문이 있으면 알려주세요. 건배.