ConnectWebSocket 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-websocket-processors-nar
설명¶
원격 WebSocket 서버와 상호 작용하는 WebSocket 클라이언트 엔드포인트의 역할을 합니다. FlowFiles 은 이 프로세서로 구성된 WebSocket 클라이언트가 원격 WebSocket 서버로부터 메시지를 수신하면 수신된 메시지 유형에 따라 다운스트림 관계로 전송됩니다. 새 flowfile이 프로세서로 전달되면 이전 세션이 닫히고 전송 중인 모든 데이터가 중단됩니다.
입력 요구 사항¶
ALLOWED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
websocket-client-controller-service |
WebSocket 서버에 연결할 수 있는 WebSocket CLIENT 컨트롤러 서비스입니다. |
websocket-client-id |
클라이언트 ID 는 WebSocket 세션을 식별합니다. WebSocket 클라이언트 컨트롤러 서비스 내에서 고유해야 합니다. 그렇지 않으면, 시작될 때 WebSocketConfigurationException 을 throw합니다. |
관계¶
이름 |
설명 |
|---|---|
binary message |
WebSocket 이진 메시지 출력은 다음과 같습니다 |
connected |
WebSocket 세션이 연결됩니다 |
disconnected |
WebSocket 세션 연결이 끊어졌습니다 |
실패 |
연결 실패 시 연결 구성 특성(예: URL 또는 HTTP 헤더)이 있는 FlowFile |
성공 |
연결에 성공한 경우 연결 구성 특성(예: URL 또는 HTTP 헤더)이 있는 FlowFile |
text message |
WebSocket 텍스트 메시지 출력 |
Writes 특성¶
이름 |
설명 |
|---|---|
websocket.controller.service.id |
WebSocket 컨트롤러 서비스 ID입니다. |
websocket.session.id |
설정된 WebSocket 세션 ID입니다. |
websocket.endpoint.id |
WebSocket 엔드포인트 ID입니다. |
websocket.local.address |
WebSocket 클라이언트 주소입니다. |
websocket.remote.address |
WebSocket 서버 주소입니다. |
websocket.message.type |
TEXT 또는 BINARY. |