Smart Water Operation and Management with EMQX MQTT Platform

Overview

Smart water operation involves optimizing and intelligently managing water supply and drainage using advanced technology and data analysis methods.

The EMQX MQTT Platform enables water enterprises to build a smart water operation platform quickly by sharing and integrating data and leveraging cloud computing and big data technologies for data analysis and decision-making. In previous cases of smart water management platforms at the city-level, EMQX has successfully helped water enterprises improve platform construction efficiency by over 30%, reduce IoT data acquisition costs by more than 35%, and decrease operational costs by over 40%.

Challenges of Building a Smart Water Operation Platform

Non-Standard Construction of Plant Stations

There is a lack of real-time centralized supervision for water utility plant station data. The self-control systems at various plant stations do not comply with uniform construction standards, and the network deployment lacks planning. This hinders the aggregation of data and the application of big data analytics, making it difficult for data mining efforts.

Severe System Barriers

Remote water meters lack standardized data transmission, leading to repeated meter reading platforms and data barriers, hindering unified management.

Data Quality Constraints for Big Data Platforms

There is a lack of standardization in accessing data related to plant stations, meter readings, and other business data, which has resulted in inconsistent data quality. Various types of data scattered across different systems make it difficult to provide real-time and format-compliant data sources for the big data center.

The Unified MQTT Platform for City-Level Smart Water Operation

Comprehensive Perception of Water IoT Devices

The edge industrial protocol gateway, NeuronEX, supports various PLC drivers such as Modbus, OPC UA, IEC 104, Siemens S7, etc. It can be flexibly deployed in water supply pump stations, pipeline networks, water plants, and user terminals of water systems to achieve real-time monitoring and control of water sources, quality, quantity, pressure, pumps, etc., through sensors, smart water meters, and other intelligent devices.

NeuronEX can perform real-time data processing and analysis on edge devices close to the data source, implementing message standardization, abnormal event monitoring, logic feedback, device linkage, etc., at the edge. This reduces data transmission delays, rapidly responds to data changes, and enhances system robustness.

Unified IoT Message Bus for Tens of Millions of Data

EMQX possesses the capabilities of a high-availability cluster, encrypted authentication, rule engine, data integration, and other enterprise-level message bus features. It provides a unified, secure, and efficiently integrated IoT platform for water management, helping manage the messages generated by hundreds of thousands or even millions of smart water devices every second in a city. This platform can integrate cloud computing, big data, and AI to achieve intelligent water operations, covering water resource management, supply, sewage treatment, quality monitoring, consumption, and more.

Massive Streaming Data Processing

On the platform side, HStream Platform provides massive data distributed storage and streaming processing capabilities, interfaces with big data platforms and time-series databases, and enables real-time data shuffling and pre-processing. It offers robust support for precision management and rapid business decision-making in smart water management platforms.

Cloud-Edge Collaborative Management

EMQX provides a unified cloud-edge module with a web-based control interface, enabling remote configuration, real-time monitoring, and log analysis of the edge software NeuronEX. This reduces the cost of on-site operations and maintenance.

The Advantages of EMQX MQTT Platform

Robust Foundation for IoT Construction

EMQX provides comprehensive capabilities in water utility intelligent terminal data acquisition and control, edge computing, high-concurrency message bus, big data integration, AI algorithm integration, and data security authentication. This forms the basis for developing IoT data capabilities for intelligent operational analytics.

Enhancing Operational Performance

EMQX's rule engine stores low-latency messages persistently in the database at a speed of over one hundred thousand per second, with the capability of providing a million messages per second concurrency. This provides high real-time, high-frequency, and high-precision data necessary for intelligent algorithms, improving the accuracy of data analysis and decision-making.

Reducing Costs

NeuronEX can be deployed on edge gateways, industrial control computers, MEC, and servers, making full use of existing hardware resources based on network conditions to choose the optimal and cost-effective deployment method. It can assist producers in remotely managing various aspects of edge module access, inspections, configurations, upgrades, updates, and alarm handling, significantly enhancing the level of intelligent management.

Continuous Adaptation to Future Development

EMQX utilizes a clustered deployment that allows for horizontal scaling by adding nodes, making it easy to expand the system. Its interfaces are flexible and easily expandable, enabling the future integration of new technologies and systems. At the edge, it can integrate with Go, Python extensions, and AI algorithms, promoting innovative development in edge intelligence.

Related Products

EMQX Enterprise

EMQX Enterprise is a powerful enterprise MQTT platform designed for large-scale deployments and high reliability in IoT applications. The following capabilities of EMQX Enterprise can benefit the industry:

• High Reliability and Scalability: EMQX Enterprise adopts a distributed architecture with high availability and scalability to handle large-scale concurrent message transmission. It supports horizontal scaling to accommodate the growing number of IoT devices and data traffic, ensuring system stability.
• Rich Protocol Support: EMQX Enterprise supports multiple messaging protocols besides the MQTT protocol. It allows developers to extend to support all kinds of private protocols for their application needs.
• Data Integration: EMQX Enterprise seamlessly integrates with various data storage services, message queues, cloud platforms, and applications. It can connect with cloud services, enabling remote data transmission and cloud-based analysis.
• Security and Authentication: EMQX Enterprise provides robust security features, including TLS/SSL encrypted transmission, client authentication, and access control. It supports various authentication methods such as username/password, X.509 certificates, and OAuth, ensuring the security of IoT communication.
• Rule Engine and Data Processing: EMQX Enterprise has a flexible rule engine for real-time data processing and forwarding based on device data. It supports operations such as data filtering, transformation, aggregation, and persistence, helping users analyze and make decisions based on their business needs.
• Visual Monitoring and Management: EMQX Enterprise provides an intuitive visual monitoring and management interface, allowing users to monitor IoT devices and message transmission in real-time. Users can view connection status, message traffic, and other metrics and perform device management, troubleshooting, and system configuration operations.

NeuronEX

NeuronEX is software tailored for the industrial sector, focusing on equipment data collection and edge intelligent analysis. It is primarily deployed in industrial settings, facilitating industrial equipment communication, industrial bus protocol acquisition, industrial system data integration, edge-level data filtering and analysis, AI algorithm integration, and integration with IIoT platforms. It offers the following features:

• Diverse Connectivity: NeuronEX provides multi-protocol access capability, supporting simultaneous access to dozens of industrial protocols such as Modbus, OPC UA, Ethernet/IP, BACnet, Siemens, Mitsubishi, and more. It enables integration with multiple data sources from systems like MES and WMS within the enterprise. NeuronEX also supports bidirectional data flow, allowing both data acquisition and control command issuance to devices.
• Deploy Anywhere: NeuronEX has very low memory footprints and is suitable for running on low-profile architecture devices like x86, ARM, RISC-V, etc. It also supports docker-like containerized deployment, running with other co-located containers in Kubernetes environments.
• Data Processing: NeuronEX incorporates 100+ built-in functions, supporting data filtering, data manipulation, device control, and data persistence, storing data in a time-series database.
• Algorithm Integration: NeuronEX supports the integration of algorithms written in languages such as C, Python, and Go. It facilitates real-time inference of industrial mechanism models, machine learning, and deep learning models at the edge, enabling alerts and intelligent decision-making.
• Edge to Cloud: Through protocols like MQTT and SparkplugB, NeuronEX aggregates and pushes industrial data to cloud platforms. The bidirectional data flow between NeuronEX and the cloud platform establishes cloud-edge data coordination and control synergy, leveraging the platform's big data storage and analysis capabilities to amplify the value of NeuronEX usage.