Python 저장 프로시저에서 데이터 액세스하기

Snowpark 라이브러리 API를 사용하여 저장 프로시저에서 데이터에 액세스할 수 있습니다.

Snowflake가 저장 프로시저에 대해 생성하는 Session 오브젝트를 사용하면 Snowpark 라이브러리 에서 API를 호출하여 데이터에 액세스할 수 있습니다. 예를 들어, 테이블에 대한 DataFrame을 만들거나 SQL 문을 실행할 수 있습니다.

세션에 대한 컨텍스트(권한, 현재 데이터베이스 및 스키마 등)는 저장 프로시저가 호출자 권한 또는 소유자 권한 으로 실행되는지에 따라 결정됩니다. 자세한 내용은 세션 상태 액세스 및 설정하기 섹션을 참조하십시오.

자세한 내용은 Snowpark 개발자 가이드 를 참조하십시오.

데이터 액세스 예

다음 예에서 Python 메서드는 한 테이블에서 다른 테이블로 지정된 수의 행을 복사본으로 복사합니다. 이 메서드는 다음 인자를 사용합니다.

  • Snowpark Session 오브젝트

  • 행을 복사할 출처가 되는 테이블의 이름

  • 행이 저장될 테이블의 이름

  • 복사할 행의 수

이 예의 메서드는 문자열을 반환합니다. Python 워크시트 에서 이 예제 코드를 실행하는 경우 워크시트의 반환 유형 을 String 으로 변경합니다.

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

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

  return "SUCCESS"
Copy
언어: 한국어