Fix br_rf_arrecadacao_itr

basedosdados · Nov 7, 2024 · dc49d6b · dc49d6b
1 parent f3f907f
commit dc49d6b
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 15 deletions.
diff --git a/models/br_rf_arrecadacao/br_rf_arrecadacao__itr.sql b/models/br_rf_arrecadacao/br_rf_arrecadacao__itr.sql
@@ -11,12 +11,15 @@
         cluster_by=["mes"],
     )
 }}
-
 select
-    safe_cast(ano as int64) ano,
-    safe_cast(mes as int64) mes,
-    safe_cast(sigla_uf as string) sigla_uf,
-    safe_cast(sigla_regiao as string) sigla_regiao,
-    safe_cast(cidade as string) cidade,
-    safe_cast(valor_arrecadado as float64) valor_arrecadado,
-from `basedosdados-staging.br_rf_arrecadacao_staging.itr` as t
+    safe_cast(itr.ano as int64) ano,
+    safe_cast(itr.mes as int64) mes,
+    safe_cast(itr.sigla_uf as string) sigla_uf,
+    safe_cast(m.id_municipio as string) id_municipio,
+    safe_cast(itr.cidade as string) nome_municipio,
+    safe_cast(itr.valor_arrecadado as float64) valor_arrecadado,
+from `basedosdados-staging.br_rf_arrecadacao_staging.itr` itr
+left join
+    `basedosdados-staging.br_bd_diretorios_brasil.municipio` m
+    on itr.cidade = m.nome
+    and itr.sigla_uf = m.sigla_uf
diff --git a/models/br_rf_arrecadacao/schema.yml b/models/br_rf_arrecadacao/schema.yml
@@ -448,7 +448,7 @@ models:
       fiscalizar e cobrar o ITR, de acordo com dispositivo constitucional.
     tests:
       - dbt_utils.unique_combination_of_columns:
-          combination_of_columns: [ano, mes, sigla_uf, sigla_regiao, cidade]
+          combination_of_columns: [ano, mes, sigla_uf, nome_municipio]
       - not_null_proportion_multiple_columns:
           at_least: 0.95
     columns:
@@ -471,14 +471,13 @@ models:
           - relationships:
               to: ref('br_bd_diretorios_brasil__uf')
               field: sigla
-      - name: sigla_regiao
-        description: Sigla da Região Política onde se localiza o município conveniado
-          ou não conveniado.
+      - name: id_municipio
+        description: ID do município conveniado ou não conveniado.
         tests:
           - relationships:
-              to: ref('br_bd_diretorios_brasil__regiao')
-              field: sigla
-      - name: cidade
+              to: ref('br_bd_diretorios_brasil__municipio')
+              field: id_municipio
+      - name: nome_municipio
         description: Nome do município conveniado ou não conveniado.
       - name: valor_arrecadado
         description: Valor arrecadado.