Connecting Waterpeople

Se encuentra usted aquí

TIRESIAS

Plataforma Big Data para el procesamiento masivo de datos de telelectura con el objeto de detectar Fugas e identificar Fraudes en Tiempo Real.

Tiresias, la Plataforma Big Data para el procesamiento masivo de datos de telelectura

Qué es Tiresias

Tiresias es una plataforma Big Data para el procesamiento masivo de datos de telelectura con el objeto de detectar Fugas e identificar situaciones de Fraude en Tiempo Real.

La plataforma está compuesta por diferentes sistemas especializados en la ingesta masiva de datos desde dispositivos IoT y en el procesamiento distribuido de los mismos en Tiempo Real. El sistema incluye un catálogo de algoritmos especializados en la detección de Fugas, Fraudes y Alarmas de Telelectura.

La plataforma está diseñada para simplificar el desarrollo de soluciones IoT para que pueda aprovechar todo el potencial del Internet de las Cosas.

Arquitectura del sistema

Su arquitectura basada en sistemas de procesamiento de datos distribuidos en streaming (Apache Spark y Apache Kafka) le permite procesar grandes volúmenes de datos en tiempo real y con gran variabilidad en la información, al persistirla en bases de datos NoSQL distribuidas (Cassandra y HDFS).

  • Stream Analytics: Capacidad de procesamiento del flujo de datos en tiempo real procedente de cientos de miles de dispositivos IoT.
  • Escalabilidad lineal: Almacenamiento de grandes volúmenes de datos en forma distribuida. El rendimiento del sistema está asegurado al aumentar linealmente a medida que se añaden nuevos nodos al clúster.
  • Microservicios: Los microservicios permiten encapsular funcionalidades empresariales más simples, las cuales se pueden escalar, probar, implementar y administrar de forma independiente.

Tiresias se ha construido a partir de un sistema operativo distribuido basado en DC/OS (datacenter operating system).

DC/OS permite administrar múltiples máquinas tanto en la nube como en local desde una sola interfaz web. Permite el despliegue de contenedores, servicios distribuidos y aplicaciones heredadas en esas máquinas, y proporciona mecanismos de gestión de redes, detección de servicios y administración de recursos para mantener los servicios en funcionamiento de forma óptima y escalable.

Ventajas de Tiresias

  • Tiempo real: Plataforma unificada de alto rendimiento y de baja latencia para la manipulación en tiempo real de diferentes fuentes de datos.
  • Capacidad Big Data: El sistema ha sido diseñado para procesar grandes volúmenes de datos en tiempo real y con gran variabilidad en la información.
  • Cloud / On-Premise: La plataforma puede ser desplegada tanto en Infraestructura en la Nube como On-Premise.
  • Experiencia: El sistema nace de la experiencia acumulada en los últimos 12 años procesando las telecturas de más de 650.000 contadores.
  • Multi-fabricante: El sistema nace de la experiencia acumulada en los últimos 12 años procesando las telecturas de más de 650.000 contadores.
  • Flexibilidad: Solución Abierta y Adaptable a cada municipio y tecnología.

Sectores de aplicación

Tiresias integra conectores de los principales fabricantes de Telelectura del mercado.

Cómo funciona

La información procedente de los diferentes canales de comunicación es preprocesada por el módulo de ingesta de datos que realiza la estandarización de los mensajes recibidos que son publicados en el bróker de mensajería (Apache Kafka) en función de las características del origen del dato (IoT, Red Fija, …).

Los mensajes publicados en el bróker son consumidos por procesos Spark Streaming que se encargan de realizar transformaciones sobre los datos (normalización de los mensajes) en tiempo real.

Finalmente, los mensajes son persistidos en una base de datos NoSQL distribuida, al mismo tiempo que son publicados en nuevos tópicos Kafka para la ejecución de cálculos analíticos en tiempo real sobre los datos (algoritmos de telelectura).

Se enumeran a continuación los principales algoritmos incluidos en Tiresias:

  • Fugas:
    • Detección de Fugas Extremas
    • Detección de Fugas Regulares
  • Fraude:
    • Detección de Consumo en Pisos Vacíos
    • Detección de Consumo sin Contrato
    • Detección de Consumo con Disco Ciego instalado
  • Contadores:
    • Detección de Contadores Parados
    • Detección de Contadores al Revés
  • Alarmas:
    • Alarmas de Batería Baja
    • Alarmas de Avería
    • Alarmas de Sub-gasto y Sobre-gasto
    • Alarmas de Manipulación

Dimensionamiento del sistema

Global Omnium

Global Omnium
Empresa especializada en la gestión integral del agua. Actualmente da cobertura a 5,5 millones de personas en más de 300 ciudades españolas, además de tener presencia en otros países extranjeros.

Solicita información a Global Omnium