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)

Confirme o arquivo e atualize o estágio do repositório¶

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

   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 estágio do repositório 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 estágio do repositório.

   Supondo que você tenha configurado a integração entre o Snowflake e seu repositório Git, resultando em um estágio de repositório, você pode atualizar o estágio buscando no repositório.

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

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

   ALTER GIT REPOSITORY snowflake_extensions FETCH;
   

   Copy

Criação e execução de um procedimento que usa o arquivo no repositório¶

1. No Snowflake, escreva o procedimento.

   Ao escrever um procedimento, você pode referenciar seu código do manipulador no local do arquivo de código no estágio do repositório. Por exemplo, para se referir a um arquivo python-handlers/filter.py na ramificação principal de um repositório sincronizado com um estágio de 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 estágio do repositório:

   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  |
   ---------------------