Azure Event Hubs는 대규모 이벤트 스트리밍을 처리하기 위한 고성능 이벤트 허브 서비스입니다. 이 서비스를 사용하면 실시간으로 데이터를 수집, 처리 및 저장할 수 있습니다. 파이썬은 이러한 이벤트 처리에 널리 사용되는 인기있는 프로그래밍 언어입니다. 이 글에서는 Azure Event Hubs를 파이썬에서 사용하는 방법을 알아보겠습니다.

1. Azure Event Hubs 설정

먼저 Azure Portal에 로그인하여 Event Hubs 인스턴스를 생성해야 합니다. Azure Portal의 “Event Hubs” 탭에서 “Event Hubs 네임스페이스”를 선택하고 새로운 네임스페이스를 생성합니다. 네임스페이스 생성이 완료되면 “Event Hubs” 섹션에 이벤트 허브 인스턴스를 추가합니다.

이벤트 허브 인스턴스를 생성한 후에는 Access Key를 가져와야 합니다. Event Hubs 인스턴스에 액세스하려면 이 Access Key가 필요합니다. Access Key는 Event Hubs 인스턴스의 “Shared access policies” 섹션에서 확인할 수 있습니다.

2. 파이썬 패키지 설치

Azure Event Hubs를 파이썬에서 사용하려면 azure-eventhub 패키지를 설치해야 합니다. 다음 명령을 사용하여 패키지를 설치할 수 있습니다:

pip install azure-eventhub

3. 이벤트 전송

이제 이벤트를 생성하고 Event Hubs로 전송하는 방법에 대해 알아보겠습니다. 다음은 간단한 예제 코드입니다:

from azure.eventhub import EventHubProducerClient, EventData

connection_str = "<Event Hubs 연결 문자열>"
eventhub_name = "<Event Hubs 이름>"

producer = EventHubProducerClient.from_connection_string(connection_str, eventhub_name=eventhub_name)

event_data = EventData("<전송할 이벤트 데이터>")

producer.send(event_data)

producer.close()

위의 코드 예제에서는 <Event Hubs 연결 문자열>과 <Event Hubs 이름>을 Event Hubs 인스턴스에 대한 실제 데이터로 대체해야 합니다. <전송할 이벤트 데이터>는 전송할 실제 이벤트 데이터로 대체해야 합니다.

4. 이벤트 수신

이벤트 허브에서 이벤트를 수신하려면 azure-eventhub 패키지를 사용하여 EventHubConsumerClient를 생성하고 이벤트를 수신하면 됩니다. 다음은 간단한 예제 코드입니다:

from azure.eventhub import EventHubConsumerClient

connection_str = "<Event Hubs 연결 문자열>"
eventhub_name = "<Event Hubs 이름>"

consumer = EventHubConsumerClient.from_connection_string(connection_str, eventhub_name=eventhub_name)

def on_event(partition_context, event):
    print("받은 이벤트:", event.body_as_str())

consumer.receive(on_event)

consumer.close()

위의 코드 예제에서도 <Event Hubs 연결 문자열>과 <Event Hubs 이름>을 실제 데이터로 대체해야 합니다.

5. 결론

Azure Event Hubs를 활용하여 파이썬으로 이벤트를 처리하는 방법에 대해 알아보았습니다. Azure Portal에서 Event Hubs 인스턴스를 설정하고, azure-eventhub 패키지를 설치하여 이벤트를 전송하고 수신할 수 있습니다. 이를 활용하여 실시간 데이터 처리 및 데이터 파이프라인 구축에 유용하게 활용할 수 있습니다.

#azure #eventhubs