Snowflake Connector for Kafka: Snowflake 구성
Snowflake Connector for Kafka: Snowflake 구성 (Snowflake Connector for Kafka: Configure Snowflake)
이 문서는 Snowflake Connector for Kafka를 Snowflake 쪽에서 어떻게 준비하는지 단계별로 설명해요.
본문
Snowflake 계정 준비
Kafka 커넥터를 사용하려면 Snowflake에 다음과 같은 객체와 권한을 준비해야 해요.
데이터베이스와 스키마
Kafka 토픽의 데이터를 로드할 데이터베이스와 스키마를 만들어요. 예를 들어:
CREATE DATABASE IF NOT EXISTS kafka_db;
CREATE SCHEMA IF NOT EXISTS kafka_db.kafka_schema;
사용자와 역할
커넥터가 사용할 전용 사용자와 역할을 만들어요. 보안상 커넥터 전용 역할을 만드는 것이 좋아요:
CREATE ROLE IF NOT EXISTS kafka_connector_role;
CREATE USER IF NOT EXISTS kafka_connector_user
PASSWORD = '<password>'
MUST_CHANGE_PASSWORD = FALSE;
GRANT ROLE kafka_connector_role TO USER kafka_connector_user;
ALTER USER kafka_connector_user SET DEFAULT_ROLE = kafka_connector_role;
권한 부여
커넥터 역할에 데이터베이스, 스키마, 테이블에 대한 권한을 부여해요:
GRANT USAGE ON DATABASE kafka_db TO ROLE kafka_connector_role;
GRANT USAGE ON SCHEMA kafka_db.kafka_schema TO ROLE kafka_connector_role;
GRANT CREATE STAGE ON SCHEMA kafka_db.kafka_schema TO ROLE kafka_connector_role;
GRANT CREATE PIPE ON SCHEMA kafka_db.kafka_schema TO ROLE kafka_connector_role;
GRANT CREATE TABLE ON SCHEMA kafka_db.kafka_schema TO ROLE kafka_connector_role;
GRANT CREATE FILE FORMAT ON SCHEMA kafka_db.kafka_schema TO ROLE kafka_connector_role;
인증 설정
Kafka 커넥터는 다음 인증 방법 중 하나를 사용해요:
- 키 페어 인증: 키 페어 인증 문서를 참고해 프라이빗 키를 준비하세요.
- OAuth: Kafka 커넥터 OAuth 구성을 참고하세요.
다음 단계
Snowflake 쪽 구성이 끝났으면 Kafka 구성으로 넘어가 커넥터 자체를 설정하세요.