From 63c72fa320d65599a300c8a94708748a59b28d01 Mon Sep 17 00:00:00 2001 From: tricktx Date: Wed, 19 Jul 2023 17:00:50 -0300 Subject: [PATCH] where dbt bd pro --- .../br_anatel_telefonia_movel__densidade_brasil.sql | 3 ++- .../br_anatel_telefonia_movel__densidade_municipio.sql | 1 + .../br_anatel_telefonia_movel__densidade_uf.sql | 3 ++- .../br_anatel_telefonia_movel__microdados.sql | 3 ++- 4 files changed, 7 insertions(+), 3 deletions(-) diff --git a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_brasil.sql b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_brasil.sql index 1d4c0cea..70ced06d 100644 --- a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_brasil.sql +++ b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_brasil.sql @@ -5,4 +5,5 @@ SAFE_CAST(ano AS INT64) ano, SAFE_CAST(mes AS INT64) mes, SAFE_CAST(densidade AS FLOAT64) densidade -FROM basedosdados-staging.br_anatel_telefonia_movel_staging.densidade_brasil AS t \ No newline at end of file +FROM basedosdados-staging.br_anatel_telefonia_movel_staging.densidade_brasil AS t +WHERE DATE_DIFF(CURRENT_DATE(),DATE(SAFE_CAST(ano AS INT64),SAFE_CAST(mes AS INT64),01),month) >= 6 \ No newline at end of file diff --git a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_municipio.sql b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_municipio.sql index 340eff44..d12820c8 100644 --- a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_municipio.sql +++ b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_municipio.sql @@ -23,3 +23,4 @@ REPLACE(CAST(id_municipio AS STRING), '.0', '') id_municipio, SAFE_CAST(densidade AS FLOAT64) densidade FROM basedosdados-staging.br_anatel_telefonia_movel_staging.densidade_municipio AS t +WHERE DATE_DIFF(CURRENT_DATE(),DATE(SAFE_CAST(ano AS INT64),SAFE_CAST(mes AS INT64),01),month) >= 6 \ No newline at end of file diff --git a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_uf.sql b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_uf.sql index ce474971..018e86f7 100644 --- a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_uf.sql +++ b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__densidade_uf.sql @@ -5,4 +5,5 @@ SAFE_CAST(ano AS INT64) ano, SAFE_CAST(mes AS INT64) mes, SAFE_CAST(sigla_uf AS STRING) sigla_uf, SAFE_CAST(densidade AS FLOAT64) densidade -FROM basedosdados-staging.br_anatel_telefonia_movel_staging.densidade_uf AS t \ No newline at end of file +FROM basedosdados-staging.br_anatel_telefonia_movel_staging.densidade_uf AS t +WHERE DATE_DIFF(CURRENT_DATE(),DATE(SAFE_CAST(ano AS INT64),SAFE_CAST(mes AS INT64),01),month) >= 6 \ No newline at end of file diff --git a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__microdados.sql b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__microdados.sql index b02bb6a4..6bac9aac 100644 --- a/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__microdados.sql +++ b/models/br_anatel_telefonia_movel/br_anatel_telefonia_movel__microdados.sql @@ -31,4 +31,5 @@ SAFE_CAST(pessoa AS STRING) pessoa, SAFE_CAST(produto AS STRING) produto, SAFE_CAST(acessos AS INT64) acessos -FROM basedosdados-staging.br_anatel_telefonia_movel_staging.microdados AS t \ No newline at end of file +FROM basedosdados-staging.br_anatel_telefonia_movel_staging.microdados AS t +WHERE DATE_DIFF(CURRENT_DATE(),DATE(SAFE_CAST(ano AS INT64),SAFE_CAST(mes AS INT64),01),month) >= 6 \ No newline at end of file