Accéder aux données à partir d’une procédure stockée Python

Vous pouvez accéder aux données d’une procédure stockée en utilisant les APIs de bibliothèque Snowpark.

Vous pouvez utiliser l’objet Session que Snowflake crée pour votre procédure stockée afin d’accéder aux données en appelant les APIs dans la bibliothèque Snowpark. Par exemple, vous pouvez créer un DataFrame pour une table ou exécuter une instruction SQL.

Le contexte de la session (y compris les privilèges, la base de données et le schéma actuels, etc.) est déterminé par le fait que la procédure stockée s’exécute avec les droits de l’appelant ou les droits du propriétaire. Pour plus de détails, voir Accéder à l’état de la session et le définir.

Voir le Guide du développeur Snowpark pour plus d’informations.

Exemple d’accès aux données

Dans l’exemple suivant, une méthode Python copie un nombre spécifié de lignes d’une table vers une autre table. La méthode accepte les arguments suivants :

  • Un objet Session Snowpark

  • Le nom de la table à partir de laquelle les lignes doivent être copiées

  • Le nom de la table dans laquelle les lignes doivent être enregistrées

  • Le nombre de lignes à copier

La méthode dans cet exemple renvoie une chaîne. Si vous exécutez cet exemple dans une feuille de calcul Python, remplacez le type de retour pour la feuille de calcul par une String

def run(session, from_table, to_table, count):

  session.table(from_table).limit(count).write.save_as_table(to_table)

  return "SUCCESS"
Copy
Langage: Français