Synapse Spark池环境下向Spark SQL传递变量的方法咨询

你之前的写法无法生效的核心原因是：Python cell中定义的普通变量，默认不会自动注入到SparkSQL的执行上下文，无法直接在%%sql cell中通过$变量名的方式读取。
正确操作有两种常用方案： #

方案1：在PySpark cell中拼接SQL语句执行 #

直接通过Python f-string拼接变量后调用spark.sql执行SQL逻辑，适合需要对结果做后续DataFrame处理的场景：

%%pyspark
# 自定义变量
stat = 'A'
# 拼接生成完整SQL语句
exec_sql = f"SELECT * FROM silver.employee_dim WHERE Status = '{stat}'"
# 执行SQL
result_df = spark.sql(exec_sql)
# 查看结果
display(result_df)

方案2：注册变量到Spark配置，在独立%%sql cell中调用 #

如果你需要单独使用%%sql魔法命令写SQL，先将Python变量注册到Spark全局配置中即可跨cell读取：

第一步：参数cell中注册变量 #

%%pyspark
stat = 'A'
# 将变量写入Spark配置，自定义配置键建议加前缀避免和内置配置冲突
spark.conf.set("app.params.stat", stat)

第二步：SQL cell中读取变量 #

使用${配置键}的格式读取已注册的变量，字符串类型变量需要在外层补单引号，如果是数值类型的变量，引用时不需要加外层单引号：

%%sql
SELECT * FROM silver.employee_dim WHERE Status = '${app.params.stat}'

注意事项 #

• 如果变量值包含单引号等SQL特殊字符，需要提前做转义处理，避免出现语法错误
• 变量更新后需要重新执行spark.conf.set操作，最新值才会同步到Spark配置中

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