ConsumeAMQP 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-amqp-nar
설명¶
AMQP 0.9.1 프로토콜을 사용하여 AMQP 브로커의 AMQP 메시지를 소비합니다. AMQP 브로커로부터 수신되는 각 메시지는 ‘성공’ 관계에 대한 자체 FlowFile 로 전송됩니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
AMQP 버전 |
AMQP Version. 현재 AMQP v0.9.1만 지원합니다. |
Brokers |
쉼표로 구분된 알려진 AMQP 브로커 목록(<호스트>:<포트> (예: localhost:5672) 형식). 이 설정이 설정되어 있으면 호스트 이름과 포트가 무시됩니다. 동일한 AMQP 클러스터의 호스트만 포함하십시오. |
클라이언트 인증서 인증 사용됨 |
사용자 이름/비밀번호 대신 SSL 인증서를 사용하여 인증합니다. |
Host Name |
AMQP 브로커의 네트워크 주소(예: 로컬 호스트). 브로커가 설정되어 있으면 이 속성은 무시됩니다. |
Max Inbound Message Body Size |
인바운드(수신) 메시지의 최대 본문 크기입니다. |
비밀번호 |
인증 및 승인에 사용되는 비밀번호입니다. |
Port |
AMQP 브로커의 포트를 식별하는 숫자 값(예: 5671). 브로커가 설정되어 있으면 이 속성은 무시됩니다. |
Queue |
메시지를 소비할 기존 AMQP 큐의 이름입니다. 일반적으로 AMQP 관리자가 미리 정의합니다. |
SSL 컨텍스트 서비스 |
SSL 컨텍스트 서비스는 TLS/SSL 연결에 대한 클라이언트 인증서 정보를 제공하는 데 사용됩니다. |
사용자 이름 |
인증 및 승인에 사용되는 사용자 이름입니다. |
Virtual Host |
보안 개선을 위해 AMQP 시스템을 분리하는 가상 호스트 이름입니다. |
auto.acknowledge |
false(비자동 승인)인 경우 FlowFiles 을 성공으로 전송하고 NiFi 세션을 커밋한 후 프로세서가 메시지를 승인합니다. 비자동 승인 모드는 ‘at-least-once’ 전송 의미 체계를 제공합니다. true(자동 승인)로 설정하면 AMQP 클라이언트로 전달되는 메시지는 전송 직후 AMQP 브로커에서 자동 승인됩니다. 이렇게 하면 일반적으로 처리량이 향상되지만 AMQP 브로커, NiFi 또는 프로세서를 다시 시작하거나 충돌할 때 메시지가 손실될 수 있습니다. 자동 승인 모드는 ‘최대 한 번’ 전송 의미 체계를 제공하며 메시지 손실이 허용되는 경우에만 권장됩니다. |
batch.size |
단일 세션에서 처리해야 하는 최대 메시지 수입니다. 이러한 많은 메시지가 수신되면(또는 더 이상 사용할 수 있는 메시지가 없을 경우) 수신된 메시지는 ‘성공’ 관계로 전환되고 AMQP 브로커에게 메시지가 승인됩니다. 이 값을 더 크게 설정하면 특히 매우 작은 메시지의 경우 성능이 향상될 수 있지만, NiFi 를 갑자기 다시 시작할 때 더 많은 메시지가 중복될 수 있습니다. |
header.format |
수신된 메시지에서 헤더를 출력하는 방법을 정의합니다 |
header.key.prefix |
FlowFile 특성에 추가될 때 헤더 키에 접두사로 붙일 텍스트입니다. 프로세서는 이 속성의 값에 ‘.’를 추가합니다 |
header.separator |
헤더의 키-값을 문자열로 구분하는 데 사용되는 문자입니다. 값은 한 문자만 입력해야 합니다. |
prefetch.count |
컨슈머의 승인되지 않은 최대 메시지 수입니다. 컨슈머가 승인하지 않은 메시지가 이 수만큼 있는 경우, AMQP 브로커는 컨슈머가 이미 전달된 메시지 중 일부를 승인할 때까지 더 이상 새 메시지를 보내지 않습니다. 허용되는 값: 0~65535. 0은 제한이 없음을 의미합니다 |
remove.curly.braces |
중괄호 제거가 true이면 헤더의 중괄호가 자동으로 제거됩니다. |
관계¶
이름 |
설명 |
|---|---|
성공 |
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 |