ConnectWebSocket 프로세서

이 문서는 Snowflake OpenFlow의 ConnectWebSocket 프로세서에 대한 참조 문서예요. 원격 WebSocket 서버와 상호작용하는 WebSocket 클라이언트 엔드포인트 역할을 하며, 받은 메시지 유형에 따라 FlowFiles를 하위 관계로 전달해요.

출처: Snowflake 문서

본문

기능 — 일반 제공 (Generally Available)

Openflow Snowflake 배포는 AWS, Azure, GCP Commercial 리전의 모든 계정에서 사용할 수 있어요.

Openflow BYOC 배포는 AWS Commercial 리전의 모든 계정에서 사용할 수 있어요.

번들 (Bundle)

그룹	NAR
org.apache.nifi	nifi-websocket-processors-nar

설명 (Description)

원격 WebSocket 서버와 상호작용하는 WebSocket 클라이언트 엔드포인트 역할을 해요. 이 프로세서로 구성된 WebSocket 클라이언트는 원격 WebSocket 서버로부터 메시지를 받고, 받은 메시지 유형에 따라 FlowFiles를 하위 관계로 전달해요. 새 flowfile이 프로세서로 전달되면 이전 세션은 닫히고 전송 중이던 데이터는 중단돼요.

태그 (Tags)

WebSocket, consume, listen, subscribe

입력 요구사항 (Input Requirement)

ALLOWED

민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)

아니요 (false)

속성 (Properties)

속성	설명
websocket-client-controller-service	WebSocket 서버에 연결할 수 있는 WebSocket CLIENT Controller Service예요.
websocket-client-id	WebSocket 세션을 식별하는 클라이언트 ID예요. WebSocket Client Controller Service 내에서 고유해야 해요. 그렇지 않으면 시작할 때 WebSocketConfigurationException이 발생해요.

관계 (Relationships)

이름	설명
binary message	WebSocket 바이너리 메시지 출력이에요.
connected	WebSocket 세션이 수립되었어요.
disconnected	WebSocket 세션이 끊어졌어요.
failure	연결 실패 시 연결 구성 속성(URL 또는 HTTP 헤더 등)을 담은 FlowFile이에요.
success	연결 성공 시 연결 구성 속성(URL 또는 HTTP 헤더 등)을 담은 FlowFile이에요.
text message	WebSocket 텍스트 메시지 출력이에요.

기록하는 속성 (Writes attributes)

이름	설명
websocket.controller.service.id	WebSocket Controller Service ID예요.
websocket.session.id	수립된 WebSocket 세션 ID예요.
websocket.endpoint.id	WebSocket 엔드포인트 ID예요.
websocket.local.address	WebSocket 클라이언트 주소예요.
websocket.remote.address	WebSocket 서버 주소예요.
websocket.message.type	`TEXT` 또는 `BINARY`예요.

ConnectWebSocket 프로세서