// Azure Event Hubs를 사용하여 데이터를 스트리밍하는 예시
using Microsoft.Azure.EventHubs;
using Microsoft.Azure.EventHubs.Processor;

// Event Hub 연결 문자열
string eventHubsConnectionString = "<your_event_hubs_connection_string>";
string eventHubName = "<your_event_hub_name>";
string storageConnectionString = "<your_storage_connection_string>";
string storageContainerName = "<your_storage_container_name>";

// Event Processor Host 설정
var eventProcessorHost = new EventProcessorHost(
    eventHubName,
    PartitionReceiver.DefaultConsumerGroupName,
    eventHubsConnectionString,
    storageConnectionString,
    storageContainerName);

// 데이터 처리를 위한 이벤트 핸들러 등록
eventProcessorHost.RegisterEventProcessorAsync<SimpleEventProcessor>();

// 데이터 수신 및 처리를 위한 이벤트 핸들러
public class SimpleEventProcessor : IEventProcessor
{
    public Task OpenAsync(PartitionContext context)
    {
        // 연결된 파티션에서 데이터 수신을 시작
        return Task.CompletedTask;
    }

    public async Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)
    {
        // 수신한 데이터를 처리
        foreach (EventData eventData in messages)
        {
            string data = Encoding.UTF8.GetString(eventData.Body.Array);
            Console.WriteLine($"수신된 데이터: '{data}'");
        }

        // 처리가 완료된 데이터의 오프셋을 저장
        await context.CheckpointAsync();
    }

    // 기타 필요한 메서드 구현
}

// 데이터 수신 및 처리 시작
await eventProcessorHost.UnregisterEventProcessorAsync();