是否可在Snowflake Snowpark的Python UDF中编写SQL查询？

普通Python UDF无法实现你要的内部执行SQL、批量克隆表的需求，你的现有代码存在几个本质问题：

• 代码里仅将SQL语句定义为字符串，没有任何触发SQL执行的逻辑，字符串本身不会在Snowflake中产生实际查询、操作效果
• 标准Python UDF运行在隔离沙箱中，没有内置可操作Snowflake的会话上下文，不支持主动发起SQL查询请求
• UDF设计上是无副作用的只读逻辑，不允许执行CREATE TABLE这类会修改库表结构的DDL写操作。

你要实现的批量克隆表逻辑，需要使用Python编写的Snowpark存储过程替代UDF，存储过程默认注入Snowpark Session对象，支持直接在代码内执行任意SQL、DDL操作，参考可运行代码如下：

create or replace procedure SnowparkPrivateSchema()
returns string
language python
runtime_version=3.8
handler='run_clone'
packages = ('snowflake-snowpark-python')
execute as owner -- 也可以根据权限需求配置为execute as caller
as $$
def run_clone(session):
    # 查询获取目标范围的表列表，建议按需加过滤条件避免克隆不需要的表
    table_records = session.sql("""
        SELECT table_name 
        FROM INFORMATION_SCHEMA.TABLES 
        WHERE TABLE_SCHEMA = '你要克隆的源SCHEMA名称'
          AND TABLE_TYPE = 'BASE TABLE'
    """).collect()

    success_count = 0
    for record in table_records:
        t_name = record.TABLE_NAME
        # 执行单表克隆
        session.sql(f"""
            CREATE OR REPLACE TABLE clone_user.{t_name} 
            CLONE 源SCHEMA名称.{t_name}
        """).collect()
        success_count += 1
    
    return f"执行完成，共克隆{success_count}张表到clone_user schema"
$$;

使用注意事项：

• 存储过程创建完成后，使用call SnowparkPrivateSchema();语法调用，和UDF调用语法不同
• 提前确认执行账号的权限：具备源表的读取权限、clone_user schema下的建表权限、INFORMATION_SCHEMA的查询权限
• 建议给查询表的SQL增加明确的schema、表名过滤规则，避免误克隆无关表。

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