ConsumeAMQP 2025.10.2.19¶
번들¶
org.apache.nifi | nifi-amqp-nar
설명¶
AMQP 0.9.1 프로토콜을 사용하여 AMQP 브로커의 AMQP 메시지를 소비합니다. AMQP 브로커로부터 수신되는 각 메시지는 ‘성공’ 관계에 대한 자체 FlowFile 로 전송됩니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
AMQP 버전 |
AMQP Version. 현재 AMQP v0.9.1만 지원합니다. |
Auto-Acknowledge Messages |
false(비자동 승인)인 경우 FlowFiles 을 성공으로 전송하고 NiFi 세션을 커밋한 후 프로세서가 메시지를 승인합니다. 비자동 승인 모드는 ‘at-least-once’ 전송 의미 체계를 제공합니다. true(자동 승인)로 설정하면 AMQP 클라이언트로 전달되는 메시지는 전송 직후 AMQP 브로커에서 자동 승인됩니다. 이렇게 하면 일반적으로 처리량이 향상되지만 AMQP 브로커, NiFi 또는 프로세서를 다시 시작하거나 충돌할 때 메시지가 손실될 수 있습니다. 자동 승인 모드는 ‘최대 한 번’ 전송 의미 체계를 제공하며 메시지 손실이 허용되는 경우에만 권장됩니다. |
Batch Size |
단일 세션에서 처리해야 하는 최대 메시지 수입니다. 이러한 많은 메시지가 수신되면(또는 더 이상 사용할 수 있는 메시지가 없을 경우) 수신된 메시지는 ‘성공’ 관계로 전환되고 AMQP 브로커에게 메시지가 승인됩니다. 이 값을 더 크게 설정하면 특히 매우 작은 메시지의 경우 성능이 향상될 수 있지만, NiFi 를 갑자기 다시 시작할 때 더 많은 메시지가 중복될 수 있습니다. |
Brokers |
쉼표로 구분된 알려진 AMQP 브로커 목록(<호스트>:<포트> (예: localhost:5672) 형식). 이 설정이 설정되어 있으면 호스트 이름과 포트가 무시됩니다. 동일한 AMQP 클러스터의 호스트만 포함하십시오. |
클라이언트 인증서 인증 사용됨 |
사용자 이름/비밀번호 대신 SSL 인증서를 사용하여 인증합니다. |
Header Key Prefix |
FlowFile 특성에 추가될 때 헤더 키에 접두사로 붙일 텍스트입니다. 프로세서는 이 속성의 값에 ‘.’를 추가합니다 |
Header Output Format |
수신된 메시지에서 헤더를 출력하는 방법을 정의합니다 |
Header Separator |
헤더의 키-값을 문자열로 구분하는 데 사용되는 문자입니다. 값은 한 문자만 입력해야 합니다. |
Host Name |
AMQP 브로커의 네트워크 주소(예: 로컬 호스트). 브로커가 설정되어 있으면 이 속성은 무시됩니다. |
Max Inbound Message Body Size |
인바운드(수신) 메시지의 최대 본문 크기입니다. |
비밀번호 |
인증 및 승인에 사용되는 비밀번호입니다. |
Port |
AMQP 브로커의 포트를 식별하는 숫자 값(예: 5671). 브로커가 설정되어 있으면 이 속성은 무시됩니다. |
Prefetch Count |
The maximum number of unacknowledged messages for the consumer. If consumer has this number of unacknowledged messages, AMQP broker will no longer send new messages until consumer acknowledges some of the messages already delivered to it. Allowed values: from 0 to 65535.0 means no limit |
Queue |
메시지를 소비할 기존 AMQP 큐의 이름입니다. 일반적으로 AMQP 관리자가 미리 정의합니다. |
Remove Curly Braces |
중괄호 제거가 true이면 헤더의 중괄호가 자동으로 제거됩니다. |
SSL 컨텍스트 서비스 |
SSL 컨텍스트 서비스는 TLS/SSL 연결에 대한 클라이언트 인증서 정보를 제공하는 데 사용됩니다. |
사용자 이름 |
인증 및 승인에 사용되는 사용자 이름입니다. |
Virtual Host |
보안 개선을 위해 AMQP 시스템을 분리하는 가상 호스트 이름입니다. |
관계¶
이름 |
설명 |
|---|---|
성공 |
AMQP 큐에서 수신되는 모든 FlowFiles 은 이 관계로 라우팅됩니다 |
Writes 특성¶
이름 |
설명 |
|---|---|
amqp$appId |
AMQP 메시지의 앱 ID 필드 |
amqp$contentEncoding |
AMQP 메시지에 의해 보고된 내용 인코딩 |
amqp$contentType |
AMQP 메시지에 의해 보고된 내용 유형 |
amqp$headers |
AMQP 메시지에 표시되는 헤더. 프로세서가 이 특성을 출력하도록 구성된 경우에만 추가됩니다. |
<헤더 키 접두사>.<특성> |
프로세서가 헤더를 특성으로 출력하도록 구성된 경우 각 메시지 헤더에 이 특성 이름이 삽입됩니다 |
amqp$deliveryMode |
메시지의 전달 모드에 대한 숫자 표시기입니다. |
amqp$priority |
메시지 우선 순위 |
amqp$correlationId |
메시지의 상관관계 ID |
amqp$replyTo |
메시지의 Reply-To 필드 값입니다 |
amqp$expiration |
메시지 설명 |
amqp$messageId |
메시지의 고유 ID |
amqp$timestamp |
epoch 이후 밀리초 단위로 표시되는 메시지의 타임스탬프입니다 |
amqp$type |
메시지의 유형 |
amqp$userId |
사용자의 ID |
amqp$clusterId |
AMQP 클러스터의 ID |
amqp$routingKey |
AMQP 메시지의 라우팅 키 |
amqp$exchange |
AMQP 메시지를 수신한 exchange |