SPARK SQL查询可用于硬编码值，但没有变量

Question

我有一个pyspark程序，其中有一个SQL查询：

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

此查询不起作用。我带有一组空白的值返回。但是，如果我将值进行了编码，则可以工作。

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

我尝试了str(id)。我该如何解决？

Answer 1

在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}'")