Краткое руководство: Отправка событий в узлы событий или получение событий с помощью JavaScript

Из этого краткого руководства вы узнаете, как отправлять события и получать события из концентратора событий с помощью пакета npm @azure/event-hubs .

Если вы не знакомы с Центрами событий Azure, ознакомьтесь с общими сведениями о Центрах событий перед началом работы.

Предпосылки

• Подписка Microsoft Azure. Чтобы использовать службы Azure, в том числе Центры событий Azure, потребуется действующая подписка. Если у вас нет учетной записи Azure, зарегистрируйтесь для получения бесплатной пробной версии.
• Node.js LTS. Скачайте последнюю долгосрочную версию поддержки (LTS).
• Visual Studio Code (рекомендовано) или любая другая интегрированная среда разработки (IDE).
• Создайте пространство имен Центров событий и концентратор событий. Используйте портал Azure, чтобы создать пространство имен типа Event Hubs. Получите учетные данные управления, которые необходимы вашему приложению для взаимодействия с концентратором событий. Дополнительные сведения см. в статье "Создание концентратора событий" с помощью портала Azure.

Установка пакетов npm для отправки событий

Чтобы установить пакет менеджера пакетов Node (npm) для Центров событий, откройте окно командной строки, в которой доступен путь npm. Измените каталог на папку, в которой вы хотите сохранить примеры.

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

npm install @azure/event-hubs

Проверка подлинности приложения в Azure

В этом кратком руководстве показано два способа подключения к Центрам событий Azure:

• Без пароля. Используйте принципал безопасности в Microsoft Entra ID и управление доступом на основе ролей (RBAC) для подключения к пространству имен Центров событий. Вам не нужно беспокоиться о наличии жестко закодированных строк подключения в коде, в файле конфигурации или безопасном хранилище, например Azure Key Vault.
• Строка подключения. Используйте строку подключения для подключения к пространству имен Event Hubs. Если вы не знакомы с Azure, вы можете найти вариант строка подключения проще следовать.

Мы рекомендуем использовать параметр без пароля в реальных приложениях и рабочих средах. Дополнительные сведения см. в статье "Проверка подлинности и авторизация служебной шины" иподключения без пароля для служб 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>

Отправка событий

В этом разделе описано, как создать приложение JavaScript, которое отправляет события в концентратор событий.

1. Откройте текстовый редактор, например Visual Studio Code.

2. Создайте файл с именемsend.js. Вставьте в него следующий код:

   • Без пароля (рекомендуется)
   • Строка подключения

   В коде используйте реальные значения для замены следующих заполнителей:

   • 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. Чтобы запустить приложение, используйте следующую команду:

   node send.js
   

   Команда отправляет пакет из трех событий в концентратор событий.

   Если вы используете безпарольную аутентификацию (управление доступом на основе ролей (RBAC) в Microsoft Entra ID), возможно, потребуется войти в Azure, используя учетную запись, добавленную в роль владельца данных Azure Event Hubs. Используйте команду az login.

4. На портале Azure убедитесь, что концентратор событий получил сообщения. Чтобы обновить диаграмму, обновите страницу. Может потребоваться несколько секунд, чтобы показать, что сообщения получены.

   

   Замечание

   Дополнительные сведения и полный исходный код см. на странице sendEvents.js GitHub.

Получение событий

В этом разделе вы получаете события из концентратора событий с помощью хранилища BLOB-объектов Azure в приложении JavaScript. Она выполняет контрольные точки метаданных для полученных сообщений с регулярными интервалами в хранилище Azure. Благодаря такому подходу позже можно легко продолжить получать сообщения с того места, где вы остановились.

Следуйте этим рекомендациям при использовании хранилища BLOB-объектов Azure в качестве хранилища контрольных точек:

• Используйте отдельный контейнер для каждой группы потребителей. Вы можете использовать одну и ту же учетную запись хранения, но использовать один контейнер для каждой группы.
• Не используйте учетную запись хранения для других действий.
• Не используйте контейнер для ничего другого.
• Создайте учетную запись хранения в том же регионе, что и развернутое приложение. Если приложение находится в локальной среде, попробуйте выбрать ближайший регион.

На странице учетной записи хранения в портале Azure в разделе службы BLOB убедитесь, что следующие параметры отключены.

• Иерархическое пространство имен
• Обратимое удаление BLOB-объекта
• Управление версиями

Создать учетную запись хранения Azure и контейнер Blob

Чтобы создать учетную запись хранения данных Azure с контейнером BLOB, выполните приведенные действия.

1. Создание учетной записи хранения Azure
2. Создайте контейнер BLOB-объектов в учетной записи хранения
3. Аутентификация для доступа к контейнеру BLOB-объектов

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>

Установка пакетов npm для получения событий

Для принимающей стороны необходимо установить еще два пакета. В этом кратком руководстве вы используете Azure Blob-хранилище для сохранения контрольных точек, чтобы программа не считывала уже прочитанные события. Оно регулярно выполняет фиксацию метаданных для полученных сообщений в большом двоичном объекте. Благодаря такому подходу позже можно легко продолжить получать сообщения с того места, где вы остановились.

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

Написание кода для получения событий

1. Откройте текстовый редактор, например Visual Studio Code.

2. Создайте файл с именемreceive.js. Вставьте в него следующий код:

   • Без пароля (рекомендуется)
   • Строка подключения

   В коде используйте реальные значения для замены следующих заполнителей:

   • 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. Чтобы запустить этот код, используйте команду node receive.js. В окне отображаются сообщения о полученных событиях.

   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'
   

   Замечание

   Полный исходный код, включая информационные комментарии, см. receiveEventsUsingCheckpointStore.js.

   Программа-получатель получает события от всех разделов группы потребителей по умолчанию в концентраторе событий.

Очистите ресурсы

Удалите группу ресурсов с пространством имен Центров событий или удалите только пространство имен, если вы хотите сохранить группу ресурсов.

Связанный контент

• Примеры JavaScript
• Примеры TypeScript