求助：Snowflake存储过程执行成功但未生成指定目标表

Snowflake存储过程完全支持创建、覆盖或插入表，你的需求完全可以实现。你的存储过程返回成功但没生成表，是因为代码里存在几个关键错误：

• 拼写错误：langauge应改为language
• Handler语法错误：正确写法是handler = 'getTarget'，不需要加括号
• SQL语句未执行：session.sql()仅构建了SQL对象，必须调用.execute()或.collect()才会实际运行SQL
• 日期变量获取错误：endLkp直接把DataFrame转成字符串，得到的不是实际日期值，需要用.collect()[0][0]提取结果
• SQL变量替换问题：当前字符串格式化写法存在逻辑漏洞，无法正确传递变量值

修正后的存储过程代码 #

create or replace procedure get_target()
returns text
language python
runtime_version = '3.8'
packages = ('snowflake-snowpark-python')
handler = 'getTarget'
as
$$
def getTarget(session):
    # 获取参考日期
    date_ref_result = session.sql("select min(refDate) from db.schema.reference").collect()
    date_ref = date_ref_result[0][0] if date_ref_result else None
    if not date_ref:
        return 'failed: 未找到参考日期'
    
    # 计算当月最后一天
    end_lkp_result = session.sql("select last_day(to_date(?))", params=[date_ref]).collect()
    end_lkp = end_lkp_result[0][0] if end_lkp_result else None
    if not end_lkp:
        return 'failed: 无法计算结束日期'
    
    # 执行建表语句，使用绑定变量避免SQL注入并确保日期格式正确
    session.sql("""
    create or replace table db.schema.target as
    with tblA as (
        select id, value as valueA 
        from db.schema.sourceA 
        where date between ? and ?
    ), tblB as (
        select id, value as valueB 
        from db.schema.sourceB 
        where date between ? and ?
    )
    select a.id, a.valueA, b.valueB
    from tblA as a left join tblB as b on a.id=b.id
    """, params=[date_ref, end_lkp, date_ref, end_lkp]).execute()

    return 'succeeded'
$$;

关键修正说明 #

1. 修正了存储过程定义的语法错误，符合Snowflake Python存储过程的规范
2. 使用params传递变量，既避免SQL注入风险，又能保证日期类型正确传递
3. 调用.execute()执行建表SQL——这是解决表未生成的核心操作，之前的代码仅定义了SQL但未实际运行
4. 增加空值判断，避免因参考表无数据导致的运行错误
5. 变量命名遵循Python规范，提升代码可读性

执行call get_target();后，即可正常生成db.schema.target表。如果需要覆盖已有表，保持create or replace table即可；如果要插入数据，可将建表语句替换为insert into db.schema.target (...) select ...。

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