// OMNIX INGEST — captura, normaliza, anonimiza, vectoriza const IngestHero = () => (

← Arquitectura / Motor 01 · INGEST

OMNIX Ingest.

Captura, normaliza, anonimiza y vectoriza. En origen.

OMNIX Ingest conecta fuentes autorizadas de la organización —sistemas, documentos, eventos, sensores y registros operacionales— para preparar información consistente, trazable y lista para ser utilizada por los modelos especializados de OMNIX.

); // Diagrama: 5 fuentes → funnel de normalización → vectores hacia Core const IngestDiagram = () => { const sources = [ { n: 'SAP', y: 80, color: '#96A3B5' }, { n: 'CRM', y: 130, color: '#96A3B5' }, { n: 'SCADA', y: 180, color: '#0050BD' }, { n: 'WMS', y: 230, color: '#96A3B5' }, { n: 'LOGS', y: 280, color: '#96A3B5' }, ]; return (

INGEST · LIVE PIPELINE STREAMING

{/* Live counters */}

); }; const IngestLiveCounters = () => { const [events, setEvents] = React.useState(1_284_402); const [dropped, setDropped] = React.useState(0); React.useEffect(() => { const id = setInterval(() => { setEvents((e) => e + Math.floor(Math.random() * 24 + 4)); if (Math.random() < 0.08) setDropped((d) => d + 1); }, 800); return () => clearInterval(id); }, []); return (

EVENTS · 24H

LATENCY P95

72 ms

DROPPED

0 ? '#B8860B' : '#0F5132', fontSize: 14 }}>{dropped}

); }; const IngestCapabilities = () => { const caps = [ { i: 'plug', t: 'Conectores enterprise nativos', d: 'SAP, Oracle, Salesforce, ServiceNow, Databricks, Snowflake, SCADA/OPC-UA, WMS/TMS, POS. Certificados, mantenidos, sin código boilerplate por parte del cliente.' }, { i: 'shuffle', t: 'Streaming + batch simultáneos', d: 'Un mismo motor procesa telemetría en tiempo real y cargas históricas. Backfill sin afectar el pipeline en vivo. Consistencia exactly-once por evento.' }, { i: 'eye-off', t: 'PII / PHI anonimizado en origen', d: 'Enmascaramiento configurable por campo. Los datos sensibles nunca abandonan el sistema fuente en claro. Cumplimiento GDPR, LGPD, HIPAA nativo.' }, { i: 'file-check-2', t: 'Vectorización multi-modal', d: 'Estructurado, texto, series temporales, voz, imagen. Embeddings propietarios entrenados sobre tu dominio — no genéricos de OpenAI o Cohere.' }, ]; return (

Todo lo que entra al pipeline sale ya listo para razonar.

{caps.map((c, i) => (

e.currentTarget.style.borderColor = '#0050BD'} onMouseLeave={(e) => e.currentTarget.style.borderColor = '#E4EBF3'}>

{c.t}

{c.d}

))}

); }; const IngestStages = () => { const stages = [ { n: '01', k: 'CAPTURE', t: 'Conectar', d: 'Adapters bidireccionales por sistema fuente. Sin agentes intrusivos, sin ETL a medida.' }, { n: '02', k: 'NORMALIZE', t: 'Homogeneizar', d: 'Cada evento pasa a un esquema canónico OMNIX. Timezones, unidades, IDs — todo consistente.' }, { n: '03', k: 'ANONYMIZE', t: 'Proteger', d: 'PII/PHI enmascarado en origen. Tokenización reversible sólo dentro del perímetro cliente.' }, { n: '04', k: 'CONTEXTUALIZE', t: 'Enriquecer', d: 'Cross-join con catálogos de negocio: clientes, productos, sitios, contratos, jerarquías.' }, { n: '05', k: 'VECTORIZE', t: 'Preparar', d: 'Embeddings multi-modales listos para consumo por Core y por Runtime.' }, ]; return (

De evento crudo a vector auditable — en menos de un segundo.
{/* Timeline horizontal con conectores */}

{stages.map((s, i) => (

{s.n}

{s.k}

{s.t}

{s.d}

))}

); }; const IngestSpecs = () => (

Lo que le mostrarías a tu arquitecto.

Los números que un CTO pide antes de firmar. Ninguno es marketing — todos son operativos hoy.

{[ { l: 'Latencia P95 · streaming', v: '< 100 ms' }, { l: 'Throughput sostenido', v: '250K eps' }, { l: 'Formatos soportados', v: '40+' }, { l: 'Adapters certificados', v: '65+' }, { l: 'Delivery guarantee', v: 'exactly-once' }, { l: 'Uptime SLA', v: '99.98%' }, { l: 'Encriptación', v: 'AES-256 · TLS 1.3' }, { l: 'Compliance', v: 'GDPR · LGPD · HIPAA' }, ].map((r, i) => (

{r.l}

{r.v}

))}

); Object.assign(window, { IngestHero, IngestDiagram, IngestCapabilities, IngestStages, IngestSpecs });