Snowflake Python API: gerenciamento de objetos Snowflake com Python¶
Recurso em versão preliminar — Aberto
Disponível para todas as contas.
A Snowflake Python API é a Python API unificada em todas as cargas de trabalho do Snowflake, destinada a fornecer APIs para todos os recursos do Snowflake nas cargas de trabalho de aplicativo de engenharia de dados, Snowpark e cliente.
Você pode usar a Snowflake Python API para interagir com os recursos do Snowflake, criando, excluindo, modificando-os e muito mais. Você pode usar Python para executar tarefas que você poderia executar com os comandos SQL do Snowflake.
Com a Snowflake Python API, atualmente você pode gerenciar os seguintes objetos Snowflake:
Tarefas, com as quais você pode executar instruções SQL, chamadas de procedimento e lógica no Script Snowflake.
Para obter mais informações, consulte Gerenciamento de tarefas do Snowflake e DAGs com Python.
Recursos no Snowpark Container Services, incluindo pools de computação, repositórios de imagens e serviços.
Para obter mais informações, consulte Gerenciamento do Snowpark Container Services com Python.
Para obter um tutorial introdutório sobre como usar a Snowflake Python API, consulte Guia de início rápido: Introdução à Snowflake Python API.
Exemplo¶
O código no exemplo a seguir executa uma tarefa chamada my_task. O código usa parâmetros de conexão definidos em um arquivo de configuração para criar uma conexão com o Snowflake. Usando o objeto Session resultante, o código cria um objeto Root para usar os tipos e métodos de API. Usando a API, o código cria um objeto Task representando my_task. Usando um objeto TaskResource task_res, o código executa a tarefa.
Para obter mais informações sobre ações relacionadas a tarefas que você pode executar com a API, consulte Gerenciamento de tarefas do Snowflake e DAGs com Python.
from snowflake.core import Root
from snowflake.core.task import Task
from snowflake.snowpark import Session
session = Session.builder.config("connection_name", "myconnection").create()
root = Root(session)
tasks = root.databases["mydb"].schemas["myschema"].tasks
task_res = tasks['my_task']
task_res.execute()
Limitações¶
A Snowflake Python API não está disponível atualmente no canal Snowflake Anaconda.
Guias do desenvolvedor¶
Guia |
Descrição |
|---|---|
Instale o pacote da Snowflake Python API. |
|
Conecte-se ao Snowflake a partir do código Python. |
|
Use a API para criar, executar e gerenciar tarefas e DAGs de tarefas. |
|
Gerenciamento de bancos de dados, esquemas e tabelas Snowflake com Python |
Use a API para criar e gerenciar bancos de dados, esquemas e tabelas. |
Gerenciamento de warehouses virtuais do Snowflake com Python |
Use a API para criar e gerenciar warehouses virtuais. |
Use a API para gerenciar componentes do Snowpark Container Services, incluindo pools de computação, repositórios de imagens e serviços. |
Referências¶
Referência da Snowflake Python API
Custos de acesso ao Snowflake¶
Para reduzir custos — tanto para crédito de uso quanto para atividade de rede — a Snowflake Python API foi projetada para se comunicar com o Snowflake somente quando você chama métodos projetados para sincronizar com o Snowflake.
Os objetos na API são referências locais (ou manipuladores) ou instantâneos de estado armazenados no Snowflake. Em geral, se você agir ou recuperar informações do Snowflake, fará isso por meio de um objeto de referência local na memória.
Essas referências não são sincronizadas com o Snowflake até que você chame um método. Quando você chama um método, geralmente incorre em custos tanto no crédito de uso quanto na atividade da rede. Por outro lado, quando você trabalha com referências na memória, como ao acessar atributos, seu trabalho é executado localmente e não incorre em tais custos.