Jinja 模板

Jinja 是一个高效、功能强大的模板引擎,广泛用于生成动态内容。它允许在多种基于文本的格式(如 HTML、XML、CSV 或 LaTex)中嵌入编程逻辑。了解更多信息,请参阅:Jinja 文档

在现代数据工程中,Jinja 因为能够在 SQL 转换中支持变量、逻辑和重用性,已经成为一种流行的选择。

Recurve 支持在 SQL 模型中直接使用 Jinja。

Jinja 语法

Jinja 的语法与 Python 类似,代码通常位于特定的分隔符标签内,主要包括以下几种:

  • 表达式{{ ... }}: 用于输出字符串、引用变量和调用宏。

  • 语句{% ... %}:用于控制流(如 for 循环和 if 语句),也用于定义宏。

  • 注释{# ... #}:注释内容,编译时会被忽略。

以下是一些在 Recurve SQL 模型中使用 Jinja 的示例。

设置变量

Recurve 支持创建全局变量,这些变量可以在多个模型和数据管道中重复使用。详情请查阅文档:变量

在 Jinja 中,您可以按照以下方式定义局部变量:

-- min_rental_duration = 3, defined in the Variables section

SELECT film_id, title, rental_duration
FROM film
WHERE rental_duration >= {{ var('min_rental_duration') }}

if 语句

if 语句来检查条件:

{% set include_r_rated = true %}

SELECT film_id, title, rating
FROM film
WHERE 1=1 
{% if include_r_rated %}
  AND rating = 'R'
{% else %}
  AND rating != 'R'
{% endif %}

for 循环

for 循环来遍历一个列表或字典:

{% set categories = ['Action', 'Comedy', 'Drama'] %}

SELECT f.film_id, f.title, c.name AS category
FROM film f
JOIN film_category fc ON f.film_id = fc.film_id
JOIN category c ON fc.category_id = c.category_id
WHERE c.name IN (
  {% for category in categories %}
    '{{ category }}'{% if not loop.last %},{% endif %}
  {% endfor %}
)

Last updated