PublishAMQP 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-amqp-nar

설명¶

FlowFile 의 내용으로 AMQP 메시지를 생성하고 AMQP Exchange로 메시지를 보냅니다. 일반적인 AMQP 교환 모델에서 AMQP 교환으로 전송된 메시지는 ‘라우팅 키’에 따라 큐의 최종 대상(바인딩)로 라우팅됩니다. 일부 잘못된 구성으로 인해 Exchange, 라우팅 키 및 큐 간의 바인딩이 설정되지 않은 경우 메시지의 최종 대상이 없고 반환됩니다(즉, 데이터가 큐에 도달하지 못함). 이 경우 앱 로그와 게시판 모두에 해당 내용이 명시된 로그가 표시되고 FlowFile 은 ‘실패’ 관계로 라우팅됩니다.

태그¶

amqp, message, publish, put, rabbit, send

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
AMQP 버전	AMQP Version. 현재 AMQP v0.9.1만 지원합니다.
Brokers	쉼표로 구분된 알려진 AMQP 브로커 목록(<호스트>:<포트> (예: localhost:5672) 형식). 이 설정이 설정되어 있으면 호스트 이름과 포트가 무시됩니다. 동일한 AMQP 클러스터의 호스트만 포함하십시오.
클라이언트 인증서 인증 사용됨	사용자 이름/비밀번호 대신 SSL 인증서를 사용하여 인증합니다.
Exchange 이름	메시지가 전송될 AMQP Exchange의 이름입니다. 일반적으로 AMQP 관리자(예:’amq.direct’)가 제공합니다. 선택적 속성입니다. 비워두면 메시지가 기본 AMQP exchange로 전송됩니다.
헤더 패턴	FlowFile 특성에 대해 평가하여 일치하는 특성을 선택하고 AMQP 헤더로 넣을 정규식입니다. 특성 이름이 헤더 키로 사용됩니다.
헤더 소스	게시된 메시지에 적용될 헤더의 소스입니다.
Host Name	AMQP 브로커의 네트워크 주소(예: 로컬 호스트). 브로커가 설정되어 있으면 이 속성은 무시됩니다.
비밀번호	인증 및 승인에 사용되는 비밀번호입니다.
Port	AMQP 브로커의 포트를 식별하는 숫자 값(예: 5671). 브로커가 설정되어 있으면 이 속성은 무시됩니다.
라우팅 키	AMQP 에서 교환에서 대상 큐로 메시지를 라우팅하는 데 사용할 라우팅 키의 이름입니다. 일반적으로 관리자가 제공(예: ‘myKey’)메시지가 기본 교환으로 전송되는 이벤트에서 이 속성은 대상 큐 이름에 해당하며, 그렇지 않으면 라우팅 키를 통해 교환에서 큐로의 바인딩을 설정해야 합니다(일반적으로 AMQP 관리자가 수행)
SSL 컨텍스트 서비스	SSL 컨텍스트 서비스는 TLS/SSL 연결에 대한 클라이언트 인증서 정보를 제공하는 데 사용됩니다.
사용자 이름	인증 및 승인에 사용되는 사용자 이름입니다.
Virtual Host	보안 개선을 위해 AMQP 시스템을 분리하는 가상 호스트 이름입니다.
header.separator	헤더의 키-값을 분할하는 데 사용되는 문자입니다. 값은 한 문자만 입력해야 합니다. 그렇지 않으면 오류 메시지가 표시됩니다

관계¶

이름	설명
실패	AMQP 대상으로 라우팅할 수 없는 모든 FlowFiles 은 이 관계로 라우팅됩니다
성공	AMQP 대상으로 전송되는 모든 FlowFiles 은 이 관계로 라우팅됩니다