📐 Arquitectura — Caso 08: 🟣 C# (.NET) → 🌉 n8n → 🌶️ Flask#
Emisor corporativo de alto rendimiento en C# / .NET 8.0 que despacha vía HttpClient hacia un receptor liviano en Flask/Jinja2, orquestado por n8n con guardrails de resiliencia (idempotencia, circuit breaker, DLQ) y persistencia transaccional en SQL Server.
🧭 Ficha técnica#
| Atributo | Valor |
|---|---|
| ID | 08 |
| Origen | C# / .NET 8.0 — origin/Program.cs |
| Puente | n8n — case-08-csharp-to-flask.json |
| Destino | Flask (Python) sobre Jinja2 — dest/app.py |
| Persistencia | SQL Server 2022 |
| Puerto (dashboard) | http://localhost:8088 |
| Perfil Docker | case08 |
| Guardrails | Idempotencia · Circuit Breaker · Dead Letter Queue |
🗺️ Diagrama de arquitectura#
diagrama mermaid
%%{init: {'theme':'base','themeVariables':{'fontSize':'26px','fontFamily':'Segoe UI, Arial, sans-serif'},'flowchart':{'useMaxWidth':true,'htmlLabels':false,'nodeSpacing':55,'rankSpacing':70,'padding':16,'diagramPadding':16}}}%%
flowchart TB
subgraph ORIGIN["ORIGEN - C# / .NET"]
B["Program.cs"]
end
subgraph BRIDGE["PUENTE - n8n + Guardrails"]
C(["Webhook"]) --> IDEM{"Idempotencia (fingerprint)"}
IDEM -->|duplicado| DISCARD["200 OK - descarta"]
IDEM -->|nuevo| CBK{"Circuit Breaker"}
CBK -->|cerrado| FWD["HTTP forward"]
CBK -->|abierto| DLQ["Dead Letter Queue"]
end
subgraph DEST["DESTINO - Flask"]
FWD --> H["app.py"]
H --> DB[("SQL Server 2022")]
DB --> DASH["Dashboard :8088"]
end
B -->|POST JSON| C
FWD -.->|error| DLQ
classDef origin fill:#512BD4,stroke:#333,color:#fff
classDef bridge fill:#EA4B71,stroke:#333,color:#fff
classDef dest fill:#000000,stroke:#333,color:#fff
classDef db fill:#CC2927,stroke:#333,color:#fff
class B origin
class C,IDEM,CBK,FWD,DLQ,DISCARD bridge
class H,DASH dest
class DB db🔁 Diagrama de secuencia (ciclo de una publicación)#
diagrama mermaid
%%{init: {'theme':'base','themeVariables':{'fontSize':'24px','fontFamily':'Segoe UI, Arial, sans-serif'},'sequence':{'useMaxWidth':true,'actorFontSize':22,'messageFontSize':20,'noteFontSize':18,'actorMargin':90,'boxMargin':16,'width':180}}}%%
sequenceDiagram
autonumber
participant Bot as Program.cs (C# / .NET)
participant N8N as n8n
participant Dest as app.py (Flask)
participant DB as SQL Server 2022
Bot->>Bot: Prepara y valida el payload
Bot->>N8N: POST /webhook (JSON del post)
N8N->>N8N: Idempotencia (fingerprint)
alt Duplicado
N8N-->>Bot: 200 OK (descartado)
else Nuevo
N8N->>N8N: Circuit Breaker (estado)
alt Breaker cerrado
N8N->>Dest: HTTP forward del payload
Dest->>DB: INSERT post
DB-->>Dest: OK
Dest-->>N8N: 200 + registro
N8N-->>Bot: 200 OK
else Breaker abierto / error
N8N->>N8N: Enruta a Dead Letter Queue
N8N-->>Bot: 5xx (reintento posterior)
end
end🧩 Componentes#
🟣 Origen — .NET Enterprise Dispatcher#
Program.csdefine objetos anónimos tipados, los serializa con System.Text.Json y los despacha vía HttpClient hacia el webhook de n8n.- Uso de inyección de dependencias y clientes HTTP optimizados para rendimiento masivo del ecosistema corporativo de Microsoft .NET.
🌉 Puente — n8n#
- Recibe el webhook, aplica idempotencia (descarta duplicados por fingerprint), pasa por el Circuit Breaker con política de reintentos (3 intentos, intervalo 1s) y reenvía al destino. Los fallos se enrutan a la Dead Letter Queue para auditoría y recuperación.
🌶️ Destino — Flask / Python#
app.pyrecibe el payload con Flask, lo procesa de forma asíncrona y lo persiste en SQL Server 2022, garantizando la integridad relacional transaccional. El motor de plantillas Jinja2 lo sirve en un dashboard web (:8088).
▶️ Cómo levantarlo#
bash
docker-compose --profile case08 up -d # levanta receptor Flask + SQL Server + n8n
python hub.py ejecutar 08-csharp-to-flask # dispara el emisor C# / .NETDashboard: http://localhost:8088
🔗 Enlaces#
- 📄 README del caso
- 🗺️ Arquitectura global del laboratorio
- 🛡️ Guardrails de resiliencia
- 🧩 Índice de casos
Diagramas en Mermaid — se renderizan nativamente en GitHub. Parte de Social Bot Scheduler.