Data Engineer

Codvo Private Limited; Pune District; On-site; INR 800,000 - 1,200,000; Full time

Job summary

A technology and engineering firm located in Pune, Maharashtra is seeking a Data Engineer to manage data pipelines from ingestion to analytics. The ideal candidate should have over 5 years of experience in data engineering, proficiency in Python, and familiarity with ETL/ELT pipelines and time-series databases. Responsibilities include ensuring data reliability and building robust monitoring systems for data quality. This role offers an opportunity to contribute to innovative AI solutions.

Qualifications

• 5+ years in data engineering with ETL/ELT pipelines.
• Strong experience with time-series databases.
• Familiar with industrial data protocols such as OPC-UA and BACnet.

Responsibilities

• Owns data pipeline from BMS ingestion to analytics layer.
• Build and maintain the BMS protocol bridge.
• Design and maintain TimescaleDB schema.

Skills

Python

PostgreSQL

TimescaleDB

MQTT

ETL/ELT pipelines

Streaming data

Docker

Kubernetes

Job description

# Data EngineerPune, MaharashtraWork Type:Full TimeCodvo.ai is a next-gen AI and engineering company helping global enterprises transform through Generative AI, Cloud-native platforms, and Product Engineering. With proprietary platforms like NeIO and Pulse, we’re enabling faster, smarter, and scalable digital transformation for industries including Energy, Retail, Travel, BFSI, and Healthcare.As we gear up to launch new AI-powered products and expand global presence, we are seeking a marketing leader to define how Codvo.ai influences the market, shapes perception, and creates a movement.Role SummaryOwns the data pipeline from BMS ingestion through to the analytics layer. Responsible fordata reliability, quality, and the real-time streaming infrastructure that feeds the ML models.ResponsibilitiesData Ingestion & StreamingBuild and maintain the BMS protocol bridge — OPC-UA, BACnet, and MQTT connectorsImplement the MQTT ingestion pipeline — topic subscription, message parsing, schemavalidation, TimescaleDB insertionMonitor ingestion health — message rates, latency, dropped messages, reconnectionlogicImplement the tag auto-mapping engine — pattern-based matching, confidence scoring,manual override workflowBuild the historian adapter — bulk data extraction from customer historian systems(AVEVA Historian, OSIsoft PI, InfluxDB) for baseline profilingData Storage & ManagementDesign and maintain the TimescaleDB schema — hypertables, continuous aggregates,retention policies, compressionImplement data partitioning strategy — per-tenant, per-site isolationBuild the training data snapshot pipeline — versioned dataset extraction with SHA-256checksums and manifest trackingManage the MinIO/S3 data lake — dataset storage, MLflow artifact storage, backupstrategyImplement data retention and archival policies per customer requirementsData Quality & MonitoringBuild the data quality monitoring pipeline — null rate tracking, stale timestampdetection, out-of-range value flagging, schema violation alertingImplement the tag freshness monitor — detect when sensors stop reporting, alert onstale dataBuild the data lineage tracking system — from raw BMS reading through featurecomputation through model predictionMonitor database performance — query latency, storage growth, index health,connection pool utilizationIntegrationBuild and maintain the CMMS integration — ServiceNow / Maximo API connectors, workorder creation, status syncImplement the feedback ingestion worker — poll CMMS for work order outcomes,match to predictions, update ground truth labelsBuild the Prometheus/Grafana metrics export pipeline — platform health metrics, dataquality dashboardsExpected Background5+ years in data engineering — ETL/ELT pipelines, streaming data, time-series databasesStrong Python skills, experience with PostgreSQL/TimescaleDB, MQTT, and messagebroker systemsExperience with Docker, Kubernetes, and CI/CD pipelinesFamiliarity with OPC-UA, BACnet, or industrial data protocols is a strong advantageExperience with data quality frameworks and monitoring**Note- Please apply via our official careers portal only, as applications sent directly to executives may not be considered.**