diff --git a/models/br_me_caged/microdados_movimentacao.sql b/models/br_me_caged/microdados_movimentacao.sql deleted file mode 100644 index e0d549fc..00000000 --- a/models/br_me_caged/microdados_movimentacao.sql +++ /dev/null @@ -1,58 +0,0 @@ -{{ - config( - schema="br_me_caged", - materialized="table", - partition_by={ - "field": "ano", - "data_type": "int64", - "range": {"start": 2020, "end": 2023, "interval": 1}, - }, - cluster_by=["mes", "sigla_uf"], - labels={"project_id": "basedosdados-dev", "tema": "economia"}, - ) -}} -select - safe_cast(ano as int64) ano, - safe_cast(mes as int64) mes, - safe_cast(a.sigla_uf as string) sigla_uf, - safe_cast(b.id_municipio as string) id_municipio, - safe_cast(cnae_2_secao as string) cnae_2_secao, - safe_cast(cnae_2_subclasse as string) cnae_2_subclasse, - safe_cast(saldo_movimentacao as int64) saldo_movimentacao, - safe_cast(cbo_2002 as string) cbo_2002, - safe_cast(categoria as string) categoria, - safe_cast(grau_instrucao as string) grau_instrucao, - safe_cast(replace(idade, '.0', '') as int64) idade, - safe_cast(replace(horas_contratuais, ',00', '') as int64) horas_contratuais, - safe_cast(raca_cor as string) raca_cor, - safe_cast(sexo as string) sexo, - safe_cast(tipo_empregador as string) tipo_empregador, - safe_cast(tipo_estabelecimento as string) tipo_estabelecimento, - safe_cast(tipo_movimentacao as string) tipo_movimentacao, - safe_cast(tipo_deficiencia as string) tipo_deficiencia, - safe_cast( - indicador_trabalho_intermitente as string - ) indicador_trabalho_intermitente, - safe_cast(indicador_trabalho_parcial as string) indicador_trabalho_parcial, - safe_cast(replace(salario_mensal, ',', '.') as float64) salario_mensal, - safe_cast( - tamanho_estabelecimento_janeiro as string - ) tamanho_estabelecimento_janeiro, - safe_cast(indicador_aprendiz as string) indicador_aprendiz, - safe_cast(origem_informacao as string) origem_informacao, - safe_cast(indicador_fora_prazo as int64) indicador_fora_prazo -from `basedosdados-dev.br_me_caged_staging.microdados_movimentacao` a -left join - `basedosdados.br_bd_diretorios_brasil.municipio` b - on a.id_municipio = b.id_municipio_6 -where - ( - date_diff( - current_date(), date(cast(ano as int64), cast(mes as int64), 1), month - ) - > 6 - or date_diff( - date(2023, 5, 1), date(cast(ano as int64), cast(mes as int64), 1), month - ) - > 0 - ) diff --git a/models/br_me_caged/microdados_movimentacao_excluida.sql b/models/br_me_caged/microdados_movimentacao_excluida.sql deleted file mode 100644 index 78cc84c5..00000000 --- a/models/br_me_caged/microdados_movimentacao_excluida.sql +++ /dev/null @@ -1,59 +0,0 @@ -{{ - config( - schema="br_me_caged", - materialized="table", - partition_by={ - "field": "ano", - "data_type": "int64", - "range": {"start": 2020, "end": 2023, "interval": 1}, - }, - cluster_by=["mes", "sigla_uf"], - labels={"project_id": "basedosdados-dev", "tema": "economia"}, - ) -}} -select - safe_cast(ano as int64) ano, - safe_cast(mes as int64) mes, - safe_cast(a.sigla_uf as string) sigla_uf, - safe_cast(b.id_municipio as string) id_municipio, - safe_cast(cnae_2_secao as string) cnae_2_secao, - safe_cast(cnae_2_subclasse as string) cnae_2_subclasse, - safe_cast(saldo_movimentacao as int64) saldo_movimentacao, - safe_cast(cbo_2002 as string) cbo_2002, - safe_cast(categoria as string) categoria, - safe_cast(grau_instrucao as string) grau_instrucao, - safe_cast(replace(idade, '.0', '') as int64) idade, - safe_cast(replace(horas_contratuais, ',00', '') as int64) horas_contratuais, - safe_cast(raca_cor as string) raca_cor, - safe_cast(sexo as string) sexo, - safe_cast(tipo_empregador as string) tipo_empregador, - safe_cast(tipo_estabelecimento as string) tipo_estabelecimento, - safe_cast(tipo_movimentacao as string) tipo_movimentacao, - safe_cast(tipo_deficiencia as string) tipo_deficiencia, - safe_cast( - indicador_trabalho_intermitente as string - ) indicador_trabalho_intermitente, - safe_cast(indicador_trabalho_parcial as string) indicador_trabalho_parcial, - safe_cast(replace(salario_mensal, ',', '.') as float64) salario_mensal, - safe_cast( - tamanho_estabelecimento_janeiro as string - ) tamanho_estabelecimento_janeiro, - safe_cast(indicador_aprendiz as string) indicador_aprendiz, - safe_cast(origem_informacao as string) origem_informacao, - safe_cast(indicador_exclusao as int64) indicador_exclusao, - safe_cast(indicador_fora_prazo as int64) indicador_fora_prazo -from `basedosdados-dev.br_me_caged_staging.microdados_movimentacao_excluida` a -left join - `basedosdados.br_bd_diretorios_brasil.municipio` b - on a.id_municipio = b.id_municipio_6 -where - ( - date_diff( - current_date(), date(cast(ano as int64), cast(mes as int64), 1), month - ) - > 6 - or date_diff( - date(2023, 5, 1), date(cast(ano as int64), cast(mes as int64), 1), month - ) - > 0 - ) diff --git a/models/br_me_caged/microdados_movimentacao_fora_prazo.sql b/models/br_me_caged/microdados_movimentacao_fora_prazo.sql deleted file mode 100644 index 6e8f4832..00000000 --- a/models/br_me_caged/microdados_movimentacao_fora_prazo.sql +++ /dev/null @@ -1,58 +0,0 @@ -{{ - config( - schema="br_me_caged", - materialized="table", - partition_by={ - "field": "ano", - "data_type": "int64", - "range": {"start": 2020, "end": 2023, "interval": 1}, - }, - cluster_by=["mes", "sigla_uf"], - labels={"project_id": "basedosdados-dev", "tema": "economia"}, - ) -}} -select - safe_cast(ano as int64) ano, - safe_cast(mes as int64) mes, - safe_cast(a.sigla_uf as string) sigla_uf, - safe_cast(b.id_municipio as string) id_municipio, - safe_cast(cnae_2_secao as string) cnae_2_secao, - safe_cast(cnae_2_subclasse as string) cnae_2_subclasse, - safe_cast(saldo_movimentacao as int64) saldo_movimentacao, - safe_cast(cbo_2002 as string) cbo_2002, - safe_cast(categoria as string) categoria, - safe_cast(grau_instrucao as string) grau_instrucao, - safe_cast(replace(idade, '.0', '') as int64) idade, - safe_cast(replace(horas_contratuais, ',00', '') as int64) horas_contratuais, - safe_cast(raca_cor as string) raca_cor, - safe_cast(sexo as string) sexo, - safe_cast(tipo_empregador as string) tipo_empregador, - safe_cast(tipo_estabelecimento as string) tipo_estabelecimento, - safe_cast(tipo_movimentacao as string) tipo_movimentacao, - safe_cast(tipo_deficiencia as string) tipo_deficiencia, - safe_cast( - indicador_trabalho_intermitente as string - ) indicador_trabalho_intermitente, - safe_cast(indicador_trabalho_parcial as string) indicador_trabalho_parcial, - safe_cast(replace(salario_mensal, ',', '.') as float64) salario_mensal, - safe_cast( - tamanho_estabelecimento_janeiro as string - ) tamanho_estabelecimento_janeiro, - safe_cast(indicador_aprendiz as string) indicador_aprendiz, - safe_cast(origem_informacao as string) origem_informacao, - safe_cast(indicador_fora_prazo as int64) indicador_fora_prazo -from `basedosdados-dev.br_me_caged_staging.microdados_movimentacao_fora_prazo` a -left join - `basedosdados.br_bd_diretorios_brasil.municipio` b - on a.id_municipio = b.id_municipio_6 -where - ( - date_diff( - current_date(), date(cast(ano as int64), cast(mes as int64), 1), month - ) - > 6 - or date_diff( - date(2023, 5, 1), date(cast(ano as int64), cast(mes as int64), 1), month - ) - > 0 - ) diff --git a/models/br_me_caged/schema.yml b/models/br_me_caged/schema.yml index 2e737fab..77d16704 100644 --- a/models/br_me_caged/schema.yml +++ b/models/br_me_caged/schema.yml @@ -1,7 +1,7 @@ --- version: 2 models: - - name: microdados_movimentacao + - name: br_me_caged__microdados_movimentacao description: Contém dados de movimentações declaradas dentro do prazo com competência de declaração. columns: @@ -60,7 +60,7 @@ models: description: Origem da Informação - name: indicador_fora_prazo description: Indicador fora do prazo - - name: microdados_movimentacao_fora_prazo + - name: br_me_caged__microdados_movimentacao_fora_prazo description: Contém dados de movimentações declaradas fora do prazo com competência de declaração. columns: @@ -119,7 +119,7 @@ models: description: Origem da Informação - name: indicador_fora_prazo description: Indicador fora do prazo - - name: microdados_movimentacao_excluida + - name: br_me_caged__microdados_movimentacao_excluida description: Contém dados de movimentações excluídas com competência de declaração. columns: - name: ano