Openflow Connector for SQL Server 설정¶

전제 조건¶

1. Openflow Connector for SQL Server 정보 을 검토했는지 확인합니다.

2. 지원되는 SQL 서버 버전 을 검토했는지 확인합니다.

3. Openflow를 설정 했는지 확인합니다.

4. 데이터베이스 관리자는 다음 작업을 수행합니다.

   1. 데이터베이스 및 테이블 에서 변경 사항 추적을 활성화합니다. 커넥터는 복제를 시작하기 전에 데이터베이스 및 테이블에서 변경 내용 추적을 사용하도록 설정해야 합니다. 복제할 계획인 모든 테이블에서 변경 내용 추적을 사용하도록 설정했는지 확인하십시오. 커넥터가 실행되는 동안 더 많은 테이블에 대해 변경 추적을 활성화할 수도 있습니다. 다음 코드 스니펫을 참조하십시오.

      ALTER DATABASE <database>
      SET CHANGE_TRACKING = ON
      (CHANGE_RETENTION = 2 DAYS, AUTO_CLEANUP = ON);
      
      ALTER TABLE <schema>.<table>
      ENABLE CHANGE_TRACKING
      WITH (TRACK_COLUMNS_UPDATED = ON);
      

      Copy

   2. 커넥터에 대한 사용자를 생성합니다. 커넥터에는 복제된 테이블에 대한 VIEW CHANGE TRACKING 권한이 있는 사용자가 필요합니다. 해당 사용자에게 커넥터의 구성에 액세스할 수 있는 비밀번호를 부여합니다.

      CREATE LOGIN <user_name> WITH PASSWORD = <password>;
      CREATE USER <user_name> FOR LOGIN <user_name>;
      GRANT SELECT ON <schema>.<table> TO <user_name>;
      GRANT VIEW CHANGE TRACKING ON <schema>.<table> TO <user_name>;
      

      Copy

   3. SSL 을 통해 연결합니다. SQL 서버에 SSL 연결을 사용할 계획이라면 데이터베이스 서버에 대한 루트 인증서를 준비합니다. 이는 구성 중에 필수입니다.

5. Snowflake 계정 관리자는 다음 작업을 수행합니다.

   1. 유형이 SERVICE 인 Snowflake 사용자를 생성합니다. 복제된 데이터를 저장할 데이터베이스를 생성하고 USAGE 및 CREATE SCHEMA 권한 을 부여하여 해당 데이터베이스에 오브젝트를 생성할 수 있도록 Snowflake 사용자에게 권한을 설정합니다.

      CREATE DATABASE <destination_database>;
      CREATE USER <openflow_user> TYPE=SERVICE COMMENT='Service user for automated access of Openflow';
      CREATE ROLE <openflow_role>;
      GRANT ROLE <openflow_role> TO USER <openflow_user>;
      GRANT USAGE ON DATABASE <destination_database> TO ROLE <openflow_role>;
      GRANT CREATE SCHEMA ON DATABASE <destination_database> TO ROLE <openflow_role>;
      CREATE WAREHOUSE <openflow_warehouse>
           WITH
               WAREHOUSE_SIZE = 'MEDIUM'
               AUTO_SUSPEND = 300
               AUTO_RESUME = TRUE;
      GRANT USAGE, OPERATE ON WAREHOUSE <openflow_warehouse> TO ROLE <openflow_role>;
      

      Copy

   2. 한 쌍의 보안 키(공개 및 비공개)를 생성합니다. 사용자의 개인 키를 파일에 저장하여 커넥터의 구성에 제공합니다. Snowflake 서비스 사용자에게 공개 키를 할당합니다.

      ALTER USER <openflow_user> SET RSA_PUBLIC_KEY = 'thekey';
      

      Copy

      자세한 내용은 키 페어 인증 및 키 페어 순환 섹션을 참조하십시오.

   3. 커넥터가 사용할 웨어하우스를 지정합니다. MEDIUM 데이터 웨어하우스 크기로 시작한 다음 복제되는 테이블의 수와 전송되는 데이터의 양에 따라 크기를 실험해 보십시오. 일반적으로 테이블 수가 많을수록 웨어하우스 크기보다는 멀티 클러스터 웨어하우스 에서 확장이 더 쉽습니다.

커넥터 설정하기¶

데이터 엔지니어는 다음 작업을 수행하여 커넥터를 구성합니다.

[
    {
        "schema": "<source table schema>",
        "table" : "<source table name>",
        "included": ["<column name>", "<column name>"],
        "excluded": ["<column name>", "<column name>"],
        "includedPattern": "<regular expression>",
        "excludedPattern": "<regular expression>",
    }
]

플로우 실행¶

1. 평면을 마우스 오른쪽 버튼으로 클릭하고 Enable all Controller Services 를 선택합니다.

2. 가져온 프로세스 그룹을 마우스 오른쪽 버튼으로 클릭하고 Start 를 선택합니다. 커넥터가 데이터 수집을 시작합니다.