Pipeline Macro (BCB/SGS → Postgres → BI)

Ingestão e modelagem de séries econômicas do Banco Central (SGS) usando Docker, n8n e PostgreSQL nas camadas bronze → silver → gold, com orquestração diária e eventos simples.

🔎 Visão Geral

• Fontes: API pública do BCB/SGS (séries 1, 11, 432, 433 por padrão)
• Orquestração: n8n (Workflows W1–W4 + Orquestrador)
• Persistência: Postgres (camadas bronze/silver/gold + catálogos e logs)
• Dashboards: Power BI conectado direto no Postgres (sem CSV)
• Eventos: spikes em USD/BRL e mudança de meta Selic gravados no banco

🧱 Arquitetura

        +-----------------+
        |   Orchestrator  |  (Cron 07:30 BRT)
        +--------+--------+
                 |
                 v
+-------- W1: Ingest (Code) --------+
| Get series -> Build windows ->    |
| Fetch SGS -> Upsert Bronze        |
+-------------------+---------------+
                    v
         +----------+-----------+
         | W2: Bronze  -> Silver|
         +----------+-----------+
                    v
         +----------+-----------+
         | W3: Silver -> Gold   |
         +----------+-----------+
                    v
         +----------+-----------+
         | W4: Alertas (DB)     |
         +----------------------+

Imagens (prints) e anotações dos workflows n8n e do dashboard.

Conteúdo

• n8n/: prints dos workflows W1–W4 e do Orquestrador
• dashboard/: prints do Power BI

n8n — Workflows

W1 — Ingest (SGS → Bronze)

W2 — Bronze → Silver

W3 — Silver → Gold

W4 — Alertas (DB)

Orquestrador