如何用Python解决气流中的Sql查询错误



I用户到气流GCStoBigqueryOperator使用f-string 进行N写查询

我在GCS N中的数据已经使用查询N选择数据驱动的Bigquery

我在GCS中的数据在此处输入图像描述

我的操作员查询

puuid = _puuid()
sql = f'SELECT * FROM game WHERE puuid={puuid};'

然后错误出现列

column"ptQZI4tcQ7a9KCL74omce0ctYCf4--6csx6j1CBgFUmuyB0XrGZElURF0K3_0ym9TVbykLVi_mqh9w"does not exists Line 1: SELECT * FROM game where puuid=ptQZI4tcQ7a9KCL74omce0ctYCf4--6csx6j1CBgFUmuyB0XrGZElURF0K3_0ym9TVbykLVi_mqh9w

我认为

SELECT * FROM game WHERE puuid='ptQZI4tcQ7a9KCL74omce0ctYCf4--6csx6j1CBgFUmuyB0XrGZElURF0K3_0ym9TVbykLVi_mqh9w' 

不是错误

如何更改我的代码??

字符串值必须用qoute包围。我想应该是这样的:
puuid = _puuid()
sql = f"SELECT * FROM game WHERE puuid='{puuid}'"

相关内容

  • 没有找到相关文章

最新更新