CAGED — Cadastro Geral de Empregados e Desempregados

ftp://ftp.mtps.gov.br/pdet/microdados/NOVO CAGED/

NOVO CAGED/
├── AAAAMM/
│   ├── CAGEDMOV_AAAAMM.txt     # Movimentações declaradas no mês
│   ├── CAGEDFOR_AAAAMM.txt     # Movimentações fora do prazo
│   └── CAGEDEXC_AAAAMM.txt     # Exclusões

import basedosdados as bd
 
# Saldo de empregos por UF no último mês disponível
query = """
SELECT
    sigla_uf,
    SUM(CASE WHEN saldo_movimentacao = 1 THEN 1 ELSE 0 END) AS admissoes,
    SUM(CASE WHEN saldo_movimentacao = -1 THEN 1 ELSE 0 END) AS desligamentos,
    SUM(saldo_movimentacao) AS saldo
FROM `basedosdados.br_me_caged.microdados_movimentacao`
WHERE ano = 2024 AND mes = 12
GROUP BY sigla_uf
ORDER BY saldo DESC
"""
 
df = bd.read_sql(query, billing_project_id="seu-projeto-gcp")
print(df)

import pandas as pd
 
# Ler microdados do Novo CAGED
arquivo = "CAGEDMOV202412.txt"
 
df = pd.read_csv(
    arquivo,
    sep=";",
    encoding="latin-1",
    dtype=str,
    decimal=","
)
 
print(f"Total de movimentações: {len(df):,}")
print(f"Colunas: {list(df.columns)}")
 
# Saldo de empregos por setor (seção CNAE)
df["saldomovimentação"] = pd.to_numeric(df["saldomovimentação"], errors="coerce")
 
saldo_setor = (
    df.groupby("secção")["saldomovimentação"]
    .sum()
    .sort_values(ascending=False)
)
 
print("\nSaldo de empregos por seção CNAE:")
print(saldo_setor)

import pandas as pd
import glob
 
# Ler todos os meses de um ano
arquivos = sorted(glob.glob("CAGEDMOV2024*.txt"))
dfs = []
 
for arq in arquivos:
    df = pd.read_csv(arq, sep=";", encoding="latin-1", dtype=str, decimal=",")
    df["saldomovimentação"] = pd.to_numeric(df["saldomovimentação"], errors="coerce")
    mes = arq[-6:-4]
    saldo = df["saldomovimentação"].sum()
    dfs.append({"mes": mes, "saldo": saldo})
 
serie = pd.DataFrame(dfs)
print("Saldo mensal de empregos formais (2024):")
print(serie.to_string(index=False))