在Databricks中,使用变量传递参数进行查询需要使用直接SQL查询,而不是spark.sql('')功能。下面是一个示例:
%sql
SELECT *
FROM table_name
WHERE column_name = '$variable_name'
在这个示例中,“$variable_name”是一个变量,可以通过其它代码设置其值,比如:
variable_value = 'some_value'
# 运行直接SQL查询
sql = f"""
SELECT *
FROM table_name
WHERE column_name = '{variable_value}'
"""
df = spark.sql(sql)
上一篇:变量正在执行任务,但出现了错误。