PutWebSocket 프로세서
PutWebSocket 프로세서
PutWebSocket은 ListenWebSocket 또는 ConnectWebSocket에 의해 수립된 WebSocket 세션을 사용해 WebSocket 원격 endpoint에 메시지를 보내는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-websocket-processors-nar
설명
ListenWebSocket 또는 ConnectWebSocket에 의해 수립된 WebSocket 세션을 사용해 WebSocket 원격 endpoint에 메시지를 보내요.
Tags WebSocket, publish, send
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| websocket-controller-service-id | WebSocket ControllerService의 id를 가져오는 NiFi 표현식이에요. |
| websocket-endpoint-id | WebSocket ControllerService의 endpoint id를 가져오는 NiFi 표현식이에요. |
| websocket-message-type | 메시지 내용 타입: TEXT 또는 BINARY. |
| websocket-session-id | 세션 id를 가져오는 NiFi 표현식이에요. 지정하지 않으면 WebSocket controller service endpoint에 연결된 모든 WebSocket 피어에게 메시지가 보내져요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | 대상으로 보내지 못한 FlowFile이 이 관계로 전송돼요. |
| success | 대상으로 성공적으로 보내진 FlowFile이 이 관계로 전송돼요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| websocket.controller.service.id | WebSocket Controller Service id예요. |
| websocket.session.id | 수립된 WebSocket 세션 id예요. |
| websocket.endpoint.id | WebSocket endpoint id예요. |
| websocket.message.type | TEXT 또는 BINARY예요. |
| websocket.local.address | WebSocket 서버 주소예요. |
| websocket.remote.address | WebSocket 클라이언트 주소예요. |
| websocket.failure.detail | 실패 상세 정보예요. |