Snowflake Snowpark Python - 存储过程

Question

我利用 Snowpark Python（私人预览版）完成了一些数据工程任务（将数据从原始状态转换为干净状态）。如何将 Python 代码上传到 Snowflake 并运行它？

我认为它需要是一个存储过程，但我找不到任何关于如何在 Python 中创建存储过程的文档。

Answer 1

Snowpark Stored Procedures for Python — Preview 于 2022 年 6 月发布。

---

文档可在Writing Stored Procedures in Snowpark (Python)获取

内联存储过程示例：

CREATE OR REPLACE PROCEDURE MYPROC(from_table STRING, to_table STRING, count INT)
  RETURNS STRING
  LANGUAGE PYTHON
  RUNTIME_VERSION = '3.8'
  PACKAGES = ('snowflake-snowpark-python')
  HANDLER = 'run'
AS
$$
def run(session, from_table, to_table, count):
  session.table(from_table).limit(count).write.save_as_table(to_table)
  return "SUCCESS"
$$;