From d3b76a21df5482df96db1b5c4ab7741b9081e897 Mon Sep 17 00:00:00 2001 From: Ricardo Dahis Date: Mon, 8 Apr 2024 14:34:13 +1000 Subject: [PATCH] update schema and materializations --- .../br_tse_eleicoes__bens_candidato.sql | 1 - .../br_tse_eleicoes__candidatos.sql | 70 ++++++++----------- .../br_tse_eleicoes__despesas_candidato.sql | 1 - ...e_eleicoes__detalhes_votacao_municipio.sql | 42 +++++++++++ ...icoes__detalhes_votacao_municipio_zona.sql | 43 ++++++++++++ ...r_tse_eleicoes__detalhes_votacao_secao.sql | 43 ++++++++++++ .../br_tse_eleicoes__partidos.sql | 56 +++++++++++++++ ...icoes__perfil_eleitorado_local_votacao.sql | 60 ++++++++++++++++ ...coes__perfil_eleitorado_municipio_zona.sql | 49 +++++++++++++ ..._tse_eleicoes__perfil_eleitorado_secao.sql | 51 ++++++++++++++ .../br_tse_eleicoes__receitas_candidato.sql | 1 - .../br_tse_eleicoes__receitas_comite.sql | 1 - ...se_eleicoes__receitas_orgao_partidario.sql | 1 - .../br_tse_eleicoes__resultados_candidato.sql | 1 - ...eicoes__resultados_candidato_municipio.sql | 34 +++++++++ ...s__resultados_candidato_municipio_zona.sql | 35 ++++++++++ ...e_eleicoes__resultados_candidato_secao.sql | 46 ++++++------ ...eleicoes__resultados_partido_municipio.sql | 31 ++++++++ ...oes__resultados_partido_municipio_zona.sql | 32 +++++++++ ...tse_eleicoes__resultados_partido_secao.sql | 42 ++++++----- .../br_tse_eleicoes__vagas.sql | 27 +++++++ models/br_tse_eleicoes/schema.yml | 30 +++----- 22 files changed, 590 insertions(+), 107 deletions(-) create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio_zona.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_secao.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__partidos.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_local_votacao.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_municipio_zona.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_secao.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio_zona.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio_zona.sql create mode 100644 models/br_tse_eleicoes/br_tse_eleicoes__vagas.sql diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__bens_candidato.sql b/models/br_tse_eleicoes/br_tse_eleicoes__bens_candidato.sql index 9f85e8d1..2f37bdab 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__bens_candidato.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__bens_candidato.sql @@ -8,7 +8,6 @@ "data_type": "int64", "range": {"start": 2006, "end": 2022, "interval": 2}, }, - cluster_by=["sigla_uf"], ) }} diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__candidatos.sql b/models/br_tse_eleicoes/br_tse_eleicoes__candidatos.sql index 6aec1d4d..0c073d5c 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__candidatos.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__candidatos.sql @@ -8,45 +8,35 @@ "data_type": "int64", "range": {"start": 1994, "end": 2022, "interval": 2}, }, - cluster_by=["sigla_uf"], ) }} --- precisa ser atualizada com as colunas de federação -select - safe_cast(ano as int64) ano, - safe_cast(tipo_eleicao as string) tipo_eleicao, - safe_cast(sigla_uf as string) sigla_uf, - safe_cast(id_municipio as string) id_municipio, - safe_cast(id_municipio_tse as string) id_municipio_tse, - cast(split(id_candidato_bd, '.')[offset(0)] as string) id_candidato_bd, - cast(split(cpf, '.')[offset(0)] as string) cpf, - safe_cast(titulo_eleitoral as string) titulo_eleitoral, - safe_cast(sequencial as string) sequencial, - safe_cast(numero as string) numero, - safe_cast(nome as string) nome, - safe_cast(nome_urna as string) nome_urna, - safe_cast(numero_partido as string) numero_partido, - safe_cast(sigla_partido as string) sigla_partido, - safe_cast(cargo as string) cargo, - safe_cast(situacao as string) situacao, - safe_cast(ocupacao as string) ocupacao, - safe_cast(data_nascimento as date) data_nascimento, - cast(split(idade, '.')[offset(0)] as int64) idade, - safe_cast(genero as string) genero, - safe_cast(instrucao as string) instrucao, - safe_cast(estado_civil as string) estado_civil, - safe_cast(nacionalidade as string) nacionalidade, - safe_cast(sigla_uf_nascimento as string) sigla_uf_nascimento, - safe_cast(municipio_nascimento as string) municipio_nascimento, - safe_cast(email as string) email, - safe_cast(raca as string) raca, --- SAFE_CAST(situacao_totalizacao AS STRING) situacao_totalizacao, --- SAFE_CAST(numero_federacao AS STRING) numero_federacao, --- SAFE_CAST(nome_federacao AS STRING) nome_federacao, --- SAFE_CAST(sigla_federacao AS STRING) sigla_federacao, --- SAFE_CAST(composicao_federacao AS STRING) composicao_federacao, --- CASE --- WHEN prestou_contas='N' THEN 'Nao' --- WHEN prestou_contas='S' THEN 'Sim' --- END AS prestou_contas -from `basedosdados-staging.br_tse_eleicoes_staging.candidatos` as t + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +CAST(SPLIT(id_candidato_bd, '.')[OFFSET(0)] AS STRING) id_candidato_bd, +CAST(SPLIT(cpf, '.')[OFFSET(0)] AS STRING) cpf, +SAFE_CAST(titulo_eleitoral AS STRING) titulo_eleitoral, +SAFE_CAST(sequencial AS STRING) sequencial, +SAFE_CAST(numero AS STRING) numero, +SAFE_CAST(nome AS STRING) nome, +SAFE_CAST(nome_urna AS STRING) nome_urna, +SAFE_CAST(numero_partido AS STRING) numero_partido, +SAFE_CAST(sigla_partido AS STRING) sigla_partido, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(situacao AS STRING) situacao, +SAFE_CAST(ocupacao AS STRING) ocupacao, +SAFE_CAST(data_nascimento AS DATE) data_nascimento, +CAST(SPLIT(idade, '.')[OFFSET(0)] AS INT64) idade, +SAFE_CAST(genero AS STRING) genero, +SAFE_CAST(instrucao AS STRING) instrucao, +SAFE_CAST(estado_civil AS STRING) estado_civil, +SAFE_CAST(nacionalidade AS STRING) nacionalidade, +SAFE_CAST(sigla_uf_nascimento AS STRING) sigla_uf_nascimento, +SAFE_CAST(municipio_nascimento AS STRING) municipio_nascimento, +SAFE_CAST(email AS STRING) email, +SAFE_CAST(raca AS STRING) raca +FROM basedosdados-staging.br_tse_eleicoes_staging.candidatos AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__despesas_candidato.sql b/models/br_tse_eleicoes/br_tse_eleicoes__despesas_candidato.sql index efebaf0a..c12af2e0 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__despesas_candidato.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__despesas_candidato.sql @@ -9,7 +9,6 @@ select "data_type": "int64", "range": {"start": 2002, "end": 2022, "interval": 2}, }, - cluster_by=["sigla_uf"], ) }} diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio.sql b/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio.sql new file mode 100644 index 00000000..101619f3 --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio.sql @@ -0,0 +1,42 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'detalhes_votacao_municipio', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1998, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(aptos AS INT64) aptos, +SAFE_CAST(secoes AS INT64) secoes, +SAFE_CAST(secoes_agregadas AS INT64) secoes_agregadas, +SAFE_CAST(aptos_totalizadas AS INT64) aptos_totalizadas, +SAFE_CAST(secoes_totalizadas AS INT64) secoes_totalizadas, +SAFE_CAST(comparecimento AS INT64) comparecimento, +SAFE_CAST(abstencoes AS INT64) abstencoes, +SAFE_CAST(votos_validos AS INT64) votos_validos, +SAFE_CAST(votos_brancos AS INT64) votos_brancos, +SAFE_CAST(votos_nulos AS INT64) votos_nulos, +SAFE_CAST(votos_legenda AS INT64) votos_legenda, +SAFE_CAST(proporcao_comparecimento AS FLOAT64) proporcao_comparecimento, +SAFE_CAST(proporcao_votos_validos AS FLOAT64) proporcao_votos_validos, +SAFE_CAST(proporcao_votos_brancos AS FLOAT64) proporcao_votos_brancos, +SAFE_CAST(proporcao_votos_nulos AS FLOAT64) proporcao_votos_nulos +FROM basedosdados-staging.br_tse_eleicoes_staging.detalhes_votacao_municipio AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio_zona.sql b/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio_zona.sql new file mode 100644 index 00000000..22eb248c --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_municipio_zona.sql @@ -0,0 +1,43 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'detalhes_votacao_municipio_zona', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1998, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(aptos AS INT64) aptos, +SAFE_CAST(secoes AS INT64) secoes, +SAFE_CAST(secoes_agregadas AS INT64) secoes_agregadas, +SAFE_CAST(aptos_totalizadas AS INT64) aptos_totalizadas, +SAFE_CAST(secoes_totalizadas AS INT64) secoes_totalizadas, +SAFE_CAST(comparecimento AS INT64) comparecimento, +SAFE_CAST(abstencoes AS INT64) abstencoes, +SAFE_CAST(votos_validos AS INT64) votos_validos, +SAFE_CAST(votos_brancos AS INT64) votos_brancos, +SAFE_CAST(votos_nulos AS INT64) votos_nulos, +SAFE_CAST(votos_legenda AS INT64) votos_legenda, +SAFE_CAST(proporcao_comparecimento AS FLOAT64) proporcao_comparecimento, +SAFE_CAST(proporcao_votos_validos AS FLOAT64) proporcao_votos_validos, +SAFE_CAST(proporcao_votos_brancos AS FLOAT64) proporcao_votos_brancos, +SAFE_CAST(proporcao_votos_nulos AS FLOAT64) proporcao_votos_nulos +FROM basedosdados-staging.br_tse_eleicoes_staging.detalhes_votacao_municipio_zona AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_secao.sql b/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_secao.sql new file mode 100644 index 00000000..ee71b7a0 --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__detalhes_votacao_secao.sql @@ -0,0 +1,43 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'detalhes_votacao_secao', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1994, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(secao AS STRING) secao, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(aptos AS INT64) aptos, +SAFE_CAST(comparecimento AS INT64) comparecimento, +SAFE_CAST(abstencoes AS INT64) abstencoes, +SAFE_CAST(votos_nominais AS INT64) votos_nominais, +SAFE_CAST(votos_brancos AS INT64) votos_brancos, +SAFE_CAST(votos_nulos AS INT64) votos_nulos, +SAFE_CAST(votos_coligacao AS INT64) votos_coligacao, +SAFE_CAST(votos_nulos_apu_sep AS INT64) votos_nulos_apu_sep, +SAFE_CAST(votos_pendentes AS INT64) votos_pendentes, +SAFE_CAST(proporcao_comparecimento AS FLOAT64) proporcao_comparecimento, +SAFE_CAST(proporcao_votos_nominais AS FLOAT64) proporcao_votos_nominais, +SAFE_CAST(proporcao_votos_coligacao AS FLOAT64) proporcao_votos_coligacao, +SAFE_CAST(proporcao_votos_brancos AS FLOAT64) proporcao_votos_brancos, +SAFE_CAST(proporcao_votos_nulos AS FLOAT64) proporcao_votos_nulos +FROM basedosdados-staging.br_tse_eleicoes_staging.detalhes_votacao_secao AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__partidos.sql b/models/br_tse_eleicoes/br_tse_eleicoes__partidos.sql new file mode 100644 index 00000000..442e904b --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__partidos.sql @@ -0,0 +1,56 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'partidos', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1990, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(numero AS STRING) numero, +SAFE_CAST(sigla AS STRING) sigla, +SAFE_CAST(nome AS STRING) nome, +SAFE_CAST(tipo_agremiacao AS STRING) tipo_agremiacao, +SAFE_CAST(sequencial_coligacao AS STRING) sequencial_coligacao, +SAFE_CAST(nome_coligacao AS STRING) nome_coligacao, +SAFE_CAST(composicao_coligacao AS STRING) composicao_coligacao, +SAFE_CAST(numero_federacao AS STRING) numero_federacao, +SAFE_CAST(nome_federacacao AS STRING) nome_federacacao, +SAFE_CAST(sigla_federacao AS STRING) sigla_federacao, +SAFE_CAST(composicao_federacao AS STRING) composicao_federacao, +SAFE_CAST(situacao_legenda AS STRING) situacao_legenda +FROM basedosdados-staging.br_tse_eleicoes_staging.partidos AS t + + + + + + + + + + + + + + + + + diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_local_votacao.sql b/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_local_votacao.sql new file mode 100644 index 00000000..9b6074b1 --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_local_votacao.sql @@ -0,0 +1,60 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'perfil_eleitorado_local_votacao', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 2016, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(secao AS STRING) secao, +SAFE_CAST(tipo_secao_agregada AS STRING) tipo_secao_agregada , +SAFE_CAST(numero AS STRING) numero, +SAFE_CAST(nome AS STRING) nome, +SAFE_CAST(tipo AS STRING) tipo, +SAFE_CAST(endereco AS STRING) endereco, +SAFE_CAST(bairro AS STRING) bairro, +SAFE_CAST(cep AS STRING) cep, +SAFE_CAST(telefone AS STRING) telefone, +SAFE_CAST(latitude AS FLOAT64) latitude, +SAFE_CAST(longitude AS FLOAT64) longitude, +SAFE_CAST(situacao AS STRING) situacao, +SAFE_CAST(situacao_zona AS STRING) situacao_zona, +SAFE_CAST(situacao_secao AS STRING) situacao_secao, +SAFE_CAST(situacao_localidade AS STRING) situacao_localidade, +SAFE_CAST(situacao_secao_acessibilidade AS STRING) situacao_secao_acessibilidade, +SAFE_CAST(quantidade_eleitores AS INT64) quantidade_eleitores, +SAFE_CAST(quantidade_eleitores_eleicao AS INT64) quantidade_eleitores_eleicao, +FROM basedosdados-staging.br_tse_eleicoes_staging.perfil_eleitorado_local_votacao AS t + + + + + + + + + + + + + + + + diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_municipio_zona.sql b/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_municipio_zona.sql new file mode 100644 index 00000000..1cee8343 --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_municipio_zona.sql @@ -0,0 +1,49 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'perfil_eleitorado_municipio_zona', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1998, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(situacao_biometria AS STRING) situacao_biometria, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(genero AS STRING) genero, +SAFE_CAST(estado_civil AS STRING) estado_civil, +SAFE_CAST(grupo_idade AS STRING) grupo_idade, +SAFE_CAST(instrucao AS STRING) instrucao, +SAFE_CAST(eleitores AS STRING) eleitores, +SAFE_CAST(eleitores_biometria AS STRING) eleitores_biometria, +SAFE_CAST(eleitores_deficiencia AS STRING) eleitores_deficiencia +FROM basedosdados-staging.br_tse_eleicoes_staging.perfil_eleitorado_municipio_zona AS t + + + + + + + + + + + + + + + + diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_secao.sql b/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_secao.sql new file mode 100644 index 00000000..230603b7 --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__perfil_eleitorado_secao.sql @@ -0,0 +1,51 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'perfil_eleitorado_secao', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 2008, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(situacao_biometria AS STRING) situacao_biometria, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(secao AS STRING) secao, +SAFE_CAST(genero AS STRING) genero, +SAFE_CAST(estado_civil AS STRING) estado_civil, +SAFE_CAST(grupo_idade AS STRING) grupo_idade, +SAFE_CAST(instrucao AS STRING) instrucao, +SAFE_CAST(eleitores AS STRING) eleitores, +SAFE_CAST(eleitores_biometria AS STRING) eleitores_biometria, +SAFE_CAST(eleitores_deficiencia AS STRING) eleitores_deficiencia, +SAFE_CAST(eleitores_inclusao_nome_social AS STRING) eleitores_inclusao_nome_social +FROM basedosdados-staging.br_tse_eleicoes_staging.perfil_eleitorado_secao AS t + + + + + + + + + + + + + + + + diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__receitas_candidato.sql b/models/br_tse_eleicoes/br_tse_eleicoes__receitas_candidato.sql index 67ce9926..fdc1cfe9 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__receitas_candidato.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__receitas_candidato.sql @@ -8,7 +8,6 @@ "data_type": "int64", "range": {"start": 2002, "end": 2022, "interval": 2}, }, - cluster_by=["sigla_uf"], ) }} diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__receitas_comite.sql b/models/br_tse_eleicoes/br_tse_eleicoes__receitas_comite.sql index 03987b15..5c1dd5b2 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__receitas_comite.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__receitas_comite.sql @@ -8,7 +8,6 @@ "data_type": "int64", "range": {"start": 2002, "end": 2014, "interval": 2}, }, - cluster_by=["sigla_uf"], ) }} diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__receitas_orgao_partidario.sql b/models/br_tse_eleicoes/br_tse_eleicoes__receitas_orgao_partidario.sql index 79924941..1e68d255 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__receitas_orgao_partidario.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__receitas_orgao_partidario.sql @@ -8,7 +8,6 @@ "data_type": "int64", "range": {"start": 2010, "end": 2022, "interval": 2}, }, - cluster_by=["sigla_uf"], ) }} diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato.sql b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato.sql index a73ffea8..48cb6dcd 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato.sql @@ -8,7 +8,6 @@ "data_type": "int64", "range": {"start": 1945, "end": 2022, "interval": 1}, }, - cluster_by=["sigla_uf"], ) }} diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio.sql b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio.sql new file mode 100644 index 00000000..2b8331f5 --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio.sql @@ -0,0 +1,34 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'resultados_candidato_municipio', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1998, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(numero_partido AS STRING) numero_partido, +SAFE_CAST(sigla_partido AS STRING) sigla_partido, +SAFE_CAST(numero_candidato AS STRING) numero_candidato, +SAFE_CAST(sequencial_candidato AS STRING) sequencial_candidato, +SAFE_CAST(id_candidato_bd AS STRING) id_candidato_bd, +SAFE_CAST(resultado AS STRING) resultado, +SAFE_CAST(votos AS INT64) votos +FROM basedosdados-staging.br_tse_eleicoes_staging.resultados_candidato_municipio AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio_zona.sql b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio_zona.sql new file mode 100644 index 00000000..a70acf5b --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_municipio_zona.sql @@ -0,0 +1,35 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'resultados_candidato_municipio_zona', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1998, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(numero_partido AS STRING) numero_partido, +SAFE_CAST(sigla_partido AS STRING) sigla_partido, +SAFE_CAST(numero_candidato AS STRING) numero_candidato, +SAFE_CAST(sequencial_candidato AS STRING) sequencial_candidato, +SAFE_CAST(id_candidato_bd AS STRING) id_candidato_bd, +SAFE_CAST(resultado AS STRING) resultado, +SAFE_CAST(votos AS INT64) votos +FROM basedosdados-staging.br_tse_eleicoes_staging.resultados_candidato_municipio_zona AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_secao.sql b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_secao.sql index db119fe7..aea7d81e 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_secao.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_candidato_secao.sql @@ -1,31 +1,35 @@ {{ config( - schema="br_tse_eleicoes", - alias="resultados_candidato_secao", - materialized="table", + schema='br_tse_eleicoes', + alias = 'resultados_candidato_secao', + materialized='table', partition_by={ "field": "ano", "data_type": "int64", - "range": {"start": 1994, "end": 2022, "interval": 2}, + "range": { + "start": 1994, + "end": 2022, + "interval": 2 + } }, cluster_by=["sigla_uf"], ) }} -select - safe_cast(ano as int64) ano, - safe_cast(turno as int64) turno, - safe_cast(tipo_eleicao as string) tipo_eleicao, - safe_cast(sigla_uf as string) sigla_uf, - safe_cast(id_municipio as string) id_municipio, - safe_cast(id_municipio_tse as string) id_municipio_tse, - safe_cast(zona as string) zona, - safe_cast(secao as string) secao, - safe_cast(cargo as string) cargo, - safe_cast(numero_partido as string) numero_partido, - safe_cast(sigla_partido as string) sigla_partido, - safe_cast(sequencial_candidato as string) sequencial_candidato, - safe_cast(numero_candidato as string) numero_candidato, - safe_cast(id_candidato_bd as string) id_candidato_bd, - safe_cast(votos as int64) votos -from `basedosdados-staging.br_tse_eleicoes_staging.resultados_candidato_secao` as t +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(secao AS STRING) secao, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(numero_partido AS STRING) numero_partido, +SAFE_CAST(sigla_partido AS STRING) sigla_partido, +SAFE_CAST(sequencial_candidato AS STRING) sequencial_candidato, +SAFE_CAST(numero_candidato AS STRING) numero_candidato, +SAFE_CAST(id_candidato_bd AS STRING) id_candidato_bd, +SAFE_CAST(votos AS INT64) votos +FROM basedosdados-staging.br_tse_eleicoes_staging.resultados_candidato_secao AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio.sql b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio.sql new file mode 100644 index 00000000..30dd06fa --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio.sql @@ -0,0 +1,31 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'resultados_partido_municipio', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1994, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(numero_partido AS STRING) numero_partido, +SAFE_CAST(sigla_partido AS STRING) sigla_partido, +SAFE_CAST(votos_nominais AS INT64) votos_nominais, +SAFE_CAST(votos_nao_nominais AS INT64) votos_nao_nominais +FROM basedosdados-staging.br_tse_eleicoes_staging.resultados_partido_municipio AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio_zona.sql b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio_zona.sql new file mode 100644 index 00000000..1cdf6b5a --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_municipio_zona.sql @@ -0,0 +1,32 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'resultados_partido_municipio_zona', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1994, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(numero_partido AS STRING) numero_partido, +SAFE_CAST(sigla_partido AS STRING) sigla_partido, +SAFE_CAST(votos_nominais AS INT64) votos_nominais, +SAFE_CAST(votos_nao_nominais AS INT64) votos_nao_nominais +FROM basedosdados-staging.br_tse_eleicoes_staging.resultados_partido_municipio_zona AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_secao.sql b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_secao.sql index 55b32d47..8b8840a4 100644 --- a/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_secao.sql +++ b/models/br_tse_eleicoes/br_tse_eleicoes__resultados_partido_secao.sql @@ -1,29 +1,33 @@ {{ config( - schema="br_tse_eleicoes", - alias="resultados_partido_secao", - materialized="table", + schema='br_tse_eleicoes', + alias = 'resultados_partido_secao', + materialized='table', partition_by={ "field": "ano", "data_type": "int64", - "range": {"start": 1994, "end": 2022, "interval": 2}, + "range": { + "start": 1994, + "end": 2022, + "interval": 2 + } }, cluster_by=["sigla_uf"], ) }} -select - safe_cast(ano as int64) ano, - safe_cast(turno as int64) turno, - safe_cast(tipo_eleicao as string) tipo_eleicao, - safe_cast(sigla_uf as string) sigla_uf, - safe_cast(id_municipio as string) id_municipio, - safe_cast(id_municipio_tse as string) id_municipio_tse, - safe_cast(zona as string) zona, - safe_cast(secao as string) secao, - safe_cast(cargo as string) cargo, - safe_cast(numero_partido as string) numero_partido, - safe_cast(sigla_partido as string) sigla_partido, - safe_cast(votos_nominais as int64) votos_nominais, - safe_cast(votos_nao_nominais as int64) votos_nao_nominais -from `basedosdados-staging.br_tse_eleicoes_staging.resultados_partido_secao` as t +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(turno AS INT64) turno, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(zona AS STRING) zona, +SAFE_CAST(secao AS STRING) secao, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(numero_partido AS STRING) numero_partido, +SAFE_CAST(sigla_partido AS STRING) sigla_partido, +SAFE_CAST(votos_nominais AS INT64) votos_nominais, +SAFE_CAST(votos_nao_nominais AS INT64) votos_nao_nominais +FROM basedosdados-staging.br_tse_eleicoes_staging.resultados_partido_secao AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/br_tse_eleicoes__vagas.sql b/models/br_tse_eleicoes/br_tse_eleicoes__vagas.sql new file mode 100644 index 00000000..83a10dda --- /dev/null +++ b/models/br_tse_eleicoes/br_tse_eleicoes__vagas.sql @@ -0,0 +1,27 @@ +{{ + config( + schema='br_tse_eleicoes', + alias = 'vagas', + materialized='table', + partition_by={ + "field": "ano", + "data_type": "int64", + "range": { + "start": 1994, + "end": 2022, + "interval": 2 + } + }, + cluster_by=["sigla_uf"], + ) +}} + +SELECT +SAFE_CAST(ano AS INT64) ano, +SAFE_CAST(tipo_eleicao AS STRING) tipo_eleicao, +SAFE_CAST(sigla_uf AS STRING) sigla_uf, +SAFE_CAST(id_municipio AS STRING) id_municipio, +SAFE_CAST(id_municipio_tse AS STRING) id_municipio_tse, +SAFE_CAST(cargo AS STRING) cargo, +SAFE_CAST(vagas AS INT64) vagas +FROM basedosdados-staging.br_tse_eleicoes_staging.vagas AS t \ No newline at end of file diff --git a/models/br_tse_eleicoes/schema.yml b/models/br_tse_eleicoes/schema.yml index 1ec57056..59f3704f 100644 --- a/models/br_tse_eleicoes/schema.yml +++ b/models/br_tse_eleicoes/schema.yml @@ -2,7 +2,7 @@ version: 2 models: - name: br_tse_eleicoes__candidatos - description: Microdados de candidatos + description: "Candidatos" columns: - name: ano description: Ano @@ -58,20 +58,8 @@ models: description: E-mail - name: raca description: Raça ou cor - - name: situacao_totalizacao - description: Situação Totalização - - name: numero_federacao - description: Número Federação - - name: nome_federacao - description: Nome Federação - - name: sigla_federacao - description: Sigla Federação - - name: composicao_federacao - description: Composição Federação - - name: prestou_contas - description: Indicador de prestação de contas - name: br_tse_eleicoes__bens_candidato - description: Microdados bens candidato + description: "Bens candidato" columns: - name: ano description: Ano @@ -92,7 +80,7 @@ models: - name: valor_item description: Valor do Item (R$) - name: br_tse_eleicoes__receitas_candidato - description: Microdados receitas candidato + description: "Receitas candidato" columns: - name: ano description: Ano @@ -211,7 +199,7 @@ models: - name: entrega_conjunto description: Entrega em conjunto - name: br_tse_eleicoes__despesas_candidato - description: Microdados despesas candidato + description: "Despesas candidato" columns: - name: ano description: Ano @@ -307,7 +295,7 @@ models: - name: cargo_fornecedor description: Cargo do fornecedor - name: br_tse_eleicoes__receitas_comite - description: Receitas de comitês eleitorais + description: "Receitas de comitês eleitorais" columns: - name: ano description: Ano @@ -380,7 +368,7 @@ models: - name: nome_doador_orig_rf description: Nome do doador originário - Receita Federal - name: br_tse_eleicoes__receitas_orgao_partidario - description: Receitas de comitês eleitorais + description: "Receitas de comitês eleitorais" columns: - name: ano description: Ano @@ -487,7 +475,7 @@ models: - name: nome_doador_orig_rf description: Nome do doador originário - Receita Federal - name: br_tse_eleicoes__resultados_candidato - description: Resultados a nível de candidato. + description: "Resultados a nível de candidato" columns: - name: ano description: Ano @@ -520,7 +508,7 @@ models: - name: votos description: Número de votos - name: br_tse_eleicoes__resultados_candidato_secao - description: Resultados a nível de candidato e seção eleitoral. + description: "Resultados a nível de candidato e seção eleitoral" columns: - name: ano description: Ano @@ -553,7 +541,7 @@ models: - name: votos description: Número de votos - name: br_tse_eleicoes__resultados_partido_secao - description: Resultados a nível de partido e seção eleitoral. + description: "Resultados a nível de partido e seção eleitoral" columns: - name: ano description: Ano