python - 如何使用 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 行。我在这里做错了什么?
编辑:从记录日期到日期的固定密钥,但仍有问题
解决方案
推荐阅读
- java - 为什么kafka中有多个反序列化器,如字符串、字节、短?
- ruby-on-rails - 如何将 split 与存储在变量中的正则表达式一起使用?
- html - 将 Font-awesome 插入符号向上和插入符号向下堆叠相邻
- reactjs - 使用 react native firebase 消息传递和 react native firebase 时出错?
- powerbi - 每个 Hiarchy 级别度量计算并将计算聚合到更高级别
- javascript - 点击搜索输入的酷炫css效果
- lua - 如何在 Lua 中执行基本身份验证
- spring-boot - 如何在弹性搜索中使用纬度经度搜索位置附近的区域
- c++ - 从共享库中剥离符号似乎不起作用
- mysql - 致命错误:试图读取结果集