PublishAMQP
PublishAMQP
FlowFile 내용에서 AMQP 메시지를 만들어 AMQP Exchange로 보내는 프로세서예요.
본문
번들 (Bundle)
org.apache.nifi | nifi-amqp-nar
설명
FlowFile 내용에서 AMQP 메시지를 만들어 AMQP Exchange로 보내요. 일반적인 AMQP exchange 모델에서 Exchange로 보낸 메시지는 'Routing Key'를 기준으로 큐의 최종 목적지(binding)로 라우팅돼요. Exchange, Routing Key, Queue 사이의 binding이 잘못 설정되어 있으면 메시지에 최종 목적지가 없어 반환돼요(즉, 데이터가 큐에 도달하지 못해요). 그런 경우 app-log와 bulletin에 그 사실을 알리는 로그가 표시되고 FlowFile이 'failure' 관계로 라우팅돼요.
태그
amqp, message, publish, put, rabbit, send
입력 요구 사항 (Input Requirement)
REQUIRED — 입력 FlowFile이 필요해요.
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false — 지원하지 않아요.
속성 (Properties)
| 속성 | 설명 |
|---|---|
| AMQP Version | AMQP 버전이에요. 현재는 AMQP v0.9.1만 지원해요. |
| Brokers | 알려진 AMQP Broker의 쉼표로 구분된 목록으로 <host>:<port> 형식이에요(예: localhost:5672). 설정하면 Host Name과 Port는 무시돼요. 같은 AMQP 클러스터의 호스트만 포함하세요. |
| Client Certificate Authentication Enabled | 사용자 이름/암호가 아닌 SSL 인증서로 인증해요. |
| Exchange Name | 메시지가 보내질 AMQP Exchange의 이름이에요. 보통 AMQP 관리자가 제공해요(예: 'amq.direct'). 선택 속성으로, 비워두면 기본 AMQP exchange로 메시지가 보내져요. |
| Header Separator | 헤더의 키-값을 구분하는 데 사용하는 문자예요. 값은 한 문자여야 해요. 그렇지 않으면 오류 메시지가 표시돼요. |
| Headers Pattern | FlowFile 속성에 대해 평가되어 일치하는 속성을 선택해 AMQP 헤더로 넣는 정규식이에요. 속성 이름이 헤더 키로 사용돼요. |
| Headers Source | 게시되는 메시지에 적용될 헤더의 소스예요. |
| Host Name | AMQP broker의 네트워크 주소예요(예: localhost). Brokers가 설정되면 이 속성은 무시돼요. |
| Password | 인증 및 권한 부여에 사용되는 암호예요. |
| Port | AMQP broker의 포트를 나타내는 숫자 값이에요(예: 5671). Brokers가 설정되면 이 속성은 무시돼요. |
| Routing Key | AMQP가 exchange에서 대상 큐로 메시지를 라우팅하는 데 사용하는 Routing Key 이름이에요. 보통 관리자가 제공해요(예: 'myKey'). 메시지가 기본 exchange로 보내질 때 이 속성은 대상 큐 이름에 해당하며, 그 외에는 Routing Key를 통한 Exchange-Queue binding이 설정되어 있어야 해요(보통 AMQP 관리자). |
| SSL Context Service | TLS/SSL 연결을 위한 클라이언트 인증서 정보를 제공하는 SSL Context Service예요. |
| Username | 인증 및 권한 부여에 사용되는 사용자 이름이에요. |
| Virtual Host | 보안 강화를 위해 AMQP 시스템을 분리하는 Virtual Host 이름이에요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
failure |
AMQP 목적지로 라우팅될 수 없는 모든 FlowFile이 이 관계로 라우팅돼요. |
success |
AMQP 목적지로 전송된 모든 FlowFile이 이 관계로 라우팅돼요. |