GetAzureEventHub 프로세서
GetAzureEventHub 프로세서
Openflow의 GetAzureEventHub 프로세서는 신뢰할 수 있는 체크포인트 추적 없이 Microsoft Azure Event Hubs에서 메시지를 수신하는 프로세서예요. 클러스터 환경에서는 각 GetAzureEventHub 인스턴스가 독립적으로 동작해 모든 클러스터 노드가 모든 메시지를 처리해요(프로세서를 Primary Only 모드로 실행하지 않는 경우).
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-azure-nar
설명 (Description)
신뢰할 수 있는 체크포인트 추적 없이 Microsoft Azure Event Hubs에서 메시지를 수신해요. 클러스터 환경에서는 GetAzureEventHub 프로세서 인스턴스가 독립적으로 동작하며 모든 클러스터 노드가 모든 메시지를 처리해요(프로세서를 Primary Only 모드로 실행하지 않는 경우). ConsumeAzureEventHub는 Azure Event Hubs에서 메시지를 수신하는 권장 방식을 제공해요. 이 프로세서는 Azure Event Hubs와의 연결을 위한 스레드 풀을 만들어요.
태그 (Tags)
azure, cloud, eventhub, events, microsoft, streaming, streams
입력 요구 사항 (Input Requirement)
금지 (FORBIDDEN)
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
아니요 (false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Consumer Group | 이벤트를 가져올 때 사용할 소비자 그룹의 이름이에요. |
| Event Hub Name | Azure Event Hubs 소스의 이름이에요. |
| Event Hub Namespace | Service Bus Endpoint 도메인 앞에 붙는 Azure Event Hubs의 네임스페이스예요. |
| Message Enqueue Time | 읽기를 시작할 메시지가 Event Hub에 인큐되었어야 하는 시점부터의 타임스탬프(ISO-8601 Instant)로, YYYY-MM-DDThhmmss.sssZ (2016-01-01T01:01:01.000Z) 형식이에요. |
| Partition Receiver Fetch Size | 수신자가 반환하기 전에 Event Hubs 파티션에서 가져올 이벤트 수예요. 기본값은 100이에요. |
| Partition Receiver Timeout | Partition Receiver가 Fetch Size를 받기 위해 대기할 시간(밀리초)이에요. 기본값은 60000이에요. |
| Service Bus Endpoint | 기본 windows.net 도메인에 없는 네임스페이스를 지원하기 위한 값이에요. |
| Shared Access Policy Key | 공유 액세스 정책의 키예요. 기본 키나 보조 키 중 하나를 사용할 수 있어요. |
| Shared Access Policy Name | 공유 액세스 정책의 이름이에요. 이 정책에는 Listen 권한이 있어야 해요. |
| Transport Type | Azure Event Hubs와 통신하기 위한 Advanced Message Queuing Protocol Transport Type이에요. |
| Use Azure Managed Identity | Azure VM/VMSS의 관리 ID를 사용할지 여부를 선택해요. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration 컨트롤러 서비스를 지정해요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| success | 이벤트 허브에서 성공적으로 수신한 모든 FlowFile이 이 관계로 전달돼요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
| eventhub.enqueued.timestamp | 메시지가 이벤트 허브에 인큐된 시간(epoch 이후의 밀리초, UTC)이에요. |
| eventhub.offset | 메시지가 저장된 파티션 내 오프셋이에요. |
| eventhub.sequence | 메시지와 연결된 Azure 시퀀스 번호예요. |
| eventhub.name | 메시지를 가져온 이벤트 허브의 이름이에요. |
| eventhub.partition | 메시지를 가져온 이벤트 허브 파티션의 이름이에요. |
| eventhub.property.* | 이 메시지의 애플리케이션 속성이에요. 예: 'application'은 'eventhub.property.application'이 돼요. |