我有一个 PySpark 程序,其中有一个这样的 SQL 查询:
id = 'abc1'
info = sqlc.sql("SELECT * from df WHERE isn = 'id'")
此查询不起作用。我返回一组空白值。但是,如果我对该值进行硬编码,它就可以工作。
info = sqlc.sql("SELECT * from df WHERE isn = 'abc1'")
我试过str(id)
只是为了确定。我该如何解决这个问题?
在 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] 删除。
我来说两句