spark snowflake connector sql query sql编译错误

Question

我试图从我的函数(通过aws glue运行)使用输入变量查询雪花。以下是我尝试过的3件事，但我一直得到以下错误:

调用o14310.load时发生错误。SQL编译错误:第一行94

你知道是什么问题吗?不使用输入变量的常规查询运行正常..

def s_counts(df, s_id):
what_to_query = "select R_ID FROM mytable WHERE S_ID ="+s_id
CurrentCount = spark.read.format(SNOWFLAKE_SOURCE_NAME)
.options(**sfOptions)
.option("query", what_to_query)
.load()
CurrentCount = spark.read.format(SNOWFLAKE_SOURCE_NAME)
.options(**sfOptions)
.option("query", "select R_ID FROM mytable WHERE S_ID = s_id")
.load()
CurrentCount = spark.read.format(SNOWFLAKE_SOURCE_NAME)
.options(**sfOptions)
.option("query", "select R_ID FROM mytable WHERE S_ID = "+s_id)
.load()

Answer 1

尝试将s_id用引号括起来。例如

what_to_query = "select R_ID FROM mytable WHERE S_ID = '{0}'".format(s_id)

或

what_to_query = "select R_ID FROM mytable WHERE S_ID = '%s'" % (s_id)

让我知道这是否适合你。