빠른 시작: JavaScript를 사용하여 이벤트 허브에서 이벤트 보내기 또는 받기

이 빠른 시작에서는 @azure/event-hubs npm 패키지를 사용하여 이벤트 허브에서 이벤트를 보내고 받는 방법을 알아봅니다.

Azure Event Hubs를 새로 사용하는 경우 시작하기 전에 Event Hubs 개요를 참조하세요.

필수 조건

• Microsoft Azure 구독. Azure Event Hubs를 비롯한 Azure 서비스를 사용하려면 구독이 필요합니다. Azure 계정이 없는 경우 무료 평가판을 등록해 보세요.
• Node.js LTS. 최신 LTS(장기 지원) 버전을 다운로드합니다.
• Visual Studio Code(권장) 또는 다른 IDE(통합 개발 환경).
• Event Hubs 네임스페이스 및 이벤트 허브를 만듭니다. Azure Portal을 사용하여 Event Hubs 형식의 네임스페이스를 만들면 애플리케이션이 이벤트 허브와 통신하는 데 필요한 관리 자격 증명을 가져옵니다. 자세한 내용은 Azure Portal을 사용하여 이벤트 허브 만들기를 참조하세요.

npm 패키지를 설치하여 이벤트 보내기

Event Hubs에 대한 npm(노드 패키지 관리자) 패키지를 설치하려면 경로에 있는 npm 명령 프롬프트 창을 엽니다. 샘플을 보관할 폴더로 디렉터리를 변경합니다.

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

npm install @azure/event-hubs

Azure에 앱 인증

이 빠른 시작에서는 Azure Event Hubs에 연결하는 두 가지 방법을 보여 줍니다.

• 암호가 없습니다. Microsoft Entra ID 및 RBAC(역할 기반 액세스 제어)의 보안 주체를 사용하여 Event Hubs 네임스페이스에 연결합니다. 코드, 구성 파일 또는 Azure Key Vault와 같은 보안 스토리지에 하드 코딩된 연결 문자열이 있는 것에 대해 걱정할 필요가 없습니다.
• 연결 문자열입니다. 연결 문자열을 사용하여 Event Hubs 네임스페이스에 연결합니다. Azure를 접하는 경우 연결 문자열 옵션을 더 쉽게 따를 수 있습니다.

실제 애플리케이션 및 프로덕션 환경에서는 암호 없는 옵션을 사용하는 것이 좋습니다. 자세한 내용은 Azure 서비스에 대한 Service Bus 인증 및 권한 부여 및 암호 없는 연결을 참조하세요.

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
   

   이 명령은 이벤트 허브에 세 개의 이벤트 일괄 처리를 보냅니다.

   암호 없는(Microsoft Entra ID RBAC(역할 기반 액세스 제어) 인증을 사용하는 경우 Azure Event Hubs 데이터 소유자 역할에 추가한 계정을 사용하여 Azure에 로그인해야 할 수 있습니다. az login 명령 사용

4. Azure Portal에서 이벤트 허브가 메시지를 받았는지 확인합니다. 차트를 업데이트하려면 페이지를 새로 고칩니다. 메시지가 수신되었음을 표시하는 데 몇 초 정도 걸릴 수 있습니다.

   

   비고

   자세한 내용 및 전체 소스 코드는 GitHub sendEvents.js 페이지를 참조하세요.

이벤트 수신

이 섹션에서는 JavaScript 애플리케이션의 Azure Blob Storage 검사점 저장소를 사용하여 이벤트 허브에서 이벤트를 수신합니다. Azure Storage Blob에서 정기적으로 수신된 메시지에 대한 메타데이터 검사점을 수행합니다. 이러한 방식이 사용되므로 메시지 수신이 중지된 이후 중지된 시점부터 계속해서 쉽게 메시지를 수신할 수 있습니다.

검사점 저장소로 Azure Blob Storage를 사용하는 경우 다음 권장 사항을 따릅니다.

• 각 소비자 그룹에 대해 별도의 컨테이너를 사용합니다. 동일한 스토리지 계정을 사용할 수 있지만 각 그룹당 하나의 컨테이너를 사용합니다.
• 스토리지 계정을 다른 용도로 사용하지 마세요.
• 컨테이너를 다른 용도로 사용하지 마세요.
• 배포된 애플리케이션과 동일한 지역에 스토리지 계정을 만듭니다. 애플리케이션이 온-프레미스인 경우 가능한 가장 가까운 지역을 선택해 보세요.

Azure Portal에서 Storage 계정 페이지의 Blob service 섹션에서 다음 설정을 사용하지 않도록 설정해야 합니다.

• 계층 구조 네임스페이스
• Blob 일시 삭제
• 버전 관리

Azure 스토리지 계정 및 blob 컨테이너 만들기

Blob 컨테이너를 사용하여 Azure Storage 계정을 만들려면 다음을 수행합니다.

1. Azure Storage 계정 만들기
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 Storage를 사용하여 검사점을 유지합니다. 이 스토리지는 일정한 간격으로 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참조하세요.

   수신기 프로그램은 이벤트 허브에 있는 기본 소비자 그룹의 모든 파티션에서 이벤트를 수신합니다.

자원을 정리하세요

Event Hubs 네임스페이스가 있는 리소스 그룹을 삭제하거나 리소스 그룹을 유지하려는 경우 네임스페이스만 삭제합니다.

관련 콘텐츠

• JavaScript 샘플
• TypeScript 샘플