我正在使用databricks笔记本,我希望使用koalas.sql将几个python变量传递给一个SQL查询。
这里是我试图做的一个简单的例子。
import databricks.koalas as ks
query = """
SELECT *
FROM my_database
WHERE animal = pyth_var
"""
ks.sql(query, globals = {'pyth_var':'dog'})但是python变量无法读取。我得到:
AnalysisException:无法解析给定的输入列“
pyth_var”
发布于 2022-10-29 20:51:29
我认为您所需要的只是用大括号将SQL语句中的引用变量封装起来,这样考拉就可以将它们解释为变量。文档说:
(koalas.sql)该函数还支持在SQL语句中嵌入Python变量(局部变量、全局变量和参数),方法是将它们封装在大括号中。
所以,你可以试试这样的方法:
ks.sql("SELECT * FROM my_database WHERE animal = {pyth_var}", globals={"python_var": "dog"})https://stackoverflow.com/questions/74208130
复制相似问题