从EventProcessorHost中获取数据

using Microsoft.Azure.ServiceBus;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        string connectionString = "Endpoint=sb://<your-servicebus-namespace>.servicebus.windows.net/;SharedAccessKeyName=<your-key-name>;SharedAccessKey=<your-key>;EntityPath=<your-queue-name>";
        string queueName = "<your-queue-name>";

        var eventProcessorHost = new EventProcessorHost(
            "sample-host",
            queueName,
            new DefaultEventProcessorFactory(new MyEventProcessor()),
            connectionString);

        await eventProcessorHost.RegisterEventProcessorAsync();
        Console.WriteLine("Press enter to stop the Event Processor Host.");
        Console.ReadLine();

        await eventProcessorHost.UnregisterEventProcessorAsync();
    }
}

class MyEventProcessor : IEventProcessor
{
    public Task OpenAsync(PartitionContext context)
    {
        Console.WriteLine($"Partition {context.Lease.PartitionId} opened.");
        return Task.CompletedTask;
    }

    public Task CloseAsync(PartitionContext context, CancellationToken reason)
    {
        Console.WriteLine($"Partition {context.Lease.PartitionId} closed. Reason: {reason}");
        return Task.CompletedTask;
    }

    public Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)
    {
        foreach (var eventData in messages)
        {
            Console.WriteLine($"Received message with ID {eventData.MessageId} from partition {context.Lease.PartitionId}: {Encoding.UTF8.GetString(eventData.Body)}");
        }
        return context.CheckpointAsync();
    }
}