Gebeurtenissen verzenden naar of gebeurtenissen ontvangen van Event Hubs met behulp van JavaScript (azure/event-hubs)

In deze quickstart ziet u hoe u gebeurtenissen kunt verzenden naar en ontvangen van een Event Hub met behulp van het JavaScript-pakket azure/event-hubs.

Vereisten

Als u nog geen ervaring hebt met Azure Event Hubs, raadpleegt u het Event Hubs-overzicht voordat u deze quickstart uitvoert.

Voor het voltooien van deze snelstart moet aan de volgende vereisten worden voldaan:

• Microsoft Azure-abonnement. Als u Azure-services wilt gebruiken, met inbegrip van Azure Event Hubs, hebt u een abonnement nodig. Als u nog geen Azure-account hebt, kunt u zich aanmelden voor een gratis proefversie of uw voordelen als MSDN-abonnee gebruiken wanneer u een account maakt.

• Node.js versie 8.x of hoger. Download de meest recente versie van LTS (Long-Term Support).

• Visual Studio Code (aanbevolen) of een andere IDE (Integrated Development Environment).

• Een actieve Azure Event Hubs-naamruimte en Event Hub. Voer de volgende stappen uit om deze te maken:

  1. Maak in de Azure-portal een naamruimte van het type Event Hubs, en verkrijg vervolgens de beheerreferenties die de toepassing nodig heeft om met de Event Hub te communiceren.
  2. Als u de naamruimte en Event Hub wilt maken volgt u de instructies in Quickstart: Een Event Hub maken met behulp van de Azure-portal.
  3. Ga verder met behulp van de instructies in deze quickstart.
  4. Volg de instructies in Verbindingsreeks ophalen om de verbindingsreeks voor uw Event Hub-naamruimte op te halen. Leg de verbindingsreeks vast zodat u deze later in deze quickstart kunt gebruiken.

• Een Event Hubs-naamruimte en een Event Hub maken. In de eerste stap gebruikt u Azure Portal om een naamruimte van het type Event Hubs te maken en de beheerreferenties te verkrijgen die de toepassing nodig heeft om met de Event Hub te communiceren. Volg de procedure in dit artikel om een naamruimte en een Event Hub te maken. Haal vervolgens de verbindingsreeks voor de Event Hubs-naamruimte op door de instructies in het artikel te volgen: Verbindingstekenreeks ophalen. U gebruikt de verbindingsreeks later in deze quickstart.

Installeer het npm-pakket

Als u het npm-pakket (Node Package Manager) voor Event Hubs wilt installeren, opent u een opdrachtprompt met npm in het bijbehorende pad. Wijzig de directory in de map waar u de voorbeelden wilt opslaan, en voer vervolgens deze opdracht uit:

npm install @azure/event-hubs

Voor deze ontvangende kant moet u nog twee pakketten installeren. In deze quickstart gebruikt u Azure Blob-opslag om controlepunten te behouden, zodat met het programma geen reeds gelezen gebeurtenissen worden gelezen. Er worden in een blob regelmatig controlepunten voor metagegevens uitgevoerd voor ontvangen berichten. Met deze aanpak kunt u later eenvoudig berichten blijven ontvangen vanaf de plek waar u was gebleven.

Voer de volgende opdrachten uit:

npm install @azure/storage-blob

npm install @azure/eventhubs-checkpointstore-blob

Gebeurtenissen verzenden

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

1. Open uw favoriete editor, bijvoorbeeld Visual Studio Code.

2. Maak een bestand met de naam send.js, en plak hierin de volgende code:

   const { EventHubProducerClient } = require("@azure/event-hubs");
   
   const connectionString = "EVENT HUBS NAMESPACE CONNECTION STRING";
   const eventHubName = "EVENT HUB NAME";
   
   async function main() {
   
     // Create a producer client to send messages to the event hub.
     const producer = new EventHubProducerClient(connectionString, eventHubName);
   
     // Prepare a batch of three events.
     const batch = await producer.createBatch();
     batch.tryAdd({ body: "First event" });
     batch.tryAdd({ body: "Second event" });
     batch.tryAdd({ body: "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 in de code echte waarden om het volgende te vervangen:

   • EVENT HUBS NAMESPACE CONNECTION STRING
   • EVENT HUB NAME

4. Voer node send.js uit om dit bestand uit te voeren. Met deze opdracht verzendt u een batch met drie gebeurtenissen naar uw Event Hub.

5. Controleer in de Azure-portal of de Event Hub de berichten heeft ontvangen. Schakel in de sectie Metrische gegevens over naar de weergave Berichten. U moet de pagina vernieuwen om de grafiek bij te werken. Het kan een paar seconden duren voordat wordt weergegeven dat de berichten zijn ontvangen.

   

   Notitie

   Ga voor de volledige broncode, inclusief aanvullende informatieve opmerkingen, naar de pagina GitHub sendEvents.js.

Gefeliciteerd! U hebt nu gebeurtenissen verzonden naar een Event Hub.

Gebeurtenissen ontvangen

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

Een Azure-opslagaccount en een blobcontainer maken

Als u een Azure-opslagaccount met een blobcontainer erin wilt maken, voert u de volgende acties uit:

1. Een Azure-opslagaccount maken
2. Een blobcontainer in het opslagaccount maken
3. De verbindingsreeks voor het opslagaccount ophalen

Zorg ervoor dat u de verbindingsreeks en de containernaam vastlegt voor later gebruik in de receive-code.

Code schrijven om gebeurtenissen te ontvangen

1. Open uw favoriete editor, bijvoorbeeld Visual Studio Code.

2. Maak een bestand met de naam receive.js, en plak hierin de volgende code:

   const { EventHubConsumerClient } = require("@azure/event-hubs");
   const { ContainerClient } = require("@azure/storage-blob");    
   const { BlobCheckpointStore } = require("@azure/eventhubs-checkpointstore-blob");
   
   const connectionString = "EVENT HUBS NAMESPACE CONNECTION STRING";    
   const eventHubName = "EVENT HUB NAME";
   const consumerGroup = "$Default"; // name of the default consumer group
   const storageConnectionString = "AZURE STORAGE CONNECTION STRING";
   const containerName = "BLOB CONTAINER NAME";
   
   async function main() {
     // Create a blob container client and a blob checkpoint store using the client.
     const containerClient = new ContainerClient(storageConnectionString, containerName);
     const checkpointStore = new BlobCheckpointStore(containerClient);
   
     // Create a consumer client for the event hub by specifying the checkpoint store.
     const consumerClient = new EventHubConsumerClient(consumerGroup, connectionString, eventHubName, 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}`);
         }
       }
     );
   
     // 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 in de code echte waarden om de volgende waarden te vervangen:

   • EVENT HUBS NAMESPACE CONNECTION STRING
   • EVENT HUB NAME
   • AZURE STORAGE CONNECTION STRING
   • BLOB CONTAINER NAME

4. Voer node receive.js in een opdrachtprompt uit om dit bestand uit te voeren. In het venster worden nu berichten over ontvangen gebeurtenissen weergegeven.

   Notitie

   Ga voor de volledige broncode, inclusief aanvullende informatieve opmerkingen, naar de pagina GitHub receiveEventsUsingCheckpointStore.js.

Gefeliciteerd! U hebt nu gebeurtenissen ontvangen van uw Event Hub. Het programma voor ontvangen, ontvangt nu gebeurtenissen van alle partities van de standaardconsumentengroep in de Event Hub.

Volgende stappen

Bekijk deze voorbeelden op GitHub:

• JavaScript-voorbeelden
• TypeScript-voorbeelden