Snabbstart: Skicka händelser till och ta emot händelser från Azure Event Hubs med hjälp av .NET

Tilldela roller till din Microsoft Entra-användare

När du utvecklar lokalt kontrollerar du att användarkontot som ansluter till Azure Event Hubs har rätt behörigheter. Du behöver rollen Azure Event Hubs-dataägare för att kunna skicka och ta emot meddelanden. Om du vill tilldela dig själv den här rollen behöver du rollen Administratör för användaråtkomst eller en annan roll som innehåller åtgärden Microsoft.Authorization/roleAssignments/write . Du kan tilldela Azure RBAC-roller till en användare med hjälp av Azure-portalen, Azure CLI eller Azure PowerShell. Läs mer om tillgängliga omfång för rolltilldelningar på översiktssidan för omfång .

I följande exempel tilldelas Azure Event Hubs Data Owner rollen till ditt användarkonto, vilket ger fullständig åtkomst till Azure Event Hubs-resurser. I ett verkligt scenario följer du principen om lägsta behörighet för att ge användarna endast de minsta behörigheter som krävs för en säkrare produktionsmiljö.

Inbyggda Azure-roller för Azure Event Hubs

För Azure Event Hubs skyddas redan hanteringen av namnområden och alla relaterade resurser via Azure-portalen och AZURE-resurshanterings-API:et med hjälp av Azure RBAC-modellen. Azure tillhandahåller de inbyggda Azure-rollerna nedan för att auktorisera åtkomst till ett Event Hubs-namnområde:

• Azure Event Hubs-dataägare: Ger dataåtkomst till Event Hubs-namnområdet och dess entiteter (köer, ämnen, prenumerationer och filter)
• Azure Event Hubs Data Sender: Använd den här rollen för att ge avsändaren åtkomst till Event Hubs-namnområdet och dess entiteter.
• Azure Event Hubs-datamottagare: Använd den här rollen för att ge mottagaren åtkomst till Event Hubs-namnområdet och dess entiteter.

Om du vill skapa en anpassad roll läser du Rättigheter som krävs för Event Hubs-åtgärder.

az eventhubs namespace show -g '<your-event-hub-resource-group>' -n '<your-event-hub-name> --query id

az role assignment create --assignee "<user@domain>" \
--role "Azure Event Hubs Data Owner" \
--scope "<your-resource-id>"

Get-AzResource -ResourceGroupName "<your-event-hub-resource-group>" -Name "<your-event-hub-name>"

New-AzRoleAssignment -SignInName <user@domain> `
-RoleDefinitionName "Azure Event Hubs Data Owner" `
-Scope <yourResourceId>

Starta Visual Studio och logga in på Azure

Du kan auktorisera åtkomst till Service Bus-namnområdet med hjälp av följande steg:

1. Starta Visual Studio. Om du ser fönstret Kom igång väljer du länken Fortsätt utan kod i den högra rutan.

2. Välj knappen Logga in längst upp till höger i Visual Studio.

   

3. Logga in med det Microsoft Entra-konto som du tilldelade en roll till tidigare.

   

Hämta anslutningssträngen

När du skapar ett nytt namnområde genereras automatiskt en inledande SAS-princip (Signatur för delad åtkomst) med primära och sekundära nycklar och anslutningssträng som var och en ger fullständig kontroll över alla aspekter av namnområdet. Se Event Hubs-autentisering och auktorisering för information om hur du skapar regler med mer begränsade rättigheter för vanliga avsändare och mottagare.

En klient kan använda anslutningssträng för att ansluta till Event Hubs-namnområdet. Så här kopierar du den primära anslutningssträng för ditt namnområde:

1. På sidan Namnområde för händelsehubb väljer du Principer för delad åtkomst på den vänstra menyn.

2. På sidan Principer för delad åtkomst väljer du RootManageSharedAccessKey.

3. I fönstret Princip: RootManageSharedAccessKey väljer du kopieringsknappen bredvid Primär Anslut ionssträng för att kopiera anslutningssträng till Urklipp för senare användning. Klistra in det här värdet i Anteckningar eller på en tillfällig plats.

   

   Du kan använda den här sidan för att kopiera primärnyckel, sekundär nyckel, primär anslutningssträng och sekundär anslutningssträng.

1. Välj Verktyg>NuGet Package Manager Package Manager-konsolen> på menyn.

2. Kör följande kommandon för att installera Azure.Messaging.EventHubs - och Azure.Identity NuGet-paket. Tryck på RETUR för att köra det andra kommandot.

   Install-Package Azure.Messaging.EventHubs
   Install-Package Azure.Identity
   

1. Välj Verktyg>NuGet Package Manager Package Manager-konsolen> på menyn.

2. Kör följande kommando för att installera NuGet-paketet Azure.Messaging.EventHubs :

   Install-Package Azure.Messaging.EventHubs
   

1. Ersätt den befintliga koden i Program.cs filen med följande exempelkod. <EVENT_HUB_NAMESPACE> Ersätt sedan och <HUB_NAME> platshållarvärden för parametrarna EventHubProducerClient med namnen på eventhubbarnas namnområde och händelsehubben. Exempelvis: "spehubns0309.servicebus.windows.net" och "spehub".

   Här är de viktiga stegen i koden:

   1. Skapar ett EventHubProducerClient-objekt med namnområdet och händelsehubbens namn.
   2. Anropar metoden CreateBatchAsync på EventHubProducerClient-objektet för att skapa ett EventDataBatch-objekt .
   3. Lägg till händelser i batchen med metoden EventDataBatch.TryAdd .
   4. Skickar batchen med meddelanden till händelsehubben med metoden EventHubProducerClient.SendAsync .

   using Azure.Identity;
   using Azure.Messaging.EventHubs;
   using Azure.Messaging.EventHubs.Producer;
   using System.Text;
   
   // number of events to be sent to the event hub
   int numOfEvents = 3;
   
   // The Event Hubs client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when events are being published or read regularly.
   // TODO: Replace the <EVENT_HUB_NAMESPACE> and <HUB_NAME> placeholder values
   EventHubProducerClient producerClient = new EventHubProducerClient(
       "<EVENT_HUB_NAMESPACE>.servicebus.windows.net",
       "<HUB_NAME>",
       new DefaultAzureCredential());
   
   // Create a batch of events 
   using EventDataBatch eventBatch = await producerClient.CreateBatchAsync();
   
   for (int i = 1; i <= numOfEvents; i++)
   {
       if (!eventBatch.TryAdd(new EventData(Encoding.UTF8.GetBytes($"Event {i}"))))
       {
           // if it is too large for the batch
           throw new Exception($"Event {i} is too large for the batch and cannot be sent.");
       }
   }
   
   try
   {
       // Use the producer client to send the batch of events to the event hub
       await producerClient.SendAsync(eventBatch);
       Console.WriteLine($"A batch of {numOfEvents} events has been published.");
       Console.ReadLine();
   }
   finally
   {
       await producerClient.DisposeAsync();
   }
   

1. Ersätt den befintliga koden i Program.cs filen med följande exempelkod. Ersätt <CONNECTION_STRING> sedan platshållarvärdena och <HUB_NAME> för parametrarna EventHubProducerClient .

   Här är de viktiga stegen i koden:

   1. Skapar ett EventHubProducerClient-objekt med hjälp av den primära anslutningssträng till namnområdet och händelsehubbens namn.
   2. Anropar metoden CreateBatchAsync på EventHubProducerClient-objektet för att skapa ett EventDataBatch-objekt .
   3. Lägg till händelser i batchen med metoden EventDataBatch.TryAdd .
   4. Skickar batchen med meddelanden till händelsehubben med metoden EventHubProducerClient.SendAsync .

   using Azure.Messaging.EventHubs;
   using Azure.Messaging.EventHubs.Producer;
   using System.Text;
   
   // number of events to be sent to the event hub
   int numOfEvents = 3;
   
   // The Event Hubs client types are safe to cache and use as a singleton for the lifetime
   // of the application, which is best practice when events are being published or read regularly.
   // TODO: Replace the <CONNECTION_STRING> and <HUB_NAME> placeholder values
   EventHubProducerClient producerClient = new EventHubProducerClient(
       "<CONNECTION_STRING>",
       "<HUB_NAME>");
   
   // Create a batch of events 
   using EventDataBatch eventBatch = await producerClient.CreateBatchAsync();
   
   for (int i = 1; i <= numOfEvents; i++)
   {
       if (!eventBatch.TryAdd(new EventData(Encoding.UTF8.GetBytes($"Event {i}"))))
       {
           // if it is too large for the batch
           throw new Exception($"Event {i} is too large for the batch and cannot be sent.");
       }
   }
   
   try
   {
       // Use the producer client to send the batch of events to the event hub
       await producerClient.SendAsync(eventBatch);
       Console.WriteLine($"A batch of {numOfEvents} events has been published.");
       Console.ReadLine();
   }
   finally
   {
       await producerClient.DisposeAsync();
   }
   

När du utvecklar lokalt kontrollerar du att användarkontot som har åtkomst till blobdata har rätt behörigheter. Du behöver Storage Blob Data-deltagare för att läsa och skriva blobdata. Om du vill tilldela dig själv den här rollen måste du tilldelas rollen Administratör för användaråtkomst eller en annan roll som innehåller åtgärden Microsoft.Authorization/roleAssignments/write . Du kan tilldela Azure RBAC-roller till en användare med hjälp av Azure-portalen, Azure CLI eller Azure PowerShell. Du kan lära dig mer om tillgängliga omfång för rolltilldelningar på översiktssidan för omfång .

I det här scenariot tilldelar du behörigheter till ditt användarkonto, begränsat till lagringskontot, för att följa principen om lägsta behörighet. Den här metoden ger användarna endast de minsta behörigheter som krävs och skapar säkrare produktionsmiljöer.

I följande exempel tilldelas rollen Storage Blob Data Contributor till ditt användarkonto, vilket ger både läs- och skrivåtkomst till blobdata i ditt lagringskonto.

az storage account show --resource-group '<your-resource-group-name>' --name '<your-storage-account-name>' --query id

az role assignment create --assignee "<user@domain>" \
    --role "Storage Blob Data Contributor" \
    --scope "<your-resource-id>"

Get-AzResource -ResourceGroupName "<yourResourceGroupname>" -Name "<yourStorageAccountName>"

New-AzRoleAssignment -SignInName <user@domain> `
    -RoleDefinitionName "Storage Blob Data Contributor" `
    -Scope <yourStorageAccountId>

Hämta anslutningssträng till lagringskontot

Anteckna anslutningssträng och containernamnet. Du använder dem i koden för att ta emot händelser från händelsehubben.

1. Välj Verktyg>NuGet Package Manager Package Manager-konsolen> på menyn.

2. I fönstret Package Manager-konsolen bekräftar du att EventHubsReceiver har valts för standardprojektet. Om inte använder du listrutan för att välja EventHubsReceiver.

3. Kör följande kommando för att installera Azure.Messaging.EventHubs och Azure.Identity NuGet-paketen. Tryck på RETUR för att köra det sista kommandot.

   Install-Package Azure.Messaging.EventHubs
   Install-Package Azure.Messaging.EventHubs.Processor
   Install-Package Azure.Identity
   

1. Välj Verktyg>NuGet Package Manager Package Manager-konsolen> på menyn.

2. I fönstret Package Manager-konsolen bekräftar du att EventHubsReceiver har valts för standardprojektet. Om inte använder du listrutan för att välja EventHubsReceiver.

3. Kör följande kommando för att installera NuGet-paketet Azure.Messaging.EventHubs :

   Install-Package Azure.Messaging.EventHubs
   Install-Package Azure.Messaging.EventHubs.Processor
   

1. Ersätt den befintliga koden i Program.cs filen med följande exempelkod. <STORAGE_ACCOUNT_NAME> Ersätt sedan platshållarvärdena och <BLOB_CONTAINER_NAME> för URI:BlobContainerClientn. <EVENT_HUB_NAMESPACE> Ersätt platshållarvärdena och <HUB_NAME> för EventProcessorClient den också.

   Här är de viktiga stegen i koden:

   1. Skapar ett EventProcessorClient-objekt med Event Hubs-namnområdet och händelsehubbens namn. Du måste skapa BlobContainerClient-objektet för containern i Azure Storage som du skapade tidigare.
   2. Anger hanterare för ProcessEventAsync- och ProcessErrorAsync-händelserna för EventProcessorClient-objektet.
   3. Börjar bearbeta händelser genom att anropa StartProcessingAsync på EventProcessorClient-objektet .
   4. Slutar bearbeta händelser efter 30 sekunder genom att anropa StopProcessingAsync på EventProcessorClient-objektet .

   using Azure.Identity;
   using Azure.Messaging.EventHubs;
   using Azure.Messaging.EventHubs.Consumer;
   using Azure.Messaging.EventHubs.Processor;
   using Azure.Storage.Blobs;
   using System.Text;
   
   // Create a blob container client that the event processor will use
   // TODO: Replace <STORAGE_ACCOUNT_NAME> and <BLOB_CONTATINAER_NAME> with actual names
   BlobContainerClient storageClient = new BlobContainerClient(
       new Uri("https://<STORAGE_ACCOUNT_NAME>.blob.core.windows.net/<BLOB_CONTAINER_NAME>"),
       new DefaultAzureCredential());
   
   // Create an event processor client to process events in the event hub
   // TODO: Replace the <EVENT_HUBS_NAMESPACE> and <HUB_NAME> placeholder values
   var processor = new EventProcessorClient(
       storageClient,
       EventHubConsumerClient.DefaultConsumerGroupName,
       "<EVENT_HUB_NAMESPACE>.servicebus.windows.net",
       "<HUB_NAME>",
       new DefaultAzureCredential());
   
   // Register handlers for processing events and handling errors
   processor.ProcessEventAsync += ProcessEventHandler;
   processor.ProcessErrorAsync += ProcessErrorHandler;
   
   // Start the processing
   await processor.StartProcessingAsync();
   
   // Wait for 30 seconds for the events to be processed
   await Task.Delay(TimeSpan.FromSeconds(30));
   
   // Stop the processing
   await processor.StopProcessingAsync();
   
   Task ProcessEventHandler(ProcessEventArgs eventArgs)
   {
       // Write the body of the event to the console window
       Console.WriteLine("\tReceived event: {0}", Encoding.UTF8.GetString(eventArgs.Data.Body.ToArray()));
       Console.ReadLine();
       return Task.CompletedTask;
   }
   
   Task ProcessErrorHandler(ProcessErrorEventArgs eventArgs)
   {
       // Write details about the error to the console window
       Console.WriteLine($"\tPartition '{eventArgs.PartitionId}': an unhandled exception was encountered. This was not expected to happen.");
       Console.WriteLine(eventArgs.Exception.Message);
       Console.ReadLine();
       return Task.CompletedTask;
   }
   

1. Ersätt den befintliga koden i Program.cs filen med följande exempelkod. <AZURE_STORAGE_CONNECTION_STRING> Ersätt sedan platshållarvärdena och <BLOB_CONTAINER_NAME> för URI:BlobContainerClientn. <EVENT_HUB_NAMESPACE_CONNECTION_STRING> Ersätt platshållarvärdena och <HUB_NAME> för EventProcessorClient den också.

   Här är de viktiga stegen i koden:

   1. Skapar ett EventProcessorClient-objekt med hjälp av den primära anslutningssträng till namnområdet och händelsehubben. Du måste skapa BlobContainerClient-objektet för containern i Azure Storage som du skapade tidigare.
   2. Anger hanterare för ProcessEventAsync- och ProcessErrorAsync-händelserna för EventProcessorClient-objektet.
   3. Börjar bearbeta händelser genom att anropa StartProcessingAsync på EventProcessorClient-objektet .
   4. Slutar bearbeta händelser efter 30 sekunder genom att anropa StopProcessingAsync på EventProcessorClient-objektet .

   using Azure.Messaging.EventHubs;
   using Azure.Messaging.EventHubs.Consumer;
   using Azure.Messaging.EventHubs.Processor;
   using Azure.Storage.Blobs;
   using System.Text;
   
   // Create a blob container client that the event processor will use 
   BlobContainerClient storageClient = new BlobContainerClient(
       "<AZURE_STORAGE_CONNECTION_STRING>", "<BLOB_CONTAINER_NAME>");
   
   // Create an event processor client to process events in the event hub
   var processor = new EventProcessorClient(
       storageClient,
       EventHubConsumerClient.DefaultConsumerGroupName,
       "<EVENT_HUBS_NAMESPACE_CONNECTION_STRING>",
       "<HUB_NAME>");
   
   // Register handlers for processing events and handling errors
   processor.ProcessEventAsync += ProcessEventHandler;
   processor.ProcessErrorAsync += ProcessErrorHandler;
   
   // Start the processing
   await processor.StartProcessingAsync();
   
   // Wait for 30 seconds for the events to be processed
   await Task.Delay(TimeSpan.FromSeconds(30));
   
   // Stop the processing
   await processor.StopProcessingAsync();
   
   Task ProcessEventHandler(ProcessEventArgs eventArgs)
   {
       // Write the body of the event to the console window
       Console.WriteLine("\tReceived event: {0}", Encoding.UTF8.GetString(eventArgs.Data.Body.ToArray()));
       return Task.CompletedTask;
   }
   
   Task ProcessErrorHandler(ProcessErrorEventArgs eventArgs)
   {
       // Write details about the error to the console window
       Console.WriteLine($"\tPartition '{eventArgs.PartitionId}': an unhandled exception was encountered. This was not expected to happen.");
       Console.WriteLine(eventArgs.Exception.Message);
       return Task.CompletedTask;
   }