Inicio rápido: Envío o recepción de eventos desde event Hubs mediante JavaScript

En este inicio rápido, aprenderá a enviar y recibir eventos desde un centro de eventos mediante el paquete npm de @azure/event-hubs .

Si no está familiarizado con Azure Event Hubs, consulte Introducción a Event Hubs antes de empezar.

Prerrequisitos

• 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 tiene una cuenta de Azure, regístrese para obtener una evaluación gratuita.
• Node.js LTS. Descargue la versión más reciente de soporte técnico a largo plazo (LTS).
• Visual Studio Code (se recomienda) o cualquier otro entorno de desarrollo integrado (IDE).
• Cree un espacio de nombres de Event Hubs y un centro de eventos. Use Azure Portal para crear un espacio de nombres de tipo Event Hubs Obtener las credenciales de administración que la aplicación necesita para comunicarse con el centro de eventos. Para más información, consulte Creación de un centro de eventos mediante Azure Portal.

Instalación de paquetes de npm para enviar eventos

Para instalar el paquete del Administrador de paquetes de node (npm) para Event Hubs, abra una ventana del símbolo del sistema que tenga npm en su ruta de acceso. Cambie el directorio a la carpeta donde desea guardar los ejemplos.

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

npm install @azure/event-hubs

Autenticación de la aplicación en Azure

En este inicio rápido se muestran dos maneras de conectarse a Azure Event Hubs:

• Sin contraseña. Use la entidad de seguridad en Microsoft Entra ID y el control de acceso basado en rol (RBAC) para conectarse a un espacio de nombres de Event Hubs. No es necesario preocuparse por tener cadenas de conexión codificadas de forma rígida en el código, en un archivo de configuración o en almacenamiento seguro como Azure Key Vault.
• Cadena de conexión. Use una cadena de conexión para conectarse a un espacio de nombres de Event Hubs. Si no está familiarizado con Azure, es posible que encuentre la opción de cadena de conexión más fácil de seguir.

Se recomienda usar la opción sin contraseña en aplicaciones reales y entornos de producción. Para más información, consulte Autenticación y autorización de Service Bus yconexiones sin contraseña para los servicios de Azure.

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>

Envío de eventos

En esta sección, creará una aplicación de JavaScript que envía eventos a un centro de eventos.

1. Abra un editor de texto, como Visual Studio Code.

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

   • Sin contraseña (recomendado)
   • Cadena de conexión

   En el código, use valores reales para reemplazar los siguientes marcadores de posición:

   • 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. Para ejecutar la aplicación, use este comando:

   node send.js
   

   El comando envía un lote de tres eventos al centro de eventos.

   Si usa la autenticación de control de acceso basado en rol (RBAC) sin contraseña (Microsoft Entra ID), es posible que necesite iniciar sesión en Azure con la cuenta que agregó al rol Propietario de datos de Azure Event Hubs. Use el comando az login.

4. En Azure Portal, compruebe que el centro de eventos recibió los mensajes. Para actualizar el gráfico, actualice la página. Puede tardar unos segundos en mostrar que se reciben los mensajes.

   

   Nota:

   Para obtener más información y el código fuente completo, consulte la página sendEvents.js de GitHub.

Recepción de eventos

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

Siga estas recomendaciones al usar Azure Blob Storage como almacén de puntos de control:

• Use un contenedor independiente para cada grupo de consumidores. Puede usar la misma cuenta de almacenamiento, pero usar un contenedor por cada grupo.
• No use la cuenta de almacenamiento para nada más.
• No use el contenedor para nada más.
• Cree la cuenta de almacenamiento en la misma región que la aplicación implementada. Si la aplicación es local, intente elegir la región más cercana posible.

En la página Cuenta de almacenamiento de Azure Portal, en la sección Blob service, asegúrese de que la siguiente configuración está deshabilitada.

• Espacio de nombres jerárquico
• Eliminación temporal de blobs
• Versionamiento

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

Para crear una cuenta de Azure Storage con un contenedor de blobs:

1. Creación de una cuenta de Azure Storage
2. Creación de un contenedor de blobs en la cuenta de almacenamiento
3. Autenticación en el contenedor de blobs

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>

Instalación de los paquetes de npm para recibir eventos

En el lado del receptor, tiene que instalar dos paquetes más. En este inicio rápido, usará Azure Blob Storage para conservar los puntos de control para que el programa no lea los eventos que ya leyó. 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ó.

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

Escribir código para recibir eventos

1. Abra un editor de texto, como Visual Studio Code.

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

   • Sin contraseña (recomendado)
   • Cadena de conexión

   En el código, use valores reales para reemplazar los siguientes marcadores de posición:

   • 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. Para ejecutar este código, use el comando node receive.js. La ventana muestra mensajes sobre eventos recibidos.

   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'
   

   Nota:

   Para obtener el código fuente completo, incluidos los comentarios informativos, vea receiveEventsUsingCheckpointStore.js.

   El programa receptor recibe eventos de todas las particiones del grupo de consumidores predeterminado en el centro de eventos.

Limpieza de recursos

Elimine el grupo de recursos que tiene el espacio de nombres de Event Hubs o elimine solo el espacio de nombres si desea mantener el grupo de recursos.

Contenido relacionado

• Ejemplos de JavaScript
• Ejemplos de TypeScript