Ir para o conteúdo

Atividade de inserção de Snowflake

Introdução

Uma atividade Inserir Snowflake, usando sua conexão Snowflake, insere dados de tabela (como um arquivo CSV ou mapeados diretamente para colunas de uma tabela) no Snowflake e deve ser usado como um alvo para consumir dados em uma operação.

Crie uma atividade de inserção de Snowflake

Uma instância de uma atividade Snowflake Insert é criada a partir de uma conexão Snowflake usando seu tipo de atividade Inserir.

Para criar uma instância de uma atividade, arraste o tipo de atividade para a quadro de design ou copie o tipo de atividade e cole-o na quadro de design. Para obter detalhes, consulte Criando uma instância de atividade em Reutilização de componentes.

Uma atividade Snowflake Inserir existente pode ser editada a partir destes locais:

Configurar uma atividade Snowflake Insert

Siga estas etapas para configurar uma atividade Inserir do Snowflake:

Etapa 1: insira um nome e selecione um objeto

Nesta etapa, forneça um nome para a atividade e selecione uma tabela ou exibição (consulte Visão geral das exibições do Snowflake). Cada elemento da interface do usuário desta etapa é descrito abaixo.

Etapa 1 da configuração da atividade Inserir Snowflake

  • Nome: Insira um nome para identificar a atividade. O nome deve ser exclusivo para cada atividade Snowflake Insert e não deve conter barras / ou dois pontos :.

  • Selecione um objeto: Esta seção exibe objetos disponíveis no endpoint do Snowflake. Ao reabrir uma configuração de atividade existente, somente o objeto selecionado é exibido em vez de recarregar a lista inteira de objetos.

    • Objeto Snowflake Selecionado: Depois que um objeto é selecionado, ele é listado aqui.

    • Pesquisar: Insira qualquer valor de coluna na caixa de pesquisa para filtrar a lista de objetos. A pesquisa não diferencia maiúsculas de minúsculas. Se os objetos já estiverem exibidos na tabela, os resultados da tabela serão filtrados em tempo real a cada pressionamento de tecla. Para recarregar objetos do endpoint ao pesquisar, insira os critérios de pesquisa e atualize, conforme descrito abaixo.

    • Atualizar: Clique no ícone de atualização Ícone de atualização ou a palavra Refresh para recarregar objetos do endpoint do Snowflake. Isso pode ser útil se objetos foram adicionados ao Snowflake. Esta ação atualiza todos os metadados usados para construir a tabela de objetos exibida na configuração.

    • Selecionando um objeto: Dentro da tabela, clique em qualquer lugar em uma linha para selecionar um objeto. Apenas um objeto pode ser selecionado. As informações disponíveis para cada objeto são obtidas do endpoint do Snowflake:

      • Nome: O nome de um objeto, seja uma tabela ou uma exibição.

      • Tipo: O tipo do objeto, seja uma tabela ou uma exibição.

    Dica

    Se a tabela não for preenchida com objetos disponíveis, a conexão Snowflake pode não ser bem-sucedido. Certifique-se de que você esteja conectado reabrindo a conexão e testando novamente as credenciais.

  • Salvar e sair: Se habilitado, clique para salvar a configuração para esta etapa e fechar a configuração da atividade.

  • Próximo: Clique para armazenar temporariamente a configuração para esta etapa e continuar para a próxima etapa. A configuração não será salva até que você clique no botão Concluído na última etapa.

  • Descartar alterações: Após fazer alterações, clique para fechar a configuração sem salvar as alterações feitas em nenhuma etapa. Uma mensagem solicita que você confirme que deseja descartar as alterações.

Etapa 2: Selecione uma abordagem

Diferentes abordagens são suportadas para inserir dados no Snowflake. Escolha entre SQL Insert ou Stage File. Ao usar a abordagem Stage File, você seleciona os tipos de arquivo de estágio Amazon S3 ou Internal.

Abordagem de inserção SQL

Para essa abordagem, as colunas da tabela serão mostradas na etapa do esquema de dados a seguir, permitindo que sejam mapeadas em uma transformação.

Etapa 2 da configuração da atividade de inserção do Snowflake Abordagem de inserção SQL

  • Abordagem: Use o menu suspenso para selecionar Inserir SQL.

  • Voltar: Clique para retornar à etapa anterior e armazenar temporariamente a configuração.

  • Próximo: Clique para continuar para a próxima etapa e armazenar temporariamente a configuração. A configuração não será salva até que você clique no botão Concluído na última etapa.

  • Descartar alterações: Após fazer alterações, clique para fechar a configuração sem salvar as alterações feitas em nenhuma etapa. Uma mensagem solicita que você confirme se deseja descartar as alterações.

Abordagem do arquivo de estágio do Amazon S3

Essa abordagem permite que um arquivo CSV seja inserido no Snowflake usando uma fonte do Amazon S3. O arquivo é preparado e então copiado para a tabela seguindo as especificações do request data esquema.

Para obter informações sobre como fazer solicitações ao Amazon S3, consulte Fazer solicitações na documentação do Amazon S3.

Abordagem do arquivo de estágio do Amazon S3 da etapa 2 da configuração da atividade de inserção do Snowflake

  • Abordagem: Use o menu suspenso para selecionar Arquivo de preparação.

  • Tipo de estágio: Escolha Amazon S3 para recuperar dados do armazenamento do Amazon S3.

  • Tipo de autenticação: Escolha entre usar Credenciais ou Integração de armazenamento. Credenciais requer o ID da chave de acesso do Amazon S3 e a Chave de acesso secreta. Integração de armazenamento requer apenas o nome da integração de armazenamento. Esses tipos de autenticação são abordados abaixo.

Autenticação de credenciais

O tipo de autenticação Credenciais requer o ID da chave de acesso do Amazon S3 e a chave de acesso secreta (para obter informações sobre como fazer solicitações ao Amazon S3, consulte Fazer solicitações na documentação do Amazon S3).

Etapa 2 da configuração da atividade de inserção do Snowflake Abordagem de credenciais do arquivo de estágio do Amazon S3

  • Tipo de autenticação: Escolha Credenciais.

  • ID da chave de acesso: Insira o ID da chave de acesso do Amazon S3.

  • Chave de acesso secreta: Insira a chave de acesso secreta do Amazon S3.

Autenticação de integração de armazenamento

O tipo de autenticação Integração de Armazenamento requer a criação de uma integração de armazenamento Snowflake. Para obter informações sobre como criar uma integração de armazenamento Snowflake, consulte Criar Integração de Armazenamento na documentação do Snowflake.

Etapa 2 da configuração da atividade de inserção do Snowflake Abordagem de arquivo do estágio Amazon S3 Integração de armazenamento

  • Tipo de autenticação: Escolha Integração de armazenamento.

  • Nome da integração de armazenamento: Insira o nome da integração de armazenamento do Snowflake.

Opções adicionais

Para autenticação de Credenciais e Integração de Armazenamento, há estas opções adicionais:

Etapa 2 da configuração da atividade de inserção do Snowflake Abordagem do arquivo de estágio do Amazon S3 Opções adicionais

  • Nome do Bucket: Insira um nome de bucket válido para um bucket existente no servidor Amazon S3. Isso será ignorado se bucketName é fornecido no esquema de dados InsertAmazonS3Request.

  • Caminho do arquivo: Insira o caminho do arquivo.

  • Em caso de erro: Escolha uma destas opções no menu suspenso Em caso de erro; opções adicionais aparecerão conforme apropriado:

    • Abort_Statement: Aborta o processamento se algum erro for encontrado.

    • Continuar: Continua carregando o arquivo mesmo se forem encontrados erros.

    • Skip_File: Ignora o arquivo se algum erro for encontrado no arquivo.

    • Skip_File_\<num>: Ignora o arquivo quando o número de erros no arquivo é igual ou excede o número especificado em Ignorar número de arquivo.

    • Skip_File_\<num>%: Ignora o arquivo quando a porcentagem de erros no arquivo excede a porcentagem especificada em Ignorar Porcentagem do Número de Arquivos.

  • Erro na incompatibilidade de contagem de colunas: Se selecionado, relata um erro no nó de erro do esquema de resposta se as contagens de colunas de origem e destino não corresponderem. Se você não selecionar esta opção, a operação não falhará e os dados fornecidos serão inseridos.

  • Voltar: Clique para retornar à etapa anterior e armazenar temporariamente a configuração.

  • Próximo: Clique para continuar para a próxima etapa e armazenar temporariamente a configuração. A configuração não será salva até que você clique no botão Concluído na última etapa.

  • Descartar alterações: Após fazer alterações, clique para fechar a configuração sem salvar as alterações feitas em nenhuma etapa. Uma mensagem pede para você confirmar que deseja descartar as alterações.

Abordagem de arquivo de estágio interno

Essa abordagem permite que um arquivo CSV seja inserido no Snowflake. O arquivo será preparado e então copiado para a tabela seguindo as especificações do esquema de dados da solicitação.

Abordagem do arquivo de estágio interno da etapa 2 da configuração da atividade Inserir Snowflake

  • Abordagem: Use o menu suspenso para selecionar Arquivo de preparação.

  • Tipo de estágio: Escolha Interno para recuperar os dados de uma fonte interna.

  • Em caso de erro: Escolha uma destas opções no menu suspenso Em caso de erro; opções adicionais aparecerão conforme apropriado:

    • Abort_Statement: Aborta o processamento se algum erro for encontrado.

    • Continuar: Continua carregando o arquivo mesmo se forem encontrados erros.

    • Skip_File: Ignora o arquivo se algum erro for encontrado no arquivo.

    • Skip_File_\<num>: Ignora o arquivo quando o número de erros no arquivo é igual ou excede o número especificado em Ignorar número de arquivo.

    • Skip_File_\<num>%: Ignora o arquivo quando a porcentagem de erros no arquivo excede a porcentagem especificada em Ignorar Porcentagem do Número de Arquivos.

  • Erro na incompatibilidade de contagem de colunas: Se selecionado, relata um erro no nó de erro do esquema de resposta se as contagens de colunas de origem e destino não corresponderem. Se você não selecionar esta opção, a operação não falhará e os dados fornecidos serão inseridos.

  • Voltar: Clique para retornar à etapa anterior e armazenar temporariamente a configuração.

  • Próximo: Clique para continuar para a próxima etapa e armazenar temporariamente a configuração. A configuração não será salva até que você clique no botão Concluído na última etapa.

  • Descartar alterações: Após fazer alterações, clique para fechar a configuração sem salvar as alterações feitas em nenhuma etapa. Uma mensagem pede para você confirmar que deseja descartar as alterações.

Abordagem do arquivo de estágio do Google Cloud Storage

Essa abordagem permite que um arquivo CSV seja inserido no Google Cloud Storage. O arquivo será preparado e então copiado para a tabela seguindo as especificações do esquema de dados da solicitação.

Etapa 2 da configuração da atividade de inserção do Snowflake Abordagem do arquivo do estágio do Google Cloud Storage

  • Abordagem: Use o menu suspenso para selecionar Arquivo de preparação.

  • Tipo de estágio: Escolha Google Cloud Storage para recuperar os dados de uma fonte interna.

  • Nome da integração de armazenamento: Insira o nome da integração de armazenamento do Snowflake.

  • Nome do bucket: Insira um nome de bucket válido para um bucket existente no Google Cloud Storage. Isso será ignorado se bucketName é fornecido no esquema de dados InsertGoogleCloudRequest.

  • Caminho do arquivo: Insira o caminho do arquivo.

  • Em caso de erro: Escolha uma destas opções no menu suspenso Em caso de erro; opções adicionais aparecerão conforme apropriado:

    • Abort_Statement: Aborta o processamento se algum erro for encontrado.

    • Continuar: Continua carregando o arquivo mesmo se forem encontrados erros.

    • Skip_File: Ignora o arquivo se algum erro for encontrado no arquivo.

    • Skip_File_\<num>: Ignora o arquivo quando o número de erros no arquivo é igual ou excede o número especificado em Ignorar número de arquivo.

    • Skip_File_\<num>%: Ignora o arquivo quando a porcentagem de erros no arquivo excede a porcentagem especificada em Ignorar Porcentagem do Número de Arquivos.

  • Erro na incompatibilidade de contagem de colunas: Se selecionado, relata um erro no nó de erro do esquema de resposta se as contagens de colunas de origem e destino não corresponderem. Se você não selecionar esta opção, a operação não falhará e os dados fornecidos serão inseridos.

  • Voltar: Clique para retornar à etapa anterior e armazenar temporariamente a configuração.

  • Próximo: Clique para continuar para a próxima etapa e armazenar temporariamente a configuração. A configuração não será salva até que você clique no botão Concluído na última etapa.

  • Descartar alterações: Após fazer alterações, clique para fechar a configuração sem salvar as alterações feitas em nenhuma etapa. Uma mensagem pede para você confirmar que deseja descartar as alterações.

Abordagem do arquivo de estágio do Microsoft Azure

Essa abordagem permite que um arquivo CSV seja inserido no Snowflake usando uma fonte do Microsoft Azure. O arquivo é preparado e então copiado para a tabela seguindo as especificações do esquema de dados da solicitação.

Etapa 2 da configuração da atividade de inserção do Snowflake Abordagem do arquivo de estágio do Microsoft Azure

  • Abordagem: Use o menu suspenso para selecionar Arquivo de preparação.

  • Tipo de estágio: Escolha Microsoft Azure para recuperar dados de contêineres de armazenamento do Microsoft Azure.

  • Tipo de autenticação: Escolha entre usar Credenciais ou Integração de armazenamento. Credenciais requer um token de assinatura de acesso compartilhado (SAS) do Microsoft Azure e um nome de conta de armazenamento. Integração de armazenamento requer apenas um nome de integração de armazenamento. Esses tipos de autenticação são abordados abaixo.

Autenticação de credenciais

O tipo de autenticação Credenciais requer um token SAS do Microsoft Azure e um nome de conta de armazenamento.

Etapa 2 da configuração da atividade de inserção do Snowflake Credenciais da abordagem do arquivo de estágio do Microsoft Azure

  • Tipo de autenticação: Escolha Credenciais.

  • Token SAS do Azure: Insira o token SAS do Microsoft Azure. Para obter informações sobre como criar tokens SAS para contêineres de armazenamento no Microsoft Azure, consulte Criar tokens SAS para seus contêineres de armazenamento na documentação do Microsoft Azure.

  • Nome da conta de armazenamento: Insira o nome da conta de armazenamento do Microsoft Azure.

Autenticação de integração de armazenamento

O tipo de autenticação Integração de Armazenamento requer a criação de uma integração de armazenamento Snowflake. Para obter informações sobre como criar uma integração de armazenamento Snowflake, consulte Criar Integração de Armazenamento na documentação do Snowflake.

Etapa 2 da configuração da atividade de inserção do Snowflake Abordagem de armazenamento do arquivo de estágio do Microsoft Azure Integração

  • Tipo de autenticação: Escolha Integração de armazenamento.

  • Nome da integração de armazenamento: Insira o nome da integração de armazenamento do Snowflake.

Opções adicionais

Para autenticação de Credenciais e Integração de Armazenamento, há estas opções adicionais:

Etapa 2 da configuração da atividade Inserir Snowflake Abordagem do arquivo de estágio do Microsoft Azure Opções adicionais

  • Chave mestra: Insira a chave mestra usada para criptografia do lado do cliente (CSE) no Microsoft Azure. Isso será ignorado se azureMasterKey é fornecido no esquema de dados InsertMicrosoftAzureCloudRequest.

    Nota

    Para obter informações sobre como criar chaves no Microsoft Azure, consulte Início rápido: definir e recuperar uma chave do Azure Key Vault usando o portal do Azure na documentação do Microsoft Azure.

    Para obter informações sobre o armazenamento CSE no Microsoft Azure, consulte criptografia do lado do cliente para blobs na documentação do Microsoft Azure.

  • Nome do contêiner: Insira um nome de bucket válido para um contêiner de armazenamento existente no Microsoft Azure. Isso será ignorado se containerName é fornecido no esquema de dados InsertMicrosoftAzureCloudRequest.

  • Caminho do arquivo: Insira o caminho do arquivo.

  • Em caso de erro: Escolha uma destas opções no menu suspenso Em caso de erro; opções adicionais aparecerão conforme apropriado:

    • Abort_Statement: Aborta o processamento se algum erro for encontrado.

    • Continuar: Continua carregando o arquivo mesmo se forem encontrados erros.

    • Skip_File: Ignora o arquivo se algum erro for encontrado no arquivo.

    • Skip_File_\<num>: Ignora o arquivo quando o número de erros no arquivo é igual ou excede o número especificado em Ignorar número de arquivo.

    • Skip_File_\<num>%: Ignora o arquivo quando a porcentagem de erros no arquivo excede a porcentagem especificada em Ignorar Porcentagem do Número de Arquivos.

  • Erro na incompatibilidade de contagem de colunas: Se selecionado, relata um erro no nó de erro do esquema de resposta se as contagens de colunas de origem e destino não corresponderem. Se você não selecionar esta opção, a operação não falhará e os dados fornecidos serão inseridos.

  • Voltar: Clique para retornar à etapa anterior e armazenar temporariamente a configuração.

  • Próximo: Clique para continuar para a próxima etapa e armazenar temporariamente a configuração. A configuração não será salva até que você clique no botão Concluído na última etapa.

  • Descartar alterações: Após fazer alterações, clique para fechar a configuração sem salvar as alterações feitas em nenhuma etapa. Uma mensagem pede para você confirmar que deseja descartar as alterações.

Etapa 3: Revise os esquemas de dados

Os esquemas de solicitação e resposta gerados do endpoint são exibidos. Os esquemas exibidos dependem da Abordagem especificada na etapa anterior.

Estas subseções descrevem as estruturas de solicitação e resposta para cada combinação de abordagem e tipo de estágio:

Estas ações estão disponíveis com cada abordagem:

  • Esquemas de dados: Esses esquemas de dados são herdados por transformações adjacentes e são exibidos novamente durante o mapeamento de transformação.

    Nota

    Os dados fornecidos em uma transformação têm precedência sobre a configuração da atividade.

    Dica

    Quando um caractere de aspas simples (') está presente em uma payload de solicitação, um erro de sintaxe é retornado em tempo de execução. Você pode habilitar a configuração Escape caracteres especiais na conexão para permitir que a atividade escape automaticamente de caracteres de aspas simples (') em tempo de execução.

    O conector Snowflake usa o Snowflake JDBC Driver e os comandos SQL do Snowflake. Consulte a documentação da API para obter informações sobre os nós e campos do esquema.

  • Atualizar: Clique no ícone de atualização Ícone de atualização ou a palavra Refresh para regenerar esquemas do endpoint do Snowflake. Esta ação também regenera um esquema em outros locais em todo o projeto onde o mesmo esquema é referenciado, como em uma transformação adjacente.

  • Voltar: Clique para armazenar temporariamente a configuração desta etapa e retornar à etapa anterior.

  • Concluído: Clique para salvar a configuração de todas as etapas e fechar a configuração da atividade.

  • Descartar alterações: Após fazer alterações, clique para fechar a configuração sem salvar as alterações feitas em nenhuma etapa. Uma mensagem pede para você confirmar que deseja descartar as alterações.

Abordagem de inserção SQL

Se a abordagem for SQL Insert, as colunas da tabela serão mostradas, permitindo que sejam mapeadas em uma transformação.

Etapa 3 da configuração da atividade de inserção do Snowflake Abordagem de inserção SQL

  • Solicitação

    Campo/Nó do Esquema de Solicitação Notas
    table Nó mostrando o nome da tabela.
    column_A Nome da primeira coluna da tabela.
    column_B Nome da segunda coluna da tabela.
    . . . Colunas de tabela seguintes.
  • Resposta

    Campo/Nó do Esquema de Resposta Notas
    status Sinalizador booleano informando se a inserção do registro foi bem-sucedida.
    errorMessage Mensagem de erro descritiva em caso de falha durante a inserção.
    recordsInserted Número de registros inseridos se a inserção for bem-sucedida.

Abordagem do arquivo de estágio do Amazon S3

Se a abordagem for Amazon S3 Stage File, as especificações para preparação e inserção de um arquivo CSV serão mostradas no esquema de dados para que possam ser mapeadas em uma transformação. O padrão usado é corresponder a apenas um arquivo. Se o padrão corresponder a mais de um arquivo, a atividade apresentará um erro com uma mensagem descritiva.

Abordagem do arquivo de estágio do Amazon S3 da etapa 3 da configuração da atividade de inserção do Snowflake

  • Solicitação

    Campo/Nó do Esquema de Solicitação Notas
    accessKey ID da chave de acesso do Amazon S3.
    secretAccessKey Chave de acesso secreta do Amazon S3.
    storageintegrationName Nome da integração de armazenamento Snowflake a ser usada para autenticação da integração de armazenamento Snowflake.
    bucketName Nome de bucket válido para um bucket existente no servidor Amazon S3.
    filePath Localização do arquivo de estágio no bucket do Amazon S3.
    pattern Padrão de expressão regular usado para encontrar o arquivo no palco; if compression é GZIP, [.]gzé anexado ao padrão.
    onError Opção Em caso de erro selecionada.
    encryption Nó que representa a criptografia.
    encryptionType Tipo de criptografia Amazon S3 ( criptografia do lado do servidor ou criptografia do lado do cliente).
    masterKey Chave mestra do Amazon S3.
    kmsKeyId Serviço de gerenciamento de chaves da Amazon ID mestre.
    fileFormat Nó que representa o formato do arquivo.
    nullIf Uma string a ser convertida para SQL NULL; por padrão, é uma string vazia. Veja o NULL_IFopção do Snowflake COPY INTO<location> documentação.
    enclosingChar Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BYopção do Snowflake COPY INTO<location> documentação.

    Nota

    O enclosingChar pode ser um caractere de aspas simples ' ou caractere de aspas duplas ". Para usar o caractere de aspas simples, use o octal ' ou o hexágono 0x27 representações ou use uma aspa dupla simples escape ''. Quando um campo contém este caractere, escape-o usando o mesmo caractere.

    compression O algoritmo de compressão usado para os arquivos de dados. GZIP ou NONE são suportados. Veja a Opção de compressão do Snowflake COPY INTO<location> documentação.
    skipHeader Número de linhas no início do arquivo de origem a serem ignoradas.
    errorOnColumnCountMismatch Sinalizador booleano para relatar um erro se as contagens de origem e destino do esquema de resposta não corresponderem.
    fieldDelimiter O caractere delimitador usado para separar campos de dados; veja o FIELD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
    recordDelimiter O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
  • Resposta

    Campo/Nó do Esquema de Resposta Notas
    status Status retornado.
    file Nome do arquivo CSV preparado processado ao inserir dados na tabela Snowflake.
    rows_parsed Número de linhas analisadas do arquivo CSV.
    rows_loaded Número de linhas carregadas do arquivo CSV para a tabela Snowflake sem erro.
    error Nó que representa as mensagens de erro.
    error_limit Número de erros que fazem com que o arquivo seja ignorado, conforme definido em Skip_File_\<num>.
    errors_seen Contagem de erros vistos.
    first_error O primeiro erro no arquivo de origem.
    first_error_line O número da primeira linha do primeiro erro.
    first_error_character O primeiro caractere do primeiro erro.
    first_error_column_name O nome da coluna do primeiro local de erro.

Abordagem do Google Cloud Storage Stage File

Se a abordagem for Google Cloud Storage Stage File, as especificações para preparação e inserção de um arquivo CSV serão mostradas no esquema de dados para que possam ser mapeadas em uma transformação. O padrão usado é corresponder a apenas um arquivo. Se o padrão corresponder a mais de um arquivo, a atividade apresentará um erro com uma mensagem descritiva.

Abordagem do arquivo de estágio do Google Cloud Storage da etapa 3 da configuração da atividade Inserir Snowflake

  • Solicitação

    Campo/Nó do Esquema de Solicitação Notas
    storageintegrationName Nome da integração de armazenamento Snowflake a ser usada para autenticação da integração de armazenamento Snowflake.
    bucketName Nome de bucket válido para um bucket existente no Google Cloud Storage.
    filePath Localização do arquivo de estágio no bucket do Google Cloud Storage.
    pattern Padrão de expressão regular usado para encontrar o arquivo no palco; if compressData é verdade, [.]gzé anexado ao padrão.
    onError Opção Em caso de erro selecionada.
    fileFormat Nó que representa o formato do arquivo.
    nullIf Uma string a ser convertida para SQL NULL; por padrão, é uma string vazia. Veja o NULL_IFopção do Snowflake COPY INTO<location> documentação.
    enclosingChar Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BYopção do Snowflake COPY INTO<location> documentação.

    Nota

    O enclosingChar pode ser um caractere de aspas simples ' ou caractere de aspas duplas ". Para usar o caractere de aspas simples, use o octal ' ou o hexágono 0x27 representações ou use uma aspa dupla simples escape ''. Quando um campo contém este caractere, escape-o usando o mesmo caractere.

    compression O algoritmo de compressão usado para os arquivos de dados. GZIP ou NONE são suportados. Veja a Opção de compressão do Snowflake COPY INTO<location> documentação.
    skipHeader Número de linhas no início do arquivo de origem a serem ignoradas.
    errorOnColumnCountMismatch Sinalizador booleano para relatar um erro se as contagens de origem e destino do esquema de resposta não corresponderem.
    fieldDelimiter O caractere delimitador usado para separar campos de dados; veja o FIELD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
    recordDelimiter O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
  • Resposta

    Campo/Nó do Esquema de Resposta Notas
    status Status retornado.
    file Nome do arquivo CSV preparado processado ao inserir dados na tabela Snowflake.
    rows_parsed Número de linhas analisadas do arquivo CSV.
    rows_loaded Número de linhas carregadas do arquivo CSV para a tabela Snowflake sem erro.
    error Nó que representa as mensagens de erro.
    error_limit Número de erros que fazem com que o arquivo seja ignorado, conforme definido em Skip_File_\<num>.
    errors_seen Contagem de erros vistos.
    first_error O primeiro erro no arquivo de origem.
    first_error_line O número da primeira linha do primeiro erro.
    first_error_character O primeiro caractere do primeiro erro.
    first_error_column_name O nome da coluna do primeiro local de erro.

Abordagem de arquivo de estágio interno

Se a abordagem for Arquivo de estágio interno, as especificações para preparar e inserir um arquivo CSV serão mostradas no esquema de dados para que possam ser mapeadas em uma transformação. O padrão usado é corresponder a apenas um arquivo. Se o padrão corresponder a mais de um arquivo, a atividade apresentará um erro com uma mensagem descritiva.

Abordagem do arquivo de estágio interno da etapa 3 da configuração da atividade Inserir Snowflake

  • Solicitação

    Campo/Nó do Esquema de Solicitação Notas
    stageName Estágio interno do Snowflake, nome da tabela ou caminho.
    destinationPrefix Caminho ou prefixo sob o qual os dados serão carregados no estágio Snowflake.
    fileContent Conteúdo do arquivo de dados, em formato CSV, que será preparado para upload na tabela Snowflake.
    destinationFileName Nome do arquivo de destino a ser usado no estágio Snowflake.
    compressData Sinalizador booleano para compactar ou não os dados antes de enviá-los para o estágio interno do Snowflake.
    pattern Padrão de expressão regular usado para encontrar o arquivo no palco; if compressData é verdade, [.]gzé anexado ao padrão.
    onError Opção Em caso de erro selecionada.
    fileFormat Nó que representa o formato do arquivo.
    nullIf Uma string a ser convertida para SQL NULL; por padrão, é uma string vazia. Veja o NULL_IFopção do Snowflake COPY INTO<location> documentação.
    enclosingChar Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BYopção do Snowflake COPY INTO<location> documentação.

    Nota

    O enclosingChar pode ser um caractere de aspas simples ' ou caractere de aspas duplas ". Para usar o caractere de aspas simples, use o octal ' ou o hexágono 0x27 representações ou use uma aspa dupla simples escape ''. Quando um campo contém este caractere, escape-o usando o mesmo caractere.

    errorOnColumnCountMismatch Sinalizador booleano para relatar um erro se as contagens de origem e destino do esquema de resposta não corresponderem.
    fieldDelimiter O caractere delimitador usado para separar campos de dados; veja o FIELD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
    recordDelimiter O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
  • Resposta

    Campo/Nó do Esquema de Resposta Notas
    file Nome do arquivo CSV preparado processado ao colocar dados na tabela Snowflake.
    status Status retornado.
    rowsParsed Número de linhas analisadas do arquivo CSV.
    rowsLoaded Número de linhas carregadas do arquivo CSV para a tabela Snowflake sem erro.
    error Nó que representa as mensagens de erro.
    error A mensagem de erro.
    code O código de erro retornado.
    sqlState O código de erro numérico do estado SQL retornado da chamada do banco de dados.
    file Nó que representa as mensagens de erro.
    columnName Nome e ordem da coluna que continha o erro.
    rowNumber O número da linha no arquivo de origem onde o erro foi encontrado.
    rowStartLine O número da primeira linha da linha onde o erro foi encontrado.

Abordagem do arquivo de estágio do Microsoft Azure

Se a abordagem for Microsoft Azure Stage File, as especificações para preparação e inserção de um arquivo CSV serão mostradas no esquema de dados para que possam ser mapeadas em uma transformação. O padrão usado é corresponder a apenas um arquivo. Se o padrão corresponder a mais de um arquivo, a atividade apresentará um erro com uma mensagem descritiva.

Abordagem do arquivo de estágio do Microsoft Azure da etapa 3 da configuração da atividade Inserir Snowflake

  • Solicitação

    Campo/Nó do Esquema de Solicitação Notas
    azureSasToken Token de Assinatura de Acesso Compartilhado (SAS) do Microsoft Azure.
    azureStorageAccountName Nome da conta de armazenamento do Microsoft Azure.
    azureStorageintegrationName Nome da integração de armazenamento Snowflake a ser usada para autenticação da integração de armazenamento Snowflake.
    containerName Nome de contêiner válido para um contêiner de armazenamento existente no Microsoft Azure.
    filePath Localização do arquivo de estágio no contêiner de armazenamento do Microsoft Azure.
    pattern Padrão de expressão regular usado para encontrar o arquivo no palco; if compression é GZIP, [.]gzé anexado ao padrão.
    onError Opção Em caso de erro selecionada.
    encryption Nó que representa a criptografia.
    encryptionType Tipo de criptografia do Microsoft Azure (somente criptografia do lado do cliente).
    azureMasterKey Chave mestra do Microsoft Azure.
    fileFormat Nó que representa o formato do arquivo.
    nullIf Uma string a ser convertida para SQL NULL; por padrão, é uma string vazia. Veja o NULL_IFopção do Snowflake COPY INTO<location> documentação.
    enclosingChar Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BYopção do Snowflake COPY INTO<location> documentação.

    Nota

    O enclosingChar pode ser um caractere de aspas simples ' ou caractere de aspas duplas ". Para usar o caractere de aspas simples, use o octal ' ou o hexágono 0x27 representações ou use uma aspa dupla simples escape ''. Quando um campo contém este caractere, escape-o usando o mesmo caractere.

    compression O algoritmo de compressão usado para os arquivos de dados. GZIP ou NONE são suportados. Veja a Opção de compressão do Snowflake COPY INTO<location> documentação.
    skipHeader Número de linhas no início do arquivo de origem a serem ignoradas.
    errorOnColumnCountMismatch Sinalizador booleano para relatar um erro se as contagens de origem e destino do esquema de resposta não corresponderem.
    fieldDelimiter O caractere delimitador usado para separar campos de dados; veja o FIELD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
    recordDelimiter O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITERopção do Snowflake COPY INTO<table> documentação.
  • Resposta

    Campo/Nó do Esquema de Resposta Notas
    status Status retornado.
    file Nome do arquivo CSV preparado processado ao inserir dados na tabela Snowflake.
    rows_parsed Número de linhas analisadas do arquivo CSV.
    rows_loaded Número de linhas carregadas do arquivo CSV para a tabela Snowflake sem erro.
    error Nó que representa as mensagens de erro.
    error_limit Número de erros que fazem com que o arquivo seja ignorado, conforme definido em Skip_File_\<num>.
    errors_seen Contagem de erros vistos.
    first_error O primeiro erro no arquivo de origem.
    first_error_line O número da primeira linha do primeiro erro.
    first_error_character O primeiro caractere do primeiro erro.
    first_error_column_name O nome da coluna do primeiro local de erro.

Próximos passos

Após configurar uma atividade Insert do Snowflake, conclua a configuração da operação adicionando e configurando outras atividades, transformações ou scripts como etapas da operação. Você também pode configurar as definições da operação, que incluem a capacidade de encadear operações que estejam no mesmo fluxo de trabalho ou em workflows diferentes.

As ações de menu para uma atividade são acessíveis a partir do painel do projeto e da quadro de design. Para obter detalhes, consulte menu de ações de atividade em Noções básicas do conector.

As atividades Inserir do Snowflake podem ser usadas como um alvo com esses padrões de operação:

Para usar a atividade com funções de script, grave os dados em um local temporário e use esse local temporário na função de script.

Quando estiver pronto, implantar e executar a operação e validar o comportamento verificando os logs de operação.