Spark Sql 查询适用于硬编码值但不适用于变量

锡德

我有一个 PySpark 程序,其中有一个这样的 SQL 查询:

id = 'abc1'

info = sqlc.sql("SELECT * from df WHERE isn = 'id'")

此查询不起作用。我返回一组空白值。但是,如果我对该值进行硬编码,它就可以工作。

info = sqlc.sql("SELECT * from df WHERE isn = 'abc1'")

我试过str(id)只是为了确定。我该如何解决这个问题?

阿尔珀 t。特克

在 Python 3.5 或之前使用格式:

info = sqlc.sql("SELECT * from df WHERE isn = '{id}'".format(id=id))

或者

info = sqlc.sql("SELECT * from df WHERE isn = '{}'".format(id))

Python 3.6 及更高版本中的文字字符串格式:

info = sqlc.sql(f"SELECT * from df WHERE isn = '{id}'")

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章