PublishMQTT 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-mqtt-nar
설명¶
MQTT 항목에 메시지를 게시합니다
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
브로커 URI |
MQTT 브로커(예: tcp://localhost:1883)에 연결할 때 사용할 URI 를 입력합니다. ‘tcp’, ‘ssl’, ‘ws’ 및 ‘wss’ 체계가 지원됩니다. ‘ssl’을 사용하려면 SSL Context Service 속성을 설정해야 합니다. 쉼표로 구분된 URI 목록이 설정된 경우(예: tcp://localhost:1883,tcp://localhost:1884), 프로세서는 연결 실패 시 라운드 로빈 알고리즘을 사용하여 브로커에 연결합니다. |
Client ID |
사용할 MQTT 클라이언트 ID 설정하지 않으면 UUID 가 생성됩니다. |
Connection Timeout (seconds) |
클라이언트가 MQTT 서버에 대한 네트워크 연결이 설정될 때까지 기다리는 최대 시간 간격입니다. 기본 시간 제한은 30초입니다. 값이 0이면 시간 제한 처리를 비활성화하여 클라이언트가 네트워크 연결이 성공하거나 실패할 때까지 기다립니다. |
Keep Alive Interval (seconds) |
주고받는 메시지 사이의 최대 시간 간격을 정의합니다. 이를 통해 클라이언트는 TCP/IP 시간 제한을 기다릴 필요 없이 서버를 더 이상 사용할 수 없는지 감지할 수 있습니다. 클라이언트는 각 킵 얼라이브 기간 동안 적어도 1개의 메시지가 네트워크를 통해 전달되도록 합니다. 해당 기간 동안 데이터 관련 메시지가 없는 경우 클라이언트는 매우 작은 “Ping” 메시지를 보내면 서버가 이를 확인합니다. 값이 0이면 클라이언트에서 keepalive 처리를 비활성화합니다. |
Last Will Message |
클라이언트의 Last Will로 보낼 메시지입니다. |
Last Will QoS Level |
Last Will 메시지를 게시할 때 사용할 QoS 레벨입니다. |
Last Will 유지 |
클라이언트의 Last Will 보관 여부. |
Last Will 토픽 |
클라이언트의 Last Will을 보낼 토픽입니다. |
MQTT 사양 버전 |
브로커와 연결할 때 MQTT 사양 버전입니다. 자세한 내용은 허용되는 값 설명을 참조하십시오. |
비밀번호 |
브로커에 연결할 때 사용할 비밀번호 |
서비스 품질(QoS) |
메시지를 보낼 서비스 품질(QoS)을 선택합니다. ‘0’, ‘1’, ‘2’의 세 가지 값을 허용합니다. ‘0’은 ‘최대 한 번’, ‘1’은 ‘최소 한 번’, ‘2’는 ‘정확히 한 번’을 의미합니다. QoS 가 다른 메시지 게시를 지원하기 위해 식 언어가 허용되지만 속성의 끝값은 ‘0’, ‘1’ 또는 ‘2’ 중 하나여야 합니다. |
메시지 유지 |
MQTT 메시지에 보존 플래그를 설정할지 여부입니다. |
SSL 컨텍스트 서비스 |
SSL 컨텍스트 서비스는 TLS/SSL 연결에 대한 클라이언트 인증서 정보를 제공하는 데 사용됩니다. |
Session Expiry Interval |
이 간격이 지나면 브로커는 클라이언트를 만료하고 세션 상태를 지웁니다. |
세션 상태 |
새로 시작할지 아니면 이전 플로우를 재개할지 여부를 결정합니다. 자세한 내용은 허용되는 값 설명을 참조하십시오. |
항목 |
메시지를 게시할 항목입니다. |
사용자 이름 |
브로커에 연결할 때 사용할 사용자 이름 |
message-demarcator |
이 속성을 사용하면 1개의 FlowFile 에서 여러 메시지를 게시할 수 있는 옵션이 있습니다. 이 속성을 사용하면 FlowFile 내용을 구분하는 데 사용할 문자열(UTF-8로 해석됨)을 제공할 수 있습니다. 이 속성은 선택 속성으로, 제공하지 않고 Record Reader/작성기를 정의하지 않으면 각 FlowFile 은 단일 메시지로 게시됩니다. ‘new line’과 같은 특수 문자를 입력하려면 OS 에 따라 CTRL+Enter 또는 Shift+Enter를 사용하십시오. |
record-reader |
수신 FlowFile 을 레코드로 구문 분석하는 데 사용할 Record Reader입니다. |
record-writer |
MQTT 메시지로 게시하기 전에 레코드를 직렬화하는 데 사용할 Record Writer입니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
대상으로 보내지 못한 FlowFiles 은 이 관계로 전송됩니다. |
성공 |
대상에게 성공적으로 전송된 FlowFiles 은 이 관계로 전송됩니다. |