GetAzureQueueStorage_v12 프로세서
GetAzureQueueStorage_v12 프로세서
Openflow의 GetAzureQueueStorage_v12 프로세서는 Azure Queue Storage에서 메시지를 검색하는 프로세서예요. 기본적으로 검색한 메시지는 큐에서 삭제돼요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-azure-nar
설명 (Description)
Azure Queue Storage에서 메시지를 검색해요. 검색된 메시지는 기본적으로 큐에서 삭제돼요. 삭제하지 않고 메시지를 소비해야 한다면 'Auto Delete Messages'를 'false'로 설정해요. 참고: 메시지를 받았지만 예상치 못한 상황으로 인해 큐에서 삭제하지 못한 경우처럼 중복이 발생할 가능성이 있어요.
태그 (Tags)
azure, cloud, dequeue, microsoft, queue, storage
입력 요구 사항 (Input Requirement)
금지 (FORBIDDEN)
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
아니요 (false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Auto Delete Messages | 받은 메시지를 큐에서 자동으로 삭제할지 여부를 지정해요. |
| Credentials Service | Azure Storage 자격 증명을 얻는 데 사용하는 컨트롤러 서비스예요. |
| Endpoint Suffix | 공용 Azure의 스토리지 계정은 항상 공통 FQDN 접미사를 사용해요. 특정 상황(Azure Stack이나 비공용 Azure 리전 등)에서는 이 엔드포인트 접미사를 다른 접미사로 덮어써요. |
| Message Batch Size | 큐에서 검색할 메시지 수예요. |
| Queue Name | Azure Storage Queue의 이름이에요. |
| Request Timeout | Azure Queue Storage에 대한 읽기/쓰기 요청의 타임아웃이에요. 기본값은 1초예요. |
| Visibility Timeout | 검색한 메시지가 다른 소비자에게 보이지 않아야 하는 기간이에요. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration 컨트롤러 서비스를 지정해요. SOCKS의 경우 선택한 SOCKS 버전이 프로세서에 사용된다는 보장은 없어요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| success | 성공적으로 처리된 모든 FlowFile이 이 관계로 보내져요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
| azure.queue.uri | 구성된 Azure Queue Storage의 절대 URI예요. |
| azure.queue.insertionTime | 메시지가 큐 스토리지에 삽입된 시간이에요. |
| azure.queue.expirationTime | 메시지가 큐 스토리지에서 만료되는 시간이에요. |
| azure.queue.messageId | 검색된 메시지의 ID예요. |
| azure.queue.popReceipt | 검색된 메시지의 pop receipt예요. |