Snowflake Data Clean Rooms: 외부 데이터 커넥터 문제를 해결해요

서비스 종료 공지

레거시 Provider 및 Consumer Data Clean Rooms는 중단될 예정입니다. 날짜와 마이그레이션 지침은 end-of-life timeline을 참조하세요.

참고

Snowflake Data Clean Rooms는 현재 데이터 주체 동의 관리를 지원하지 않습니다. 고객은 자신의 clean rooms에 연결된 데이터를 사용하는 데 필요한 모든 권리와 동의를 획득했는지 확인할 책임이 있습니다. 또한 고객은 타사 커넥터와 관련하여 Data Clean Rooms를 사용할 때 적용 가능한 모든 법률 및 규정을 준수해야 합니다.

이 항목에서는 외부 데이터 오류를 해결하는 방법을 설명합니다. 이 내용은 Amazon Web Services, Microsoft Azure 및 Google Cloud에 적용됩니다.

출처: 문서

본문

외부 데이터 오류를 해결하기 위한 단계

경로 URL/URI가 올바른지 확인하세요. 올바른 URL/URI는 관련 주제를 참조하세요.
버킷 또는 Blob 스토리지에 파일이 하나 이상 있는지 확인하세요.
파일이 parquet 형식인지 확인하세요.
parquet 파일이 비어 있지 않은지 확인하세요.
parquet 파일이 Snappy 형식으로 압축되지 않았는지 확인하세요.
위의 방법으로 문제가 해결되지 않으면 다음 스크립트로 디버그하세요.

USE ROLE SAMOOHA_APP_ROLE;
USE DATABASE SAMOOHA_BY_SNOWFLAKE_LOCAL_DB;
USE SCHEMA PUBLIC;

/*
  Query the stage name from the connector configuration.
  Use AWS_CONNECTOR_ID for AWS, GCP_CONNECTOR_ID for GCP and
  AZURE_CONNECTOR_ID for Azure.

  For example, if you are connecting to AWS, enter:

  SELECT CONFIGURATION_ID, PARSE_JSON(CONFIGURATION) FROM SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.CONNECTOR_CONFIGURATION WHERE CONNECTOR_ID = 'AWS_CONNECTOR_ID';

/*
  Note that the rest of this script relies on the output of this query so you
  must save the output for use in the rest of the steps.

  Next, check the storage integration. Replace <CONFIGURATION_ID> from the output
  of the query.
*/

  DESC STORAGE INTEGRATION SAMOOHA_STORAGE_INT_<CONFIGURATION_ID>;

/*
  List files in the stage. Replace <STAGE_NAME> from the output of the query.
*/

  LIST @<STAGE_NAME>;

/*
  Check if you are able to query the files in the external stage. Replace
  <STAGE_NAME> from the output of the query.
*/

  SELECT * FROM @<STAGE_NAME> LIMIT 10;

/*
  Check if you are able to infer the schema from the files in the external
  stage. Replace <STAGE_NAME> from the output of the query.
*/

  SELECT ARRAY_AGG(OBJECT_CONSTRUCT(*))
  WITHIN GROUP (ORDER BY order_id)
  FROM TABLE(
    INFER_SCHEMA(
      LOCATION=>'@<STAGE_NAME>',
      FILE_FORMAT=>'SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.PAR_FF'
    )
  );

/*
  Try to create a table from the external stage. Replace <STAGE_NAME> from
  the output of the query.
*/

  CALL SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.LIBRARY.CREATE_TABLE_FROM_STAGE('<STAGE_NAME>', 'EXT_INT_TEMP_TABLE');

/*
  Check data in the table.
*/

  SELECT * FROM SAMOOHA_BY_SNOWFLAKE_LOCAL_DB.PUBLIC.EXT_INT_TEMP_TABLE LIMIT 10;

더 알아보기 (Learn more)

end-of-life timeline