Envío o recepción de eventos en Event Hubs mediante JavaScript (azure/event-hubs)

En este inicio rápido se muestra cómo enviar y recibir eventos desde un centro de eventos mediante el paquete de JavaScript azure/event-hubs.

Requisitos previos

Si es la primera vez que usa Azure Event Hubs, consulte la información general de Event Hubs antes de continuar con este inicio rápido.

Para completar este tutorial de inicio rápido, debe cumplir los siguientes requisitos previos:

• Una suscripción a Microsoft Azure. Para usar los servicios de Azure, entre los que se incluye Azure Event Hubs, se necesita una suscripción. Si no se dispone de una cuenta de Azure, es posible registrarse para obtener una evaluación gratuita, o bien usar las ventajas que disfrutan los suscriptores MSDN al crear una cuenta.

• Node.js, versión 8.x o posteriores. Descargue la versión más reciente del soporte técnico a largo plazo (LTS).

• Visual Studio Code (se recomienda) o cualquier otro entorno de desarrollo integrado (IDE).

• Un espacio de nombres de Event Hubs y un centro de eventos activos. Para crearlos, siga estos pasos:

  1. En Azure Portal, cree un espacio de nombres del tipo Event Hubs y obtenga las credenciales de administración que la aplicación necesita para comunicarse con el centro de eventos.
  2. Para crear tanto el espacio de nombres como el centro de eventos, siga las instrucciones que encontrará en Inicio rápido: Creación de un centro de eventos desde Azure Portal.
  3. Para continuar, siga las instrucciones de este inicio rápido.
  4. Para obtener la cadena de conexión del espacio de nombres del centro de eventos, siga las instrucciones de Obtención de una cadena de conexión. Registre la cadena de conexión para usarla más adelante en este inicio rápido.

• Creación de un espacio de nombres de Event Hubs y un centro de eventos. El primer paso consiste en usar Azure Portal para crear un espacio de nombres de tipo Event Hubs y obtener las credenciales de administración que la aplicación necesita para comunicarse con el centro de eventos. Para crear un espacio de nombres y un centro de eventos, siga el procedimiento que se indica en este artículo. Después, obtenga la cadena de conexión para el espacio de nombres de Event Hubs. Para ello, siga las instrucciones del artículo: Obtenga la cadena de conexión. La cadena de conexión la utilizará más adelante en este inicio rápido.

Instalación del paquete npm

Para instalar el paquete del administrador de paquetes de nodos (npm) para Event Hubs, abra un símbolo del sistema que tenga npm en su ruta de acceso, cambie el directorio a la carpeta en la que quiere tener los ejemplos y después ejecute este comando:

npm install @azure/event-hubs

En el lado del receptor, tiene que instalar dos paquetes más. En este inicio rápido se usar Azure Blob Storage para conservar los puntos de control, con el fin de que el programa no lea los eventos que ya ha leído. Ejecuta los puntos de comprobación de metadatos en los mensajes recibidos a intervalos regulares en un blob. Este enfoque facilita la tarea de seguir recibiendo posteriormente mensajes desde donde lo dejó.

Ejecute los comandos siguientes:

npm install @azure/storage-blob

npm install @azure/eventhubs-checkpointstore-blob

Envío de eventos

En esta sección se crea una aplicación de JavaScript que envía eventos a un centro de eventos.

1. Abra el editor que prefiera, como Visual Studio Code.

2. Cree un archivo denominado send.js y pegue en él el código siguiente:

   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. En el código, use valores reales para reemplazar los siguientes:

   • EVENT HUBS NAMESPACE CONNECTION STRING
   • EVENT HUB NAME

4. Ejecute node send.js para ejecutar este archivo. Este comando envía un lote de tres eventos al centro de eventos.

5. En Azure Portal, compruebe que el centro de eventos ha recibido los mensajes. En la sección Métricas, cambie a la vista Mensajes. Actualice la página para actualizar el gráfico. Pueden pasar unos segundos hasta que aparezca que los mensajes se han recibido.

   

   Nota

   Para ver todo el código fuente, incluidos los comentarios informativos adicionales, vaya a la página sendEvents.js de GitHub.

Felicidades. Ha enviado eventos a un centro de eventos.

Recepción de eventos

En esta sección recibe eventos de un centro de eventos mediante un almacén de puntos de comprobación de Azure Blob Storage en una aplicación de JavaScript. Ejecuta los puntos de comprobación de metadatos en los mensajes recibidos a intervalos regulares en Azure Storage Blob. Este enfoque facilita la tarea de seguir recibiendo posteriormente mensajes desde donde lo dejó.

Creación de una cuenta de Azure Storage y un contenedor de blobs

Para crear una cuenta de Azure Storage y un contenedor de blobs en ella, realice estas acciones:

1. Creación de una cuenta de Azure Storage
2. Creación de un contenedor de blobs en la cuenta de almacenamiento
3. Obtención de la cadena de conexión para una cuenta de almacenamiento

Asegúrese de registrar la cadena de conexión y el nombre del contenedor para usarlo posteriormente en el código de recepción.

Escritura de código para recibir eventos

1. Abra el editor que prefiera, como Visual Studio Code.

2. Cree un archivo denominado receive.js y pegue en él el código siguiente:

   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. En el código, use valores reales para reemplazar los siguientes:

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

4. Ejecute node receive.js en un símbolo del sistema para ejecutar este archivo. La ventana debe mostrar mensajes sobre los eventos recibidos.

   Nota

   Para ver todo el código fuente, incluidos los comentarios informativos adicionales, vaya a la página receiveEventsUsingCheckpointStore.js de GitHub.

Felicidades. Ya ha recibido eventos procedentes del centro de eventos. El programa del destinatario recibirá los eventos de todas las particiones del grupo de consumidores predeterminado en el centro de eventos.

Pasos siguientes

Consulte estos ejemplos de código en GitHub:

• Ejemplos de JavaScript
• Ejemplos de TypeScript