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 SnowparkO 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"