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:
- A quadro de design (veja menu de ações do componente em Tela de design).
- A aba Componentes do painel do projeto (consulte menu de ações do componente na aba Componentes do painel Projeto).
Configurar uma atividade Snowflake Insert
Siga estas etapas para configurar uma atividade Inserir do Snowflake:
-
Etapa 1: Insira um nome e selecione um objeto
Forneça um nome para a atividade e selecione um objeto, seja uma tabela ou uma visualização. -
Etapa 2: Selecione uma abordagem
Diferentes abordagens são suportadas para inserir dados no Snowflake. Escolha entre Stage File ou SQL Insert. Ao usar a abordagem Stage File, você pode selecionar os tipos de arquivo de estágio Amazon S3 ou Internal. -
Etapa 3: Revise os esquemas de dados
Todos os esquemas de solicitação ou resposta gerados a partir do endpoint são exibidos.
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.
-
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 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
- Abordagem de arquivo de estágio do Amazon S3
- Abordagem de arquivo de estágio do Google Cloud Storage
- Abordagem de arquivo de estágio interno
- Abordagem de arquivo de estágio do Microsoft Azure
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.
-
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: 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).
-
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.
-
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:
-
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 dadosInsertAmazonS3Request
. -
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: 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.
-
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 dadosInsertGoogleCloudRequest
. -
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.
-
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.
-
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.
-
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:
-
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 dadosInsertMicrosoftAzureCloudRequest
.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 dadosInsertMicrosoftAzureCloudRequest
. -
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:
- abordagem de inserção SQL
- Abordagem de arquivo de estágio do Amazon S3
- Abordagem de arquivo de estágio do Google Cloud Storage
- Abordagem de arquivo de estágio interno
- Abordagem de arquivo de estágio do Microsoft Azure
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 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.
-
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.
-
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 oNULL_IF
opção do SnowflakeCOPY INTO
<location>
documentação.enclosingChar
Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BY
opção do SnowflakeCOPY 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ágono0x27
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
ouNONE
são suportados. Veja a Opção de compressão do SnowflakeCOPY 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_DELIMITER
opção do SnowflakeCOPY INTO
<table>
documentação.recordDelimiter
O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITER
opção do SnowflakeCOPY 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.
-
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 oNULL_IF
opção do SnowflakeCOPY INTO
<location>
documentação.enclosingChar
Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BY
opção do SnowflakeCOPY 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ágono0x27
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
ouNONE
são suportados. Veja a Opção de compressão do SnowflakeCOPY 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_DELIMITER
opção do SnowflakeCOPY INTO
<table>
documentação.recordDelimiter
O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITER
opção do SnowflakeCOPY 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.
-
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 oNULL_IF
opção do SnowflakeCOPY INTO
<location>
documentação.enclosingChar
Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BY
opção do SnowflakeCOPY 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ágono0x27
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_DELIMITER
opção do SnowflakeCOPY INTO
<table>
documentação.recordDelimiter
O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITER
opção do SnowflakeCOPY 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.
-
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 oNULL_IF
opção do SnowflakeCOPY INTO
<location>
documentação.enclosingChar
Caractere usado para delimitar campos de dados; veja o FIELD_OPTIONALLY_ENCLOSED_BY
opção do SnowflakeCOPY 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ágono0x27
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
ouNONE
são suportados. Veja a Opção de compressão do SnowflakeCOPY 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_DELIMITER
opção do SnowflakeCOPY INTO
<table>
documentação.recordDelimiter
O caractere delimitador usado para separar grupos de campos; veja o RECORD_DELIMITER
opção do SnowflakeCOPY 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:
- Padrão de Transformação
- Padrão de duas transformações (como o primeiro ou segundo alvo)
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.