Szybki start: wysyłanie zdarzeń do lub odbieranie zdarzeń z centrów zdarzeń przy użyciu języka JavaScript

Z tego przewodnika Szybki start dowiesz się, jak wysyłać zdarzenia do centrum zdarzeń i odbierać je z centrum zdarzeń przy użyciu pakietu npm @azure/event-hubs .

Jeśli dopiero zaczynasz korzystać z Azure Event Hubs, zobacz Omówienie Event Hubs przed rozpoczęciem.

Wymagania wstępne

• Subskrypcja platformy Microsoft Azure. Do korzystania z usług platformy Azure, w tym usługi Azure Event Hubs, potrzebna jest subskrypcja. Jeśli nie masz konta platformy Azure, utwórz konto bezpłatnej wersji próbnej.
• Node.js LTS. Pobierz najnowszą długoterminową wersję pomocy technicznej (LTS).
• Visual Studio Code (zalecane) lub inne zintegrowane środowisko projektowe (IDE).
• Utwórz przestrzeń nazw usługi Event Hubs i centrum zdarzeń. Użyj portalu Azure, aby utworzyć przestrzeń nazw typu Event Hubs. Pobierz poświadczenia zarządzania, których aplikacja potrzebuje, aby komunikować się z centrum zdarzeń. Aby uzyskać więcej informacji, zobacz Tworzenie centrum zdarzeń przy użyciu witryny Azure Portal.

Instalowanie pakietów npm w celu wysyłania zdarzeń

Aby zainstalować pakiet Node Package Manager (npm) dla usługi Event Hubs, otwórz okno wiersza polecenia, które ma npm w swojej ścieżce. Zmień katalog na folder, w którym chcesz zachować przykłady.

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

npm install @azure/event-hubs

Uwierzytelnianie aplikacji na platformie Azure

Ten szybki start przedstawia dwa sposoby nawiązywania połączenia z Azure Event Hubs.

• Bez hasła. Użyj swojego podmiotu zabezpieczeń w Microsoft Entra ID i kontroli dostępu opartej na rolach (RBAC), aby połączyć się z przestrzenią nazw Event Hubs. Nie musisz martwić się o zakodowane parametry połączenia w kodzie, w pliku konfiguracji lub w bezpiecznym magazynie, na przykład w usłudze Azure Key Vault.
• Parametry połączenia. Użyj parametrów połączenia, aby nawiązać połączenie z przestrzenią nazw usługi Event Hubs. Jeśli dopiero zaczynasz korzystać z platformy Azure, możesz znaleźć opcję parametry połączenia łatwiejszą do naśladowania.

Zalecamy użycie opcji bez hasła w rzeczywistych aplikacjach i środowiskach produkcyjnych. Aby uzyskać więcej informacji, zobacz Uwierzytelnianie i autoryzacja usługi Service Bus oraz połączenia bez hasła dla usług platformy 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>

Wysyłanie zdarzeń

W tej sekcji utworzysz aplikację JavaScript, która wysyła zdarzenia do centrum zdarzeń.

1. Otwórz edytor tekstów, taki jak Visual Studio Code.

2. Utwórz plik o nazwie send.js. Wklej do niego następujący kod:

   • Bez hasła (zalecane)
   • Łańcuch połączenia

   W kodzie użyj rzeczywistych wartości, aby zastąpić następujące symbole zastępcze:

   • 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. Aby uruchomić aplikację, użyj następującego polecenia:

   node send.js
   

   Polecenie wysyła partię trzech zdarzeń do centrum zdarzeń.

   Jeśli używasz uwierzytelniania kontroli dostępu opartej na rolach (RBAC) bez hasła (Microsoft Entra ID Role-Based Access Control), może być konieczne zalogowanie się na platformie Azure przy użyciu konta dodanego do roli właściciela danych usługi Azure Event Hubs. Użyj polecenia az login.

4. W witrynie Azure Portal sprawdź, czy centrum zdarzeń odebrało komunikaty. Aby zaktualizować wykres, odśwież stronę. Może upłynąć kilka sekund, aby pokazać, że komunikaty są odbierane.

   

   Uwaga / Notatka

   Aby uzyskać więcej informacji i pełny kod źródłowy, zobacz stronę usługi GitHub sendEvents.js.

Odbieranie zdarzeń

W tej sekcji zdarzenia są odbierane z centrum zdarzeń przy użyciu magazynu punktów kontrolnych usługi Azure Blob Storage w aplikacji JavaScript. Wykonuje ona punkty kontrolne metadanych na odebranych komunikatach w regularnych odstępach czasu w obiekcie blob usługi Azure Storage. Takie podejście ułatwia kontynuowanie odbierania komunikatów później z miejsca, w którym zostało przerwane.

Postępuj zgodnie z tymi zaleceniami, gdy używasz usługi Azure Blob Storage jako magazynu punktów kontrolnych:

• Użyj oddzielnego kontenera dla każdej grupy odbiorców. Możesz użyć tego samego konta magazynu, ale użyj jednego kontenera dla każdej grupy.
• Nie używaj konta magazynowego do niczego innego.
• Nie używaj kontenera do niczego innego.
• Utwórz konto magazynu w tym samym regionie co wdrożona aplikacja. Jeśli aplikacja jest na miejscu, spróbuj wybrać najbliższy możliwy region.

Na stronie konta magazynowego w portalu Azure, w sekcji usługi Blob, upewnij się, że następujące ustawienia zostały wyłączone.

• Hierarchiczna przestrzeń nazw
• Miękkie usuwanie obiektów blob
• Wersjonowanie

Tworzenie konta usługi Azure Storage i kontenera obiektów blob

Aby utworzyć konto usługi Azure Storage z kontenerem blobów:

1. Tworzenie konta usługi Azure Storage
2. Utwórz kontener obiektów blob na koncie usługi magazynowej
3. Uwierzytelnij się do kontenera obiektów 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>

Instalowanie pakietów npm w celu odbierania zdarzeń

Po stronie odbierania należy zainstalować jeszcze dwa pakiety. W tym przewodniku Szybki start użyjesz usługi Azure Blob Storage do utrwalania punktów kontrolnych, aby program nie odczytywał już odczytanych zdarzeń. Wykonuje ona punkty kontrolne metadanych na odebranych komunikatach w regularnych odstępach czasu w obiekcie blob. Takie podejście ułatwia kontynuowanie odbierania komunikatów później z miejsca, w którym zostało przerwane.

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

Pisanie kodu w celu odbierania zdarzeń

1. Otwórz edytor tekstów, taki jak Visual Studio Code.

2. Utwórz plik o nazwie receive.js. Wklej do niego następujący kod:

   • Bez hasła (zalecane)
   • Łańcuch połączenia

   W kodzie użyj rzeczywistych wartości, aby zastąpić następujące symbole zastępcze:

   • 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. Aby uruchomić ten kod, użyj polecenia node receive.js. W oknie są wyświetlane komunikaty o odebranych zdarzeniach.

   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'
   

   Uwaga / Notatka

   Aby uzyskać pełny kod źródłowy, w tym komentarze informacyjne, zobacz receiveEventsUsingCheckpointStore.js.

   Program odbiorcy odbiera zdarzenia ze wszystkich partycji domyślnej grupy odbiorców w centrum zdarzeń.

Uprzątnij zasoby

Usuń grupę zasobów, która ma przestrzeń nazw usługi Event Hubs lub usuń tylko przestrzeń nazw, jeśli chcesz zachować grupę zasobów.

Treści powiązane

• Przykłady języka JavaScript
• Przykłady języka TypeScript