将所有的re模块函数都添加到了dbt-jinja中,但是如何使用它呢?我尝试了以下两种方法,但都没有用。
{% set matcher = re.match('^C', 'Cat') %}
're' is undefined. This can happen when calling a macro that does not exist. Check for typos and/or install package dependencies with "dbt deps".
{% set matcher = match('
我想使用DBT来枢轴在我的BigQuery表中的列。
由于我有100多个值,所以我希望我的旋转列是动态的,我想这样做:
select *
from ( select ceiu.value, ceiu.user_id, ce.name as name
from company_entity_item_user ceiu
left join company_entity ce on ce.id = ceiu.company_entity_id)
PIVOT(STRING_AGG(value) FOR name IN (select
我试图通过AirFlow触发dbt云,但无法找到以下错误的答案。
ERROR - run_job()得到了一个意外的关键字参数“conf”
我正在使用来自的插件代码
"""Main handler method to run the dbt Cloud job and track the job run status"""
job_run_id = self._trigger_job()
print(f"job_run_id = {job_run_id}")
visit_u
我需要基于行列的dbt中的动态循环。
select id,loop_count,
{% set row_loop_cnt %}
loop_count
{% endset %}
{% for i in range(loop_count) %}
//creating a list
{% endfor %}
created_list as column_name
from table_name
我得到'str对象不能解释为整数‘错误
我尝试了多种方法
loop_count::int‘红移’
loop_count | int 'Jinja‘
但运气不好,你能帮帮我吗?
我在DBT和Jinja方面非常新,我想在SQL中使用Jinja时优化我的情况。
所以,这就是我的处境:
select *,
case when what_id='006' then what_id else null end as opportunity_id
,case when what_id='a1b' then what_id else null end as billing_acc_id
,case when what_id='a04' then what_id else null end as In
我在dbt (+雪花)中有一个查询,如下所示:
with bank_str_table as (
select *
from {{ ref('bank_str_dbt') }}
),
first_table as (
select
bk.id,
bk.metadata$row_id,
bk.label,
ts_del.merge_key,
from bank_str_table bk
inner join bank_str_table ts_del on bk.METADA
我正在尝试使用Jinja在DBT中实现一个增量查询。
考虑到仓库中每个月都会创建带有年份和月份后缀的表,我需要编写一个逻辑来合并每个月创建的新表来执行DBT模型。下面是我开始使用的代码
#initialize the months in a list
{% set months= ['03','04','05','06','07','08','09','10','11','12','01','02'] %
我正在构建一个数据管道,它包含来自几个模式的数据。我试图使用jinja来获取模式名称的列表,然后在将数据组合到单个暂存表之前,在所有这些模式中查询表中的特定列(名称相同)。
在概念层面上,我知道我需要用Jinja创建两个列表:一个具有schema名称的列表,它是我想遍历的,另一个是我要在表中查询的列名列表,该列表存在于我正在查询的所有模式中。让我们调用模式名称列表schema_names和列名列表column_names。
{% set var schema_names=('brand1', 'brand2', 'brand3') %}
我想根据babel地区使用时区。我怎样才能做到这一点?我所处的具体情况是为了显示一篇文章的日期和时间以及一种人性化和本地化的方式,例如:
昨天
13时21分
或者,如果设置了瑞典语参数,它将显示。
Ig r
13时21分
如果日期不是昨天或今天,它将打印日期和24小时的时间。我想除了处理时区之外,我一切都成功了:
from webapp2_extras import i18n
from webapp2_extras.i18n import lazy_gettext as _
import datetime
from datetime import date
我正在尝试将我正在处理的Jinja模板中的字符串转换为大写。
在中,我读到:
upper(s)
Convert a value to uppercase.
所以我写了这段代码:
{% if student.department == "Academy" %}
Academy
{% elif upper(student.department) != "MATHS DEPARTMENT" %}
Maths department
{% endif %}
但是我发现了一个错误:
UndefinedError: 'upper' i
单行子查询返回多行。
这是运行以下雪花代码时遇到的错误。我知道,这是因为TO_VARCHAR函数并不适合整个表,column..any关于如何解决问题并将其应用于整个专栏的想法?
SELECT sv.SKU
, li.price
, li.cost_price
, pc.product_description
FROM raw.stitch_heroku.spree_line_items as li
LEFT OUTER JOIN (SELECT *
FROM raw.stitch_heroku.spree_var
我不确定我已经冲洗得有多糟糕了。我把dbt全局更新到v20太快了。我确实卸载了v20。我需要将项目返回到版本19.1。我在做这件事时遇到了错误。作为后台,我正在运行一个虚拟的。我用的是macos。这两个命令按预期工作:brew tap dbt-labs/dbt brew unlink dbt 然后我运行brew install dbt-labs/dbt/dbt@0.19.1 我得到(我希望是这样) Warning: dbt-labs/dbt/dbt@0.19.1 0.19.1_1 is already installed, it's just not linked. To link
我正在尝试将DBT与AWS MWAA集成,但出现以下错误: 2021-09-06 07:04:31,290] {{dbt_hook.py:117}} INFO - /usr/local/airflow/.local/bin/dbt run --profiles-dir /usr/local/airflow/dags/dbt/
[2021-09-06 07:04:31,326] {{dbt_hook.py:126}} INFO - Output:
[2021-09-06 07:04:33,280] {{dbt_hook.py:130}} INFO - Running with dbt=0.20