Beispiele für die Verwendung von Git mit Snowflake¶

Für dieses Beispiel benötigter Code¶

Der Handler in diesem Beispiel hängt von einer Datenbank ab, die mit SQL-Code ähnlich dem folgenden erstellt wurde:

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

Das Beispiel verwendet den folgenden Python-Handler-Code, der in filter.py enthalten ist:

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)

Datei committen und den Repository-Stagingbereich aktualisieren¶

1. Fügen Sie den Code über Ihren Git-Client zum Repository hinzu.

   Der Code im folgenden Beispiel verwendet das git-Befehlszeilentool, um die Handler-Datei zum lokalen Repository hinzuzufügen und zu committen. Anschließend wird sie in das externe Repository gepusht, auf das der Repository-Stagingbereich in Snowflake verweist:

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

   Copy

2. Aktualisieren Sie in Snowflake den Repository-Stagingbereich.

   Angenommen, das Einrichten der Integration zwischen Snowflake und Ihrem Git-Repository ist erfolgt und der Repository-Stagingbereich wurde erstellt, dann können Sie den Stagingbereich durch Abrufen der Daten aus dem Repository aktualisieren.

   Die Verwendung von Snowflake zum Aktualisieren Ihres Repositorys ähnelt der Arbeit mit anderen Git-Client-Tools, bei denen Sie vor Beginn der Arbeit das Repository abrufen, um sicherzustellen, dass Sie die neuesten Änderungen haben.

   Der Code im folgenden Beispiel führt den Befehl ALTER GIT REPOSITORY aus, um die letzten Änderungen aus dem Repository abzurufen. Der Code generiert einen vollständigen Klon, der Zweige, Tags und Commits enthält.

   ALTER GIT REPOSITORY snowflake_extensions FETCH;
   

   Copy

Prozedur erstellen und ausführen, die die Datei im Repository verwendet¶

1. Schreiben Sie die Prozedur in Snowflake.

   Wenn Sie eine Prozedur schreiben, können Sie deren Handler-Code am Speicherort der Code-Datei im Repository-Stagingbereich referenzieren. Um beispielsweise auf eine Datei python-handlers/filter.py im Hauptzweig eines Repositorys zu verweisen, das mit einem Git-Repository-Stagingbereich namens snowflake_extensions synchronisiert ist, verwenden Sie eine Syntax ähnlich der folgenden:

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

   Copy

   Der Code im folgenden Beispiel erstellt eine Prozedur namens filter_by_role, die den im Repository-Stagingbereich des Repositorys gespeicherten Handler-Code angibt:

   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. Führen Sie die Prozedur aus.

   Der folgende Code führt die Prozedur aus.

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

   Copy

   Hier ist ein Beispiel für die Ausgabe der Prozedur:

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