Exemplos de uso do Git com Snowflake¶

Código exigido por este exemplo¶

O manipulador neste exemplo depende de um banco de dados criado com código SQL semelhante ao seguinte:

CREATE DATABASE example_db;
USE DATABASE example_db;
CREATE SCHEMA example_schema;
USE SCHEMA example_schema;

CREATE OR REPLACE TABLE employees(id NUMBER, name VARCHAR, role VARCHAR);
INSERT INTO employees (id, name, role) VALUES (1, 'Alice', 'op'), (2, 'Bob', 'dev'), (3, 'Cindy', 'dev');

O exemplo usa o seguinte código de manipulador Python contido em filter.py:

from snowflake.snowpark.functions import col

def filter_by_role(session, table_name, role):
  df = session.table(table_name)
  return df.filter(col("role") == role)

Confirmar o arquivo e atualizar o clone do repositório Git¶

1. No seu cliente Git, adicione o código ao repositório remoto.

   O código no exemplo a seguir usa a ferramenta de linha de comando git para adicionar e confirmar o arquivo do manipulador no repositório local e, em seguida, enviá-lo para o repositório remoto referenciado pelo clone do repositório Git no Snowflake:

   $ git add python-handlers/filter.py
   $ git commit -m "Adding code to filter by role"
   $ git push
   

   Copy

2. No Snowflake, atualize o clone do repositório Git.

   Supondo que você tenha configurado a integração entre o Snowflake e o seu repositório Git remoto, resultando em um clone do repositório Git no Snowflake, é possível atualizar o clone do repositório Git buscando no repositório remoto.

   Usar o Snowflake para atualizar a partir do seu repositório remoto é semelhante a trabalhar com outras ferramentas de cliente Git, em que você busca no repositório remoto antes de começar a trabalhar para garantir que tenha as alterações mais recentes.

   O código no exemplo a seguir executa o comando ALTER GIT REPOSITORY para recuperar as alterações mais recentes do repositório remoto. O código gera um clone completo que inclui ramificações, tags e commits.

   ALTER GIT REPOSITORY snowflake_extensions FETCH;
   

   Copy

Criar e executar um procedimento que use o arquivo no clone do repositório Git¶

1. No Snowflake, escreva o procedimento.

   Quando você escreve um procedimento, pode fazer referência ao seu código manipulador no local do arquivo do código no clone do repositório Git no Snowflake. Por exemplo, para se referir a um arquivo python-handlers/filter.py na ramificação principal de um repositório remoto sincronizado com um clone do repositório Git chamado snowflake_extensions, você usaria uma sintaxe semelhante à seguinte:

   @snowflake_extensions/branches/main/python-handlers/filter.py
   

   Copy

   O código no exemplo a seguir cria um procedimento chamado filter_by_role, especificando o código do manipulador armazenado no clone do repositório Git:

   CREATE OR REPLACE PROCEDURE filter_by_role(tableName VARCHAR, role VARCHAR)
     RETURNS TABLE(id NUMBER, name VARCHAR, role VARCHAR)
     LANGUAGE PYTHON
     RUNTIME_VERSION = '3.9'
     PACKAGES = ('snowflake-snowpark-python')
     IMPORTS = ('@example_db.example_schema.snowflake_extensions/branches/main/python-handlers/filter.py')
     HANDLER = 'filter.filter_by_role';
   

   Copy

2. Execute o procedimento.

   O código a seguir executa o procedimento.

   CALL filter_by_role('employees', 'dev');
   

   Copy

   Aqui está um exemplo de saída do procedimento.

   ---------------------
   | ID | NAME  | ROLE |
   ---------------------
   | 2  | Bob   | dev  |
   ---------------------
   | 3  | Cindy | dev  |
   ---------------------