Snowflake中无需定义UDF/存储过程运行Python代码的方法

Snowflake目前没有像SQL匿名块那样原生支持Python/Java/Scala的匿名块语法，但可以通过以下两种方式实现一次性运行代码、不创建任何持久化/临时数据库对象的需求：

方法1：Snowpark客户端即席执行（本地脚本/Notebook） #

直接在本地通过Snowflake的Snowpark SDK连接账户，编写并执行代码逻辑，全程不会在Snowflake端创建UDF或存储过程。

Python示例 #

from snowflake.snowpark import Session

# 配置Snowflake连接参数
conn_params = {
    "account": "你的账户标识",
    "user": "用户名",
    "password": "密码",
    "warehouse": "计算仓库",
    "database": "目标数据库",
    "schema": "目标模式"
}

# 创建会话并执行一次性逻辑
with Session.builder.configs(conn_params).create() as session:
    # 读取数据并处理
    df = session.table("示例表")
    filtered_df = df.filter(df["STATUS"] == "ACTIVE").select("ID", "VALUE")
    
    # 输出结果
    filtered_df.show()

所有计算逻辑在客户端与Snowflake交互完成后，不会在Snowflake中留下任何对象。

方法2：Snowflake Worksheet内联代码块 #

在Snowflake Web UI的Worksheet中，切换到对应语言模式，直接编写并运行代码，无需创建存储过程或UDF，执行后无残留对象。

操作步骤 #

1. 打开Snowflake Worksheet，点击顶部语言选择器，切换到Python或Scala
2. 编写代码并点击「Run」执行，示例（Python）：

# 直接在Worksheet中运行的一次性代码
df = session.table("销售数据表")
monthly_total = df.groupBy("月份").agg({"销售额": "SUM"}).collect()

# 打印结果
for row in monthly_total:
    print(f"{row[0]}: {row[1]}")

Java/Scala适配说明 #

对于Java和Scala，实现逻辑与Python一致：

• 客户端方式：通过Snowpark Java/Scala SDK创建会话，编写即席执行代码
• Worksheet方式：在Worksheet中切换到Scala模式，直接编写运行代码

注意事项 #

• 确保你的Snowflake账户已启用Snowpark支持
• 客户端执行需提前安装对应语言的Snowpark SDK（如Python：pip install snowflake-snowpark-python）

内容的提问来源于stack exchange，提问作者Lukasz Szozda