Azure Logic Apps에서 이벤트 허브에 워크플로 연결

적용 대상: Azure Logic Apps(사용량 + 표준)

Azure Logic Apps의 워크플로 내에서 이벤트 허브의 이벤트를 모니터링하고 관리하는 작업을 자동화하려면 Azure Event Hubs 커넥터 작업을 사용합니다. 예를 들어 워크플로는 이벤트 허브에서 이벤트를 확인하고 보내고 받을 수 있습니다.

이 문서에서는 Event Hubs 트리거 또는 작업을 워크플로에 추가하여 이벤트 허브에 연결하는 방법을 보여 줍니다.

커넥터 참조

이 커넥터의 작업, 해당 매개 변수 및 제한, 알려진 문제 등과 같은 기타 기술 정보에 대한 자세한 내용은 Event Hubs 커넥터의 참조 페이지를 참조하세요.

필수 구성 요소

• Azure 계정 및 구독 구독이 없는 경우 Azure 체험 계정에 등록합니다.

• Event Hubs 네임스페이스 및 이벤트 허브입니다.

  워크플로가 이벤트 허브에 액세스할 수 있는지 확인합니다. 이 작업을 완료하려면 다음 단계를 수행합니다.

  1. Azure Portal에서 특정 이벤트 허브가 아닌 Event Hubs 네임스페이스로 이동합니다.

  2. 네임스페이스 메뉴의 설정에서 공유 액세스 정책을 선택합니다. 클레임 열에서 해당 네임스페이스에 대해 최소한 관리 권한이 있는지 확인합니다.

     비고

     나중에 Event Hubs 네임스페이스에 대한 연결을 만들 때 연결에 대한 인증 유형을 선택하라는 메시지가 표시됩니다. 인증 유형 선택에 따라 네임스페이스 연결 문자열이 필요할 수 있습니다. 예를 들어 Access Key 인증에는 이 연결 문자열이 필요합니다.

  3. 나중에 Event Hubs 네임스페이스에 대한 연결 문자열이 필요한 인증 유형을 선택하려는 경우 나중에 해당 정보를 입력할 수 있도록 해당 문자열을 저장합니다.

     1. 정책 열에서 RootManageSharedAccessKey를 선택합니다.

     2. 기본 키 연결 문자열을 찾습니다. 나중에 사용할 수 있도록 연결 문자열을 복사하고 저장합니다.

        연결 문자열이 특정 이벤트 허브가 아닌 Event Hubs 네임스페이스에 속하는지 확인하려면 연결 문자열에 매개 변수가 EntityPath 없는지 확인합니다. 이 매개 변수를 찾으면 연결 문자열이 이벤트 허브에 속하며 워크플로에 사용할 올바른 문자열이 아닙니다.

        

• 이벤트 허브에 액세스하려는 논리 앱 워크플로

  Event Hubs 트리거를 사용하여 워크플로를 시작하려면 빈 워크플로가 필요합니다. 워크플로에서 Event Hubs 작업을 사용하려면 시나리오에 가장 적합한 트리거를 사용하여 워크플로를 시작할 수 있습니다.

Event Hubs 트리거 추가

Azure Logic Apps에서 모든 워크플로는 특정 조건이 충족될 때 실행되는 트리거로 시작해야 합니다. 트리거가 실행될 때마다 Azure Logic Apps는 워크플로의 인스턴스를 만들고 워크플로의 단계를 실행하기 시작합니다.

다음 단계에서는 이벤트 허브에서 이벤트를 사용할 수 있는 경우와 같은 Event Hubs 트리거를 추가하는 일반적인 방법을 설명합니다. 이 예제 트리거는 이벤트 허브에서 새 이벤트를 확인하고 새 이벤트가 있을 때 워크플로 실행을 시작합니다.

1. Azure Portal에서 논리 앱 리소스를 엽니다.

2. 소비 또는 표준 논리 앱 리소스가 있는지 여부에 따라 해당 단계를 수행합니다.

   • 소비: 리소스 사이드바의 개발 도구에서 디자이너를 선택하여 빈 워크플로를 엽니다.

   • 표준: 리소스 사이드바의 워크플로에서 워크플로를 선택한 다음 빈 워크플로를 선택합니다. 워크플로 사이드바의 도구 아래에서 디자이너를 선택하여 빈 워크플로를 엽니다.

3. 디자이너에서 다음 일반적인 단계에 따라 워크플로에 원하는 Event Hubs 트리거를 추가 합니다.

   자세한 내용은 Event Hubs - 트리거를 참조하세요. 이 예제에서는 이벤트 허브에서 이벤트를 사용할 수 있는 경우라는 트리거를 계속 사용합니다. 이 트리거는 이벤트 허브에서 새 이벤트를 확인하고 새 이벤트가 있을 때 워크플로 실행을 시작합니다.

4. 메시지가 표시되면 이벤트 허브에 대한 연결 정보를 제공합니다.

5. 트리거에서 선택한 트리거에 대해 필요한 정보를 입력합니다.

   예제 트리거의 경우 다음 표에서는 다음 기본 매개 변수부터 시작하여 사용 가능한 매개 변수를 설명합니다.

   매개 변수	필수	설명
   이벤트 허브 이름	예	모니터링할 이벤트 허브의 이름입니다.

   항목을 확인하는 빈도 아래에서 다음 기본 매개 변수를 사용할 수 있습니다.

   매개 변수	필수	설명
   간격	예	빈도에 따라 워크플로가 얼마나 자주 실행되는지를 설명하는 양의 정수입니다.
   빈도	예	되풀이 시간 단위입니다.
   표준 시간대	아니요	이 트리거는 UTC 오프셋을 허용하지 않으므로 시작 시간을 지정할 때만 적용됩니다. 적용하려는 표준 시간대를 선택합니다. 자세한 내용은 되풀이 워크플로 예약 및 실행을 참조하세요.
   시작 시간	아니요	시작 시간을 다음 형식으로 입력합니다. 표준 시간대를 선택하는 경우 YYYY-MM-DDThh:mm:ss 또는 표준 시간대를 선택하지 않은 경우 YYYY-MM-DDThh:mm:ssZ 자세한 내용은 되풀이 워크플로 예약 및 실행을 참조하세요.

   고급 매개 변수 목록에서 다음 선택적 매개 변수를 사용할 수 있습니다.

   매개 변수	필수	설명
   콘텐츠 형식	아니요	이벤트의 콘텐츠 형식입니다. 기본값은 application/octet-stream입니다.
   콘텐츠 스키마	아니요	이벤트의 콘텐츠 스키마입니다.
   소비자 그룹 이름	아니요	이벤트 읽기에 사용할 Event Hubs 소비자 그룹의 이름입니다. 지정하지 않으면 기본 소비자 그룹이 사용됩니다.
   최소 파티션 키	아니요	읽을 최소 파티션 ID를 입력합니다. 기본적으로 모든 파티션이 읽혀집니다.
   최대 파티션 키	아니요	읽을 최대 파티션 ID를 입력합니다. 기본적으로 모든 파티션이 읽혀집니다.
   최대 이벤트 수	아니요	최대 이벤트 수입니다. 트리거는 1과 이 속성으로 지정된 이벤트의 수 범위의 숫자를 반환합니다.

6. 완료되면 디자이너 도구 모음에서 저장을 선택합니다.

7. 이제 트리거 출력을 사용하여 다른 작업을 수행할 수 있도록 하나 이상의 작업을 계속 추가합니다.

   예를 들어 특정 값(예: 범주)에 따라 이벤트를 필터링하려면 이벤트 보내기 작업에서 조건에 맞는 이벤트만 보내도록 조건을 추가하면 됩니다.

트리거 동작

트리거 폴링 동작

모든 Event Hubs 트리거는 긴 폴링 트리거입니다. 이 동작은 트리거가 발생할 때 모든 이벤트를 처리한 다음, 더 많은 이벤트가 이벤트 허브에 표시되도록 30초 동안 대기함을 의미합니다. 설계상, 30초 동안 표시되는 이벤트가 없으면 트리거를 건너뜁니다. 그렇지 않으면 트리거는 이벤트 허브가 빈 상태가 될 때까지 이벤트를 계속 읽습니다. 다음 트리거 폴링은 트리거 속성에 설정한 되풀이 간격을 기준으로 발생합니다.

예를 들어 트리거가 4개의 파티션으로 설정된 경우 이 지연 시간은 트리거가 모든 파티션 폴링을 완료하기까지 최대 2분이 걸릴 수 있습니다. 이 지연 시간 내에 이벤트가 수신되지 않으면 트리거 실행을 건너뜁니다. 그렇지 않으면 트리거는 이벤트 허브가 빈 상태가 될 때까지 이벤트를 계속 읽습니다. 다음 트리거 폴링은 트리거의 속성에 지정한 되풀이 간격을 기준으로 발생합니다.

메시지가 표시되는 특정 파티션을 알고 있는 경우 해당 파티션에서만 이벤트를 읽도록 트리거를 업데이트할 수 있습니다. 트리거의 최대 및 최소 파티션 키를 설정합니다. 자세한 내용은 Event Hubs 트리거 추가 섹션을 참조하세요.

검사점 동작 트리거

Event Hubs 트리거가 이벤트 허브의 각 파티션에서 이벤트를 읽는 경우 트리거는 스트림 오프셋 (파티션의 이벤트 위치) 및 트리거가 이벤트를 읽는 파티션에 대한 정보를 유지하기 위해 사용자 고유의 상태를 유지 관리합니다.

워크플로가 실행될 때마다 트리거는 트리거 상태에 저장된 스트림 오프셋에서 시작하여 파티션에서 이벤트를 읽습니다. 라운드 로빈 방식으로 트리거는 이벤트 허브의 각 파티션을 반복하고 후속 트리거 실행에서 이벤트를 읽습니다. 단일 실행은 한 번에 하나의 파티션에서 이벤트를 가져옵니다.

트리거는 스토리지에서 이 검사점 기능을 사용하지 않으므로 추가 비용이 발생하지 않습니다. Event Hubs 트리거를 업데이트하면 트리거의 상태가 다시 설정되며, 이로 인해 트리거가 스트림 시작 시 이벤트를 읽을 수 있습니다.

Event Hubs 작업 추가

Azure Logic Apps에서 작업은 트리거 또는 다른 작업을 따르고 워크플로에서 일부 작업을 수행합니다. 다음 단계에서는 Send 이벤트와 같은 Event Hubs 작업을 추가하는 일반적인 방법을 설명합니다. 이 예제의 경우 워크플로는 이벤트 허브에서 새 이벤트를 확인하는 Event Hubs 트리거로 시작합니다.

1. Azure Portal에서 논리 앱 리소스를 엽니다.

2. 소비 또는 표준 논리 앱 리소스가 있는지 여부에 따라 해당 단계를 수행합니다.

   • 소비: 리소스 사이드바의 개발 도구에서 디자이너를 선택하여 워크플로를 엽니다.

   • 표준: 리소스 사이드바의 워크플로에서 워크플로를 선택한 다음 워크플로를 선택합니다. 워크플로 사이드바의 도구에서 디자이너를 선택하여 워크플로를 엽니다.

3. 디자이너에서 다음 일반적인 단계에 따라 워크플로에 원하는 Event Hubs 작업을 추가 합니다.

   자세한 내용은 Event Hubs - 작업을 참조하세요. 이 예제에서는 Send 이벤트라는 작업을 계속합니다.

4. 메시지가 표시되면 이벤트 허브에 대한 연결 정보를 제공합니다.

5. 작업에서 선택한 작업에 필요한 정보를 제공합니다.

   예제 작업의 경우 다음 표에서는 다음 기본 매개 변수부터 시작하여 사용 가능한 매개 변수를 설명합니다.

   매개 변수	필수	설명
   이벤트 허브 이름	예	이벤트를 보낼 이벤트 허브의 이름입니다.

   고급 매개 변수 목록에서 다음 선택적 매개 변수를 사용할 수 있습니다.

   매개 변수	필수	설명
   파티션 키	아니요	이벤트를 보낼 위치에 대한 파티션 ID입니다.
   콘텐츠	아니요	보낼 이벤트의 콘텐츠입니다.
   속성	아니요	보낼 앱 속성 및 값입니다.

   예를 들어 Event Hubs 트리거의 출력을 다른 이벤트 허브로 보낼 수 있습니다.

   

6. 완료되면 디자이너 도구 모음에서 저장을 선택합니다.

연결 만들기

Event Hubs 트리거 또는 작업을 처음 추가하면 이벤트 허브에 대한 연결을 만들라는 메시지가 표시됩니다. 이 연결의 경우 다음 정보를 제공하고 새로 만들기를 선택합니다.

연결을 만든 후에 Event Hubs 트리거 추가 또는 Event Hubs 작업 추가를 계속 진행합니다.

관련 콘텐츠

• Azure Logic Apps의 커넥터란?
• Azure Logic Apps용 관리형 커넥터