首页 > 解决方案 > 如何使用 Jinja 将日期字符串传递到 SQL 查询中

问题描述

我需要将日期“20200303”传递到读取 jinja 的 SQL 表中。

python脚本如下:

record_date = '20170303'

sql_data = {'date':record_date}

for file in files_sql:
    with open(file) as file_reader:
        sql_template = file_reader.read()

    sql_template = jinja(sql_template)
    sql_query = sql_template.render(data=sql_data)
    spark.sql(sql_query)

它正在读取的 sql 查询文件 (query_A.sql) 如下所示:

SELECT * FROM table where date <= {{date}}

但是这不起作用并且返回 0 行。我在这里做错了什么?

编辑:从记录日期到日期的固定密钥,但仍有问题

标签: pythonsqltsqljinja2

解决方案


推荐阅读