Exemples d’utilisation de Git avec Snowflake¶

Code requis par cet exemple¶

Le gestionnaire (handler) de cet exemple dépend d’une base de données créée à l’aide d’un code SQL similaire au suivant :

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');

L’exemple utilise le code du gestionnaire (handler) Python suivant, contenu dans 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)

Valider le fichier et actualiser la zone de préparation de référentiel¶

1. Depuis votre référentiel Git, ajoutez le code au référentiel.

   Le code de l’exemple suivant utilise l’outil de ligne de commande git pour ajouter et valider le fichier du gestionnaire (handler) dans le référentiel local, puis le pousser dans le référentiel distant référencé par la zone de préparation du référentiel dans Snowflake :

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

   Copy

2. Dans Snowflake, actualisez la zone de préparation du référentiel.

   En supposant que vous avez configuré l’intégration entre Snowflake et votre référentiel Git, résultant en une zone de préparation de référentiel, vous pouvez actualiser la zone de préparation en récupérant des données du référentiel.

   L’utilisation de Snowflake pour actualiser votre référentiel est similaire à celle d’autres outils clients Git, où vous récupérez le référentiel avant de commencer à travailler pour vous assurer que vous disposez des dernières modifications.

   Le code de l’exemple suivant exécute la commande ALTER GIT REPOSITORY pour récupérer les dernières modifications du référentiel. Le code génère un clone complet qui inclut des branches, des balises et des validations.

   ALTER GIT REPOSITORY snowflake_extensions FETCH;
   

   Copy

Créer et exécuter une procédure qui utilise le fichier dans le référentiel¶

1. Dans Snowflake, écrivez la procédure.

   Lorsque vous écrivez une procédure, vous pouvez faire référence au code de son gestionnaire (handler) à l’emplacement du fichier en question dans la zone de préparation de référentiel. Par exemple, pour faire référence à un fichier python-handlers/filter.py dans la branche principale d’un référentiel synchronisé avec une zone de préparation de référentiel Git appelée snowflake_extensions, vous utiliserez une syntaxe similaire à la suivante :

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

   Copy

   Le code de l’exemple suivant crée une procédure appelée filter_by_role, en spécifiant le code du gestionnaire (handler) stocké dans la zone de préparation du référentiel :

   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. Exécutez la procédure.

   Le code suivant exécute la procédure.

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

   Copy

   Voici un exemple de sortie de la procédure.

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