存储过程中调用Snowflake外部函数失效问题求助

直接使用SELECT语句调用Snowflake外部函数可正常执行：

select djone_src.sf_notify.lambda_sns_notify('subject','body','ebs-international-trigger-timely') 
from dual;

但在Python存储过程中，无论是用call_udf还是session.sql执行SELECT调用同一外部函数，都无法触发调用，查询概览也没有相关记录。存储过程代码如下：

USE DATABASE DJONE_DEV;
create or replace procedure email_last_results(subject string, sns_topic string)
returns string
language python
runtime_version=3.8
packages = ('snowflake-snowpark-python', 'tabulate')
handler = 'x'
execute as caller
as
$$
import snowflake.snowpark as snowpark
from snowflake.snowpark.functions import call_udf


def x(session, subject, sns_topic):
     try: 
        body = session.sql(
         "select * from table(result_scan(last_query_id(-1))) limit 100"
                    ).to_pandas().to_markdown()
     except snowflake.snowpark.exceptions.SnowparkSQLException as e:
        body = '%s\n%s' % (type(e), e)
     
     call_udf(
      'djone_src.sf_notify.lambda_sns_notify','subject','body','sns_topic')
     return 'email sent:\n%s' % body
$$;

call email_last_results('para@email.com', 'results from snowflake', 'ebs-international-trigger-timely');

请问是否可通过调整会话日志级别提升问题可见性？

1. 先修复存储过程中外部函数的调用问题 #

当前存储过程的call_udf调用存在两个核心问题：

• 传入的是字符串字面量'subject'、'body'、'sns_topic'，而非存储过程的参数变量，导致函数接收固定字符串而非预期的动态值。
• call_udf是Snowpark的表达式构造函数，直接调用不会触发执行，必须嵌入DataFrame操作（如select+collect）才会实际运行。

修正方式一：用session.sql执行带绑定变量的SELECT #

替换原call_udf代码，通过绑定变量安全传递参数并触发执行：

session.sql("""
    select djone_src.sf_notify.lambda_sns_notify(?, ?, ?)
    from dual
""", params=[subject, body, sns_topic]).collect()

修正方式二：正确使用call_udf结合DataFrame操作 #

用lit()将Python变量转为Snowpark表达式，再通过select+collect触发执行：

from snowflake.snowpark.functions import lit

session.select(
    call_udf(
        'djone_src.sf_notify.lambda_sns_notify',
        lit(subject), lit(body), lit(sns_topic)
    )
).collect()

2. 调整会话日志级别提升问题可见性 #

可以通过以下两种方式开启详细日志，辅助排查问题：

• 设置Snowflake会话日志级别：

ALTER SESSION SET CLIENT_LOG_LEVEL = 'DEBUG';

• 在Python存储过程中添加日志配置：

import logging
logging.basicConfig(level=logging.DEBUG)

开启DEBUG级别后，会输出外部函数调用的请求、响应细节，以及SQL执行的完整链路日志，帮助定位未触发调用的具体原因。

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