Schnellstart: Senden von Ereignissen an oder Empfangen von Ereignissen von Event Hubs mithilfe von JavaScript

In dieser Schnellstartanleitung erfahren Sie, wie Sie Ereignisse mithilfe des npm-Pakets @azure/event-hubs an einen Event Hub senden und ereignisse von einem Event Hub empfangen.

Wenn Sie mit Azure Event Hubs noch nicht fertig sind, lesen Sie die Übersicht über Event Hubs , bevor Sie beginnen.

Voraussetzungen

• Microsoft Azure-Abonnement. Für die Verwendung von Azure-Diensten benötigen Sie ein Abonnement. Das gilt auch für Azure Event Hubs. Wenn Sie nicht über ein Azure-Konto verfügen, registrieren Sie sich für eine kostenlose Testversion.
• Node.js LTS. Laden Sie die neueste ltS-Version (Long-Term Support) herunter.
• Visual Studio Code (empfohlen) oder eine andere integrierte Entwicklungsumgebung (Integrated Development Environment, IDE)
• Erstellen Sie einen Event Hubs-Namespace und einen Event Hub. Verwenden Sie das Azure-Portal , um einen Namespace vom Typ "Event Hubs" zu erstellen. Rufen Sie die Verwaltungsanmeldeinformationen ab, die Ihre Anwendung für die Kommunikation mit dem Event Hub benötigt. Weitere Informationen finden Sie unter Erstellen eines Event Hub mithilfe des Azure-Portals.

Installieren von npm-Paketen zum Senden von Ereignissen

Um das Node Package Manager (npm) Paket für Event Hubs zu installieren, öffnen Sie ein Eingabeaufforderungsfenster, bei dem npm in seinem Pfad enthalten ist. Ändern Sie das Verzeichnis in den Ordner, in dem Sie Ihre Beispiele speichern möchten.

npm install @azure/event-hubs
npm install @azure/identity

npm install @azure/event-hubs

Authentifizieren der App bei Azure

In dieser Schnellstartanleitung werden zwei Möglichkeiten zum Herstellen einer Verbindung mit Azure Event Hubs gezeigt:

• Kennwortlos. Verwenden Sie Ihren Sicherheitsprinzipal in Microsoft Entra ID und die rollenbasierte Zugriffssteuerung (RBAC), um eine Verbindung zu einem Event Hubs Namespace herzustellen. Sie müssen sich keine Gedanken darüber machen, dass hartcodierte Verbindungszeichenfolgen in Ihrem Code, in einer Konfigurationsdatei oder im sicheren Speicher wie Azure Key Vault vorhanden sind.
• Verbindungszeichenfolge. Verwenden Sie eine Verbindungszeichenfolge, um eine Verbindung mit einem Event Hubs-Namespace herzustellen. Wenn Sie noch nicht mit Azure vertraut sind, ist die Option mit einer Verbindungszeichenfolge möglicherweise einfacher.

In realen Anwendungen und Produktionsumgebungen wird die kennwortlose Option empfohlen. Weitere Informationen finden Sie unter Service Bus-Authentifizierung und Autorisierung und kennwortloseVerbindungen für Azure-Dienste.

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>

Senden von Ereignissen

In diesem Abschnitt erstellen Sie eine JavaScript-Anwendung, die Ereignisse an einen Event Hub sendet.

1. Öffnen Sie einen Text-Editor, z. B. Visual Studio Code.

2. Erstellen Sie eine Datei namenssend.js. Fügen Sie den folgenden Code in ihn ein:

   • Kennwortlos (empfohlen)
   • Verbindungszeichenfolge

   Ersetzen Sie im Code die folgenden Platzhalter durch echte Werte:

   • EVENT HUBS NAMESPACE NAME
   • EVENT HUB NAME

   const { EventHubProducerClient } = require("@azure/event-hubs");
   const { DefaultAzureCredential } = require("@azure/identity");
   
   // Event hubs 
   const eventHubsResourceName = "EVENT HUBS NAMESPACE NAME";
   const fullyQualifiedNamespace = `${eventHubsResourceName}.servicebus.windows.net`; 
   const eventHubName = "EVENT HUB NAME";
   
   // Azure Identity - passwordless authentication
   const credential = new DefaultAzureCredential();
   
   async function main() {
   
     // Create a producer client to send messages to the event hub.
     const producer = new EventHubProducerClient(fullyQualifiedNamespace, eventHubName, credential);
   
     // Prepare a batch of three events.
     const batch = await producer.createBatch();
     batch.tryAdd({ body: "passwordless First event" });
     batch.tryAdd({ body: "passwordless Second event" });
     batch.tryAdd({ body: "passwordless Third event" });    
   
     // Send the batch to the event hub.
     await producer.sendBatch(batch);
   
     // Close the producer client.
     await producer.close();
   
     console.log("A batch of three events have been sent to the event hub");
   }
   
   main().catch((err) => {
     console.log("Error occurred: ", err);
   });
   

3. Verwenden Sie den folgenden Befehl, um die Anwendung auszuführen:

   node send.js
   

   Der Befehl sendet einen Batch von drei Ereignissen an ihren Event Hub.

   Wenn Sie die kennwortlose Authentifizierung (Microsoft Entra ID Role-based access control, RBAC) verwenden, müssen Sie sich möglicherweise mit dem Konto anmelden, das Sie der Azure Event Hubs-Datenbesitzerrolle hinzugefügt haben. Verwenden Sie den Befehl az login.

4. Überprüfen Sie im Azure-Portal, ob der Event Hub die Nachrichten empfangen hat. Um das Diagramm zu aktualisieren, aktualisieren Sie die Seite. Es kann einige Sekunden dauern, bis der Empfang der Nachrichten angezeigt wird.

   

   Hinweis

   Weitere Informationen und den vollständigen Quellcode finden Sie auf der GitHub-sendEvents.js-Seite.

Empfangen von Ereignissen

In diesem Abschnitt erhalten Sie Ereignisse von einem Event Hub mithilfe eines Azure Blob Storage-Prüfpunktspeichers in einer JavaScript-Anwendung. Er führt Metadatenprüfpunkte für empfangene Nachrichten in regelmäßigen Abständen in einem Azure Storage-Blob aus. Dadurch kann der Empfang von Nachrichten später problemlos an der Stelle fortgesetzt werden, an der Sie aufgehört haben.

Befolgen Sie diese Empfehlungen, wenn Sie Azure Blob Storage als Prüfpunktspeicher verwenden:

• Verwenden Sie einen separaten Container für jede Consumergruppe. Sie können dasselbe Speicherkonto verwenden, aber verwenden Sie für jede Gruppe einen eigenen Container.
• Verwenden Sie das Speicherkonto nicht für andere Elemente.
• Verwenden Sie den Container nicht für andere Elemente.
• Erstellen Sie das Speicherkonto in derselben Region wie die bereitgestellte Anwendung. Wenn die Anwendung lokal ist, versuchen Sie, die nächstgelegene Region auszuwählen.

Stellen Sie auf der Seite Speicherkonto im Azure-Portal im Abschnitt Blobdienst sicher, dass die folgenden Einstellungen deaktiviert sind.

• Hierarchischer Namespace
• Vorläufiges Löschen von Blobs
• Versionsverwaltung

Erstellen eines Azure-Speicherkontos und eines Blobcontainers

So erstellen Sie ein Azure-Speicherkonto mit einem BLOB-Container:

1. Erstellen eines Azure-Speicherkontos
2. Erstellen Sie einen Blob-Container im Speicherkonto
3. Authentifizieren beim Blobcontainer

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>

Installieren der npm-Pakete zum Empfangen von Ereignissen

Für die empfangende Seite müssen Sie zwei weitere Pakete installieren. In dieser Schnellstartanleitung verwenden Sie Azure Blob Storage, um Prüfpunkte beizubehalten, damit das Programm die bereits gelesenen Ereignisse nicht liest. In einem Blob werden für empfangene Nachrichten in regelmäßigen Abständen Metadatenprüfpunkte erstellt. Dadurch kann der Empfang von Nachrichten später problemlos an der Stelle fortgesetzt werden, an der Sie aufgehört haben.

npm install @azure/storage-blob
npm install @azure/eventhubs-checkpointstore-blob
npm install @azure/identity

npm install @azure/storage-blob
npm install @azure/eventhubs-checkpointstore-blob

Schreiben von Code zum Empfangen von Ereignissen

1. Öffnen Sie einen Text-Editor, z. B. Visual Studio Code.

2. Erstellen Sie eine Datei namensreceive.js. Fügen Sie den folgenden Code in ihn ein:

   • Kennwortlos (empfohlen)
   • Verbindungszeichenfolge

   Ersetzen Sie im Code die folgenden Platzhalter durch echte Werte:

   • EVENT HUBS NAMESPACE NAME
   • EVENT HUB NAME
   • STORAGE ACCOUNT NAME
   • STORAGE CONTAINER NAME

   const { DefaultAzureCredential } = require("@azure/identity");
   const { EventHubConsumerClient, earliestEventPosition  } = require("@azure/event-hubs");
   const { ContainerClient } = require("@azure/storage-blob");    
   const { BlobCheckpointStore } = require("@azure/eventhubs-checkpointstore-blob");
   
   // Event hubs 
   const eventHubsResourceName = "EVENT HUBS NAMESPACE NAME";
   const fullyQualifiedNamespace = `${eventHubsResourceName}.servicebus.windows.net`; 
   const eventHubName = "EVENT HUB NAME";
   const consumerGroup = "$Default"; // name of the default consumer group
   
   // Azure Storage 
   const storageAccountName = "STORAGE ACCOUNT NAME";
   const storageContainerName = "STORAGE CONTAINER NAME";
   const baseUrl = `https://${storageAccountName}.blob.core.windows.net`;
   
   // Azure Identity - passwordless authentication
   const credential = new DefaultAzureCredential();
   
   async function main() {
   
     // Create a blob container client and a blob checkpoint store using the client.
     const containerClient = new ContainerClient(
       `${baseUrl}/${storageContainerName}`,
       credential
     );  
     const checkpointStore = new BlobCheckpointStore(containerClient);
   
     // Create a consumer client for the event hub by specifying the checkpoint store.
     const consumerClient = new EventHubConsumerClient(consumerGroup, fullyQualifiedNamespace, eventHubName, credential, checkpointStore);
   
     // Subscribe to the events, and specify handlers for processing the events and errors.
     const subscription = consumerClient.subscribe({
         processEvents: async (events, context) => {
           if (events.length === 0) {
             console.log(`No events received within wait time. Waiting for next interval`);
             return;
           }
   
           for (const event of events) {
             console.log(`Received event: '${event.body}' from partition: '${context.partitionId}' and consumer group: '${context.consumerGroup}'`);
           }
           // Update the checkpoint.
           await context.updateCheckpoint(events[events.length - 1]);
         },
   
         processError: async (err, context) => {
           console.log(`Error : ${err}`);
         }
       },
       { startPosition: earliestEventPosition }
     );
   
     // After 30 seconds, stop processing.
     await new Promise((resolve) => {
       setTimeout(async () => {
         await subscription.close();
         await consumerClient.close();
         resolve();
       }, 30000);
     });
   }
   
   main().catch((err) => {
     console.log("Error occurred: ", err);
   });
   

3. Verwenden Sie den Befehl node receive.js, um diesen Code auszuführen. Im Fenster werden Meldungen zu empfangenen Ereignissen angezeigt.

   C:\Self Study\Event Hubs\JavaScript>node receive.js
   Received event: 'First event' from partition: '0' and consumer group: '$Default'
   Received event: 'Second event' from partition: '0' and consumer group: '$Default'
   Received event: 'Third event' from partition: '0' and consumer group: '$Default'
   

   Hinweis

   Den vollständigen Quellcode, einschließlich Informationskommentaren, finden Sie unterreceiveEventsUsingCheckpointStore.js.

   Das Empfängerprogramm empfängt Ereignisse von allen Partitionen der Standardconsumergruppe im Event Hub.

Bereinigen von Ressourcen

Löschen Sie die Ressourcengruppe mit dem Event Hubs-Namespace, oder löschen Sie nur den Namespace, wenn Sie die Ressourcengruppe behalten möchten.

Verwandte Inhalte

• JavaScript samples (JavaScript-Beispiele)
• TypeScript-Beispiele