Guida introduttiva: Inviare e ricevere eventi da Hub eventi di Azure tramite .NET

Assegnare ruoli all'utente di Microsoft Entra

Quando si sviluppa in locale, assicurarsi che l'account utente che si connette a Hub eventi di Azure disponga delle autorizzazioni corrette. Per inviare e ricevere messaggi, è necessario il ruolo di proprietario dei dati Hub eventi di Azure. Per assegnare a se stessi questo ruolo, è necessario il ruolo Accesso utente Amministrazione istrator o un altro ruolo che include l'azioneMicrosoft.Authorization/roleAssignments/write. È possibile assegnare ruoli controllo degli accessi in base al ruolo di Azure a un utente usando il portale di Azure, l'interfaccia della riga di comando di Azure o Azure PowerShell. Altre informazioni sugli ambiti disponibili per le assegnazioni di ruolo sono disponibili nella pagina panoramica dell'ambito .

L'esempio seguente assegna il Azure Event Hubs Data Owner ruolo all'account utente, che fornisce l'accesso completo alle risorse di Hub eventi di Azure. In uno scenario reale, seguire il principio dei privilegi minimi per concedere agli utenti solo le autorizzazioni minime necessarie per un ambiente di produzione più sicuro.

Ruoli predefiniti di Azure per Hub eventi di Azure

Per Hub eventi di Azure, la gestione degli spazi dei nomi e di tutte le risorse correlate tramite il portale di Azure e l'API di gestione delle risorse di Azure è già protetta usando il modello di controllo degli accessi in base al ruolo di Azure. Azure offre i ruoli predefiniti di Azure seguenti per autorizzare l'accesso a uno spazio dei nomi di Hub eventi:

• Hub eventi di Azure Proprietario dati: consente l'accesso ai dati allo spazio dei nomi di Hub eventi e alle relative entità (code, argomenti, sottoscrizioni e filtri)
• Hub eventi di Azure Mittente dati: usare questo ruolo per concedere al mittente l'accesso allo spazio dei nomi di Hub eventi e alle relative entità.
• Hub eventi di Azure Ricevitore dati: usare questo ruolo per concedere al ricevitore l'accesso allo spazio dei nomi di Hub eventi e alle relative entità.

Per creare un ruolo personalizzato, vedere Diritti necessari per le operazioni di Hub eventi.

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>

Avviare Visual Studio e accedere ad Azure

È possibile autorizzare l'accesso allo spazio dei nomi del bus di servizio seguendo questa procedura:

1. Avviare Visual Studio. Se viene visualizzata la finestra Attività iniziali , selezionare il collegamento Continua senza codice nel riquadro destro.

2. Selezionare il pulsante Accedi in alto a destra in Visual Studio.

   

3. Accedere usando l'account Microsoft Entra a cui è stato assegnato un ruolo in precedenza.

   

Ottenere la stringa di connessione

La creazione di un nuovo spazio dei nomi genera automaticamente un criterio di firma di accesso condiviso iniziale con chiavi primarie e secondarie e stringa di connessione che ogni concede il controllo completo su tutti gli aspetti dello spazio dei nomi. Per informazioni su come creare regole con diritti più vincolati per mittenti e ricevitori regolari, vedere Autenticazione e autorizzazione di Hub eventi.

Un client può usare il stringa di connessione per connettersi allo spazio dei nomi di Hub eventi. Per copiare il stringa di connessione primario per lo spazio dei nomi, seguire questa procedura:

1. Nella pagina Spazio dei nomi dell'hub eventi selezionare Criteri di accesso condiviso nel menu a sinistra.

2. Nella pagina Criteri di accesso condiviso selezionare RootManageSharedAccessKey.

3. Nella finestra Criteri: RootManageSharedAccessKey selezionare il pulsante copia accanto a Stringa di Connessione primaria per copiare il stringa di connessione negli Appunti per usarlo in un secondo momento. Incollare questo valore nel Blocco note o in un'altra posizione temporanea.

   

   È possibile usare questa pagina per copiare la chiave primaria, la chiave secondaria, la stringa di connessione primaria e le stringa di connessione secondarie.

1. Scegliere Strumenti>Gestione pacchetti NuGet>Console di Gestione pacchetti dal menu.

2. Eseguire i comandi seguenti per installare i pacchetti NuGet Azure.Messaging.EventHubs e Azure.Identity . Premere INVIO per eseguire il secondo comando.

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

1. Scegliere Strumenti>Gestione pacchetti NuGet>Console di Gestione pacchetti dal menu.

2. Eseguire il comando seguente per installare il pacchetto NuGet Azure.Messaging.EventHubs:

   Install-Package Azure.Messaging.EventHubs
   

1. Sostituire il codice esistente nel Program.cs file con il codice di esempio seguente. Sostituire quindi e <HUB_NAME> impostare <EVENT_HUB_NAMESPACE> i valori segnaposto per i EventHubProducerClient parametri con i nomi dello spazio dei nomi di Hub eventi e dell'hub eventi. Ad esempio: "spehubns0309.servicebus.windows.net" e "spehub".

   Ecco i passaggi importanti del codice:

   1. Crea un oggetto EventHubProducerClient usando lo spazio dei nomi e il nome dell'hub eventi.
   2. Richiama il metodo CreateBatchAsync nell'oggetto EventHubProducerClient per creare un oggetto EventDataBatch .
   3. Aggiungere eventi al batch usando il metodo EventDataBatch.TryAdd .
   4. Invia il batch di messaggi all'hub eventi usando il metodo 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. Sostituire il codice esistente nel Program.cs file con il codice di esempio seguente. Sostituire quindi i <CONNECTION_STRING> valori segnaposto e <HUB_NAME> per i EventHubProducerClient parametri.

   Ecco i passaggi importanti del codice:

   1. Crea un oggetto EventHubProducerClient usando il stringa di connessione primario allo spazio dei nomi e al nome dell'hub eventi.
   2. Richiama il metodo CreateBatchAsync nell'oggetto EventHubProducerClient per creare un oggetto EventDataBatch .
   3. Aggiungere eventi al batch usando il metodo EventDataBatch.TryAdd .
   4. Invia il batch di messaggi all'hub eventi usando il metodo 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();
   }
   

Quando si sviluppa in locale, assicurarsi che l'account utente che accede ai dati BLOB disponga delle autorizzazioni corrette. È necessario Archiviazione Collaboratore ai dati BLOB per leggere e scrivere dati BLOB. Per assegnare a se stessi questo ruolo, è necessario assegnare il ruolo Amministratore accesso utenti o un altro ruolo che include l'azione Microsoft.Authorization/roleAssignments/write. È possibile assegnare ruoli controllo degli accessi in base al ruolo di Azure a un utente usando il portale di Azure, l'interfaccia della riga di comando di Azure o Azure PowerShell. Per altre informazioni sugli ambiti disponibili per le assegnazioni di ruolo, vedere la pagina di panoramica dell'ambito.

In questo scenario si assegneranno le autorizzazioni all'account utente, con ambito all'account di archiviazione, per seguire il principio dei privilegi minimi. Questa procedura offre agli utenti solo le autorizzazioni minime necessarie e crea ambienti di produzione più sicuri.

L'esempio seguente assegnerà il ruolo collaboratore ai dati BLOB Archiviazione all'account utente, che fornisce sia l'accesso in lettura che in scrittura ai dati BLOB nell'account di archiviazione.

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>

Ottenere la stringa di connessione all'account di archiviazione

Prendere nota della stringa di connessione e del nome del contenitore. È possibile usarli nel codice per ricevere eventi dall'hub eventi.

1. Scegliere Strumenti>Gestione pacchetti NuGet>Console di Gestione pacchetti dal menu.

2. Nella finestra della console di Gestione pacchetti verificare che EventHubsReceiver sia selezionato per il progetto predefinito. In caso contrario, usare l'elenco a discesa per selezionare EventHubsReceiver.

3. Eseguire il comando seguente per installare i pacchetti Azure.Messaging.EventHubs e Azure.Identity NuGet. Premere INVIO per eseguire l'ultimo comando.

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

1. Scegliere Strumenti>Gestione pacchetti NuGet>Console di Gestione pacchetti dal menu.

2. Nella finestra della console di Gestione pacchetti verificare che EventHubsReceiver sia selezionato per il progetto predefinito. In caso contrario, usare l'elenco a discesa per selezionare EventHubsReceiver.

3. Eseguire il comando seguente per installare il pacchetto NuGet Azure.Messaging.EventHubs:

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

1. Sostituire il codice esistente nel Program.cs file con il codice di esempio seguente. Sostituire quindi i <STORAGE_ACCOUNT_NAME> valori segnaposto e <BLOB_CONTAINER_NAME> per l'URI BlobContainerClient . Sostituire anche i <EVENT_HUB_NAMESPACE> valori segnaposto e <HUB_NAME> .EventProcessorClient

   Ecco i passaggi importanti del codice:

   1. Crea un oggetto EventProcessorClient usando lo spazio dei nomi di Hub eventi e il nome dell'hub eventi. È necessario compilare l'oggetto BlobContainerClient per il contenitore nell'archiviazione di Azure creata in precedenza.
   2. Specifica i gestori per gli eventi ProcessEventAsync e ProcessErrorAsync dell'oggetto EventProcessorClient .
   3. Avvia l'elaborazione degli eventi richiamando StartProcessingAsync nell'oggetto EventProcessorClient .
   4. Arresta l'elaborazione degli eventi dopo 30 secondi richiamando StopProcessingAsync nell'oggetto EventProcessorClient .

   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. Sostituire il codice esistente nel Program.cs file con il codice di esempio seguente. Sostituire quindi i <AZURE_STORAGE_CONNECTION_STRING> valori segnaposto e <BLOB_CONTAINER_NAME> per l'URI BlobContainerClient . Sostituire anche i <EVENT_HUB_NAMESPACE_CONNECTION_STRING> valori segnaposto e <HUB_NAME> .EventProcessorClient

   Ecco i passaggi importanti del codice:

   1. Crea un oggetto EventProcessorClient usando il stringa di connessione primario nello spazio dei nomi e nell'hub eventi. È necessario compilare l'oggetto BlobContainerClient per il contenitore nell'archiviazione di Azure creata in precedenza.
   2. Specifica i gestori per gli eventi ProcessEventAsync e ProcessErrorAsync dell'oggetto EventProcessorClient .
   3. Avvia l'elaborazione degli eventi richiamando StartProcessingAsync nell'oggetto EventProcessorClient .
   4. Arresta l'elaborazione degli eventi dopo 30 secondi richiamando StopProcessingAsync nell'oggetto EventProcessorClient .

   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;
   }