Quickstart: Gebeurtenissen verzenden naar of ontvangen van event hubs met behulp van JavaScript

In deze quickstart leert u hoe u gebeurtenissen verzendt naar en ontvangt van een Event Hub met behulp van het npm-pakket @azure/event-hubs .

Als u nog geen toegang hebt tot Azure Event Hubs, raadpleegt u het overzicht van Event Hubs voordat u begint.

Vereiste voorwaarden

• Microsoft Azure-abonnement. Als u Azure-services wilt gebruiken, met inbegrip van Azure Event Hubs, hebt u een abonnement nodig. Als u geen Azure-account hebt, meldt u zich aan voor een gratis proefversie.
• Node.js LTS. Download de nieuwste LTS-versie (Langetermijnondersteuning).
• Visual Studio Code (aanbevolen) of een andere IDE (Integrated Development Environment).
• Een Event Hubs-naamruimte en een Event Hub maken. Gebruik Azure Portal om een naamruimte van het type Event Hubs te maken om de beheerreferenties op te halen die uw toepassing nodig heeft om te communiceren met de Event Hub. Zie Een Event Hub maken met behulp van Azure Portal voor meer informatie.

NPM-pakketten installeren om gebeurtenissen te verzenden

Als u het Node Package Manager-pakket (npm) voor Event Hubs wilt installeren, opent u een opdrachtpromptvenster dat zich in het pad bevindt npm . Verander van map naar de map waarin u uw voorbeelden wilt bewaren.

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

npm install @azure/event-hubs

De app verifiëren bij Azure

In deze quickstart ziet u twee manieren om verbinding te maken met Azure Event Hubs:

• Wachtwoordloos. Gebruik uw beveiligingsprincipaal in Microsoft Entra ID en op rollen gebaseerd toegangsbeheer (RBAC) om verbinding te maken met een Event Hubs-naamruimte. U hoeft zich geen zorgen te maken over het gebruik van vastgelegde verbindingsreeksen in uw code, in een configuratiebestand of in beveiligde opslag, zoals Azure Key Vault.
• Verbindingsreeks. Gebruik een verbindingsreeks om verbinding te maken met een Event Hubs-naamruimte. Als u nog niet eerder met Azure werkt, kunt u de verbindingsreeks optie gemakkelijker volgen.

We raden u aan de optie zonder wachtwoord te gebruiken in echte toepassingen en productieomgevingen. Zie Service Bus-verificatie en -autorisatie enverbindingen zonder wachtwoord voor Azure-services voor meer informatie.

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>

Gebeurtenissen verzenden

In deze sectie maakt u een JavaScript-toepassing waarmee gebeurtenissen worden verzonden naar een Event Hub.

1. Open een teksteditor, zoals Visual Studio Code.

2. Maak een bestand met de naamsend.js. Plak de volgende code erin:

   • Wachtwoordloos (aanbevolen)
   • Verbindingsstring

   Gebruik in de code echte waarden om de volgende tijdelijke aanduidingen te vervangen:

   • 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. Gebruik deze opdracht om de toepassing uit te voeren:

   node send.js
   

   Met de opdracht wordt een batch van drie gebeurtenissen naar uw Event Hub verzonden.

   Als u de verificatie voor wachtwoordloos (op rollen gebaseerd toegangsbeheer (RBAC) van Microsoft Entra ID gebruikt, moet u zich mogelijk aanmelden bij Azure met het account dat u hebt toegevoegd aan de rol Gegevenseigenaar van Azure Event Hubs. Gebruik de opdracht az login.

4. Controleer in Azure Portal of de Event Hub de berichten heeft ontvangen. Als u de grafiek wilt bijwerken, vernieuwt u de pagina. Het kan enkele seconden duren voordat wordt aangegeven dat de berichten zijn ontvangen.

   

   Opmerking

   Zie de pagina GitHub sendEvents.js voor meer informatie en de volledige broncode.

Gebeurtenissen ontvangen

In deze sectie ontvangt u gebeurtenissen van een Event Hub met behulp van een Azure Blob Storage-controlepuntarchief in een JavaScript-toepassing. Er worden controlepunten voor metagegevens uitgevoerd op ontvangen berichten met regelmatige tussenpozen in een Azure Storage-blob. Met deze aanpak kunt u later eenvoudig berichten blijven ontvangen vanaf de plek waar u was gebleven.

Volg deze aanbevelingen wanneer u Azure Blob Storage als controlepuntarchief gebruikt:

• Gebruik een afzonderlijke container voor elke consumentengroep. U kunt hetzelfde opslagaccount gebruiken, maar één container per groep gebruiken.
• Gebruik het opslagaccount niet voor iets anders.
• Gebruik de container niet voor iets anders.
• Maak het opslagaccount in dezelfde regio als de geïmplementeerde toepassing. Als de toepassing on-premises is, probeert u de dichtstbijzijnde regio te kiezen.

Controleer op de pagina Opslagaccount in Azure Portal in de sectie Blob-service of de volgende instellingen zijn uitgeschakeld.

• Hiërarchische naamruimte
• Blob zacht verwijderen
• Versiebeheer

Een Azure-opslagaccount en een blobcontainer maken

Een Azure Storage-account maken met een blobcontainer:

1. Een Azure-opslagaccount maken
2. Een blobcontainer maken in het opslagaccount
3. Authenticeren bij de 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>

De npm-pakketten installeren om gebeurtenissen te ontvangen

Voor de ontvangende kant moet u nog twee pakketten installeren. In deze quickstart gebruikt u Azure Blob Storage om controlepunten vast te leggen, zodat het programma de gebeurtenissen die het programma al heeft gelezen niet leest. Het voert regelmatig metadata-checkpoints uit op ontvangen berichten in een blob. Met deze aanpak kunt u later eenvoudig berichten blijven ontvangen vanaf de plek waar u was gebleven.

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

Code schrijven om gebeurtenissen te ontvangen

1. Open een teksteditor, zoals Visual Studio Code.

2. Maak een bestand met de naamreceive.js. Plak de volgende code erin:

   • Wachtwoordloos (aanbevolen)
   • Verbindingsstring

   Gebruik in de code echte waarden om de volgende tijdelijke aanduidingen te vervangen:

   • 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. Gebruik de opdracht node receive.jsom deze code uit te voeren. In het venster worden berichten over ontvangen gebeurtenissen weergegeven.

   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'
   

   Opmerking

   Zie receiveEventsUsingCheckpointStore.jsvoor de volledige broncode, inclusief informatieve opmerkingen.

   Het ontvangerprogramma ontvangt gebeurtenissen van alle partities van de standaardconsumergroep in de Event Hub.

De hulpbronnen opschonen

Verwijder de resourcegroep met de Event Hubs-naamruimte of verwijder alleen de naamruimte als u de resourcegroep wilt behouden.

Verwante inhoud

• JavaScript-voorbeelden
• TypeScript-voorbeelden