CREATE OPENFLOW CONNECTOR

CREATE OPENFLOW CONNECTOR

gen 2 런타임에 커넥터(connector)를 만드는 명령이에요. 커넥터는 특정 데이터 소스(예: PostgreSQL CDC)와 Snowflake 사이의 데이터 흐름을 구성하는 Openflow 객체예요.

출처: 문서

본문

gen 2 런타임에 커넥터를 만들어요.

함께 보기: ALTER OPENFLOW CONNECTOR, DROP OPENFLOW CONNECTOR, SHOW OPENFLOW CONNECTOR DEFINITIONS, SHOW OPENFLOW CONNECTORS, DESCRIBE OPENFLOW CONNECTOR, SHOW VERSIONS IN OPENFLOW CONNECTOR

구문 (Syntax)

CREATE OPENFLOW CONNECTOR [ IF NOT EXISTS ] <name>
  IN RUNTIME <runtime_name>
  FROM DEFINITION <connector_definition_id>
  [ DISPLAY_NAME = <string> ]
  [ COMMENT = <string> ]

CREATE OPENFLOW CONNECTOR [ IF NOT EXISTS ] <name>
  IN RUNTIME <runtime_name>
  FROM '<stage_reference>'
  [ COMMENT = <string> ]

필수 매개변수 (Required parameters)

name 런타임의 스키마 안에서 커넥터의 식별자를 지정해요. 자세한 내용은 식별자 요구 사항(Identifier requirements)을 참고해요.

IN RUNTIME runtime_name 커넥터를 호스팅하는 gen 2 런타임이에요. 단순 이름 또는 정규화된 이름(<database>.<schema>.<runtime_name>)으로 지정해요.

다음 소스 매개변수 중 정확히 하나가 필요해요.

FROM DEFINITION connector_definition_id 커넥터 유형의 카탈로그 정의 ID예요 (예: OPENFLOW_POSTGRES_CDC). 사용 가능한 ID는 SHOW OPENFLOW CONNECTOR DEFINITIONS로 확인할 수 있어요. FROM '<stage_reference>'와 상호 배타적이에요. 라이브(live) 구성 버전을 만들며, 커밋하기 전까지 커넥터는 커밋된 기본 버전 없이 시작돼요.

FROM 'stage_reference' 모든 스테이지 참조에 있는 완전한 구성 번들(bundle)이에요 — Git 저장소 스테이지(@my_git_repo/...), 내부 이름 지정 스테이지, 또는 다른 커넥터의 스테이지(snow://openflow_connector/...)가 될 수 있어요. 스테이지 안의 경로는 선택적이에요. FROM DEFINITION과 상호 배타적이에요. 기본 버전을 만들며, 커밋 없이 커넥터가 즉시 시작할 수 있어요. gen 2 커넥터 구성과 버전 관리의 알려진 구성에서 만들기(Create from a known configuration)를 참고해요.

선택 매개변수 (Optional parameters)

IF NOT EXISTS 커넥터가 이미 존재하지 않을 때만 만들도록 해요. 커넥터가 이미 존재하면 문은 아무것도 하지 않고 성공 메시지를 반환해요.

DISPLAY_NAME = string UI 표시 이름이에요.

  • 기본값: 값 없음

COMMENT = string

  • 기본값: 값 없음

접근 제어 (Access control)

스키마에 대한 CREATE OPENFLOW CONNECTOR 권한과 런타임에 대한 USAGE 권한이 필요해요.

예시 (Examples)

정의(definition)로부터 만들기:

CREATE OPENFLOW CONNECTOR my_db.my_schema.my_postgres_connector
  IN RUNTIME my_db.my_schema.my_runtime
  FROM DEFINITION OPENFLOW_POSTGRES_CDC
  DISPLAY_NAME = 'My Postgres CDC Connector';

스테이지 참조로부터 만들기:

-- From a Git repository stage
CREATE OPENFLOW CONNECTOR my_db.my_schema.my_connector
  IN RUNTIME my_db.my_schema.my_runtime
  FROM '@my_git_repo/branches/main/connectors/my_connector/'
  COMMENT = 'Created from Git stage';

-- From another connector's committed configuration
CREATE OPENFLOW CONNECTOR my_db.my_schema.my_connector_copy
  IN RUNTIME my_db.my_schema.my_other_runtime
  FROM 'snow://openflow_connector/my_db.my_schema.my_connector/versions/LAST/'
  COMMENT = 'Cloned from existing connector';

더 알아보기 (Learn more)