Snowflake Data Clean Rooms:solução de problemas de conectores de dados externos

Nota

Snowflake Data Clean Rooms atualmente não oferecem suporte ao gerenciamento do consentimento do titular dos dados. Os clientes são responsáveis por garantir que obtiveram todos os direitos e consentimentos necessários para usar os dados vinculados em suas salas limpas. Os clientes também devem garantir a conformidade com todas as leis e regulamentos aplicáveis ao usar o Data Clean Rooms, inclusive em conexão com conectores de terceiros.

Este tópico descreve como solucionar erros de dados externos. Isso se aplica ao Amazon Web Services, Microsoft Azure e Google Cloud.

Etapas a seguir para solucionar erros de dados externos

  1. Certifique-se de que o caminho URL/URI esteja correto. Veja o tópico relacionado associado para o URL/URI correto.

  2. Certifique-se de que haja pelo menos um arquivo no bucket ou no armazenamento de blobs.

  3. Certifique-se de que o arquivo esteja no formato parquet.

  4. Certifique-se de que o arquivo parquet não esteja vazio.

  5. Certifique-se de que o arquivo parquet não esteja compactado usando o formato Snappy.

  6. Se nenhuma das opções acima resolver o problema, faça a depuração com o seguinte script:

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;