diff --git a/models/br_rf_arrecadacao/br_rf_arrecadacao__itr.sql b/models/br_rf_arrecadacao/br_rf_arrecadacao__itr.sql index e52f5758..9df429f1 100644 --- a/models/br_rf_arrecadacao/br_rf_arrecadacao__itr.sql +++ b/models/br_rf_arrecadacao/br_rf_arrecadacao__itr.sql @@ -11,12 +11,14 @@ 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-dev.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.valor_arrecadado as float64) valor_arrecadado, +from `basedosdados-de.br_rf_arrecadacao_staging.itr` itr +left join + `basedosdados-dev.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 index f9d55e16..e28167cc 100644 --- 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, id_municipio] - not_null_proportion_multiple_columns: at_least: 0.95 columns: @@ -471,14 +471,11 @@ 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 - description: Nome do município conveniado ou não conveniado. + to: ref('br_bd_diretorios_brasil__municipio') + field: id_municipio - name: valor_arrecadado description: Valor arrecadado.