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 le clone de référentiel Git¶

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

   Le code de l’exemple suivant utilise l’outil de ligne de commande Git pour ajouter et valider le fichier du gestionnaire dans le référentiel local, puis le pousser vers le référentiel distant référencé par le clone de référentiel Git dans Snowflake :

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

   Copy

2. Dans Snowflake, actualisez le clone du référentiel Git.

   En supposant que vous avez configuré l’intégration entre Snowflake et votre référentiel Git distant, entraînant un clone de référentiel Git dans Snowflake, vous pouvez actualiser le clone de référentiel Git en récupérant des données du référentiel distant.

   Utiliser Snowflake pour actualiser à partir du référentiel distant revient à travailler avec d’autres outils clients Git, où vous extrayez du référentiel distant 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 distant. 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 clone du référentiel Git¶

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

   Lorsque vous écrivez une procédure, vous pouvez faire référence à son code du gestionnaire à l’emplacement du fichier de code dans le clone du référentiel Git dans Snowflake. Par exemple, pour faire référence à un fichier python-handlers/filter.py dans la branche principale d’un référentiel distant synchronisé avec un clone de référentiel Git appelé 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, qui spécifie le code du gestionnaire stocké dans le clone du référentiel 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. 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  |
   ---------------------