如何在DBT项目中更改Google_ads模式?
我有一个DBT项目,我正在使用AD_Reporting模型。 除Google_ads外,所有来源都很好。 那是因为我没有Google_ads架构,而是我有Google_ads_us架构。 我…
使用/设计 dbt 关系测试的好方法
我想对M_0进行DBT关系测试。 models: - name: m_0 columns: - name: customer_id tests: - relationships: to: ref('m_1') field: id 然后我遇到了两…
如何上传包含DBT NEWLINE的CSV数据
我有一个第三方生成的CSV文件,我希望使用 dbt seed 上传到Google BigQuery。 我设法将其手动上传到BigQuery,但是我需要启用默认情况下的“引用Newli…
将字符串转换为数组 SQL/Snowflake?dbt
我有以下列,每行的字符串: country = us& lan = en&零售商= nike&零售商= addidas&零售商= puma = puma, 我想提取国家和零售…
将运行查询的结果存储到DBT中的表中
我在 dbt 中调用这个存储过程。如何使用 select 语句将结果存储到临时表中? {% set results= run_query('call mystoredproc()') %} {% do log("Print…
我们可以通过使用sql的存储过程返回雪花上大约270列的表吗?语法如下
我们可以使用SQL作为语言返回雪花中的表格吗?如果可能的话,正确的语法是什么? create or replace procedure sp() returns table () language sql a…
hook to dbt_cloud_pr schemas(dbt云CI)
我想知道是否可以将 post hook 附加到 DBT_CLOUD_PR 模式(由 dbt Cloud CI 生成),以便只有开发人员才能看到数据库上生成的 PR 表。 我想做如下的事…
如何在DBT中使用CETA(Synapse无服务器池)?
在 Synapse Serverless Pool 中,我可以使用 CETAS 创建外部表并将结果导出到 Azure Data Lake Storage。 CREATE EXTERNAL TABLE external_table WITH…
DBT Cloud:下游模型未构建
我有一个DBT云项目,该项目具有 erp_distributor_selected.sql 作为其第一个模型。有下游模型,例如 erp_sel_flatfile_transaction_references2.sql …
for 循环中的 DBT 引用
我的 dbt 项目中有一个子查询列表 [“base”、“table_1”、“table_2”、“table_3”...]。 我想将它们加入到一个共同的列 id 中。 我想通过使用 for…
使用dbt时如何手动创建表或使用postgres分区?
我想使用 dbt 将数据插入到分区表中,但发现 postgres 不支持 dbt 分区。 通过另一种方式,我在 pre_hook 中创建表和分区,但在 dbt 运行时收到错误“…
运行 dbt docs generated 时 DBT 不会抛出错误,但缺少catalog.json
我是 dbt 新手,我成功地创建了模型、模式和宏,但是当我生成 dbt 文档时,我得到了 manifest.json,但没有得到catalog.json,所以 dbt docsserve正在…