Acesso a dados de um procedimento armazenado em Python

Você pode acessar os dados de um procedimento armazenado usando APIs da biblioteca Snowpark.

Você pode usar o objeto Session que o Snowflake cria para o seu procedimento armazenado para acessar os dados chamando APIs na biblioteca Snowpark. Por exemplo, você pode criar um DataFrame para uma tabela ou executar uma instrução SQL.

O contexto da sessão (incluindo os privilégios, o banco de dados e o esquema atuais etc.) é determinado pelo fato de o procedimento armazenado ser executado com os direitos do chamador ou com os direitos do proprietário. Para obter mais detalhes, consulte Acesso e configuração do estado da sessão.

Consulte o Guia do Desenvolvedor do Snowpark para obter mais informações.

Exemplo de acesso aos dados

No exemplo a seguir, um método Python copia um número específico de linhas de uma tabela para outra tabela. O método utiliza os seguintes argumentos:

  • Um objeto Session do Snowpark

  • O nome da tabela para copiar as linhas de

  • O nome da tabela para salvar as linhas para

  • O número de linhas a copiar

O método neste exemplo retorna uma cadeia de caracteres. Se você executar este exemplo em uma planilha Python, mude o tipo de retorno para a planilha para um String

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

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

  return "SUCCESS"
Copy