ListenWebSocket
ListenWebSocket
WebSocket 서버 엔드포인트로 동작해 클라이언트 연결을 수락하는 프로세서예요. 이 프로세서로 구성된 WebSocket 서버가 클라이언트 요청을 수신하면 수신된 메시지 유형에 따라 FlowFiles를 다운스트림 관계로 전송해요.
출처: Snowflake 문서
본문
기능 — 일반 제공(Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP Commercial 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS Commercial 리전의 모든 계정에서 사용할 수 있어요.
Bundle
org.apache.nifi | nifi-websocket-processors-nar
설명 (Description)
클라이언트 연결을 수락하도록 WebSocket 서버 엔드포인트 역할을 해요. 이 프로세서로 구성된 WebSocket 서버가 클라이언트 요청을 수신하면, 수신된 메시지 유형에 따라 FlowFiles가 다운스트림 관계로 전송돼요.
태그 (Tags)
WebSocket, consume, listen, subscribe
입력 요구사항 (Input Requirement)
FORBIDDEN (금지)
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| Property | Description |
|---|---|
| server-url-path | 이 프로세서가 수신 대기하는 WebSocket URL Path예요. ‘/’로 시작해야 하며 예: ‘/example’. |
| websocket-server-controller-service | WebSocket 요청을 수락할 수 있는 WebSocket SERVER Controller Service예요. |
관계 (Relationships)
| Name | Description |
|---|---|
| binary message | WebSocket binary 메시지 출력이에요. |
| connected | WebSocket 세션이 수립되었을 때 연결돼요. |
| disconnected | WebSocket 세션이 끊어졌을 때 연결돼요. |
| text message | WebSocket text 메시지 출력이에요. |
쓰기 속성 (Writes attributes)
| Name | Description |
|---|---|
| websocket.controller.service.id | WebSocket Controller Service id예요. |
| websocket.session.id | 수립된 WebSocket 세션 id예요. |
| websocket.endpoint.id | WebSocket endpoint id예요. |
| websocket.local.address | WebSocket 서버 주소예요. |
| websocket.remote.address | WebSocket 클라이언트 주소예요. |
| websocket.message.type | TEXT 또는 BINARY예요. |