Kafka, Flink & Python

Empresa del sector Oil & Gas requiere para su equipo de trabajo "Real-Time Data Engineer (Hands-on Developer / OT-IT)". Título profesional en Ingeniería de Sistemas, Ciencias de la Computación, Ingeniería Electrónica o afines.

El propósito del rol es desarrollar, probar y mantener el código de las canalizaciones (pipelines) de datos en tiempo real que ingieren telemetría desde sistemas industriales (SCADA, historiadores y sensores), asegurando que los datos fluyan continuamente desde la planta hasta los sistemas analíticos mediante transformaciones de baja latencia y sin degradación de rendimiento.

Requisitos del perfil:

Experiencia: Sólida trayectoria en ingeniería de datos y desarrollo de software "hands-on", procesando datos en streaming e integrando sistemas industriales (OT-IT). Experiencia comprobable gestionando formatos típicos de telemetría de campo (Timestamp, Tag/Sensor ID, Value, Quality Flag).

Lenguajes y Bases de Datos: Nivel avanzado en Python (asyncio, FastAPI) y SQL (agregaciones por ventanas, particionamiento de series temporales). Nivel intermedio/avanzado en Java o Scala. Dominio técnico en bases de datos de series temporales (ClickHouse, TimescaleDB o InfluxDB) y optimización de consultas INSERT.

Streaming y Conectividad SCADA: Uso intensivo de Apache Kafka (APIs, conectores) y motores como Flink o Spark Streaming. Experiencia conectando servidores SCADA e historiadores (Ignition, PI Web API) mediante OPC UA, Modbus y MQTT. Implementación de serialización (Avro/Protobuf) y Schema Registry.

Competencias: Perfil 100% ejecutor orientado al código limpio. Capacidad analítica para depurar problemas de rendimiento (cuellos de botella, lag, backpressure). Dominio de entornos Linux, Docker, Git y flujos CI/CD.

Funciones principales:
Escribir aplicaciones de procesamiento en streaming para transformar y enriquecer datos industriales continuos; construir servicios livianos para conectarse a servidores SCADA y gateways IoT; desarrollar la lógica de inserción masiva por micro-lotes hacia bases de datos y datalakes; resolver problemas diarios de rendimiento en producción; y ejecutar pruebas unitarias para validar lógicas de agregación y el manejo de datos que llegan fuera de orden (watermarking).

Modalidad: Remoto
Contrato: Indefinido