diff --git a/README.md b/README.md index 2c53512..8ab24d8 100644 --- a/README.md +++ b/README.md @@ -7,8 +7,8 @@ A high-performance, scalable OPC UA data ingestion system designed for industria ### Core Functionality - **OPC UA Integration**: Native support for OPC UA servers with secure and unsecured connections - **Automatic Load Balancing**: Slot-based architecture for horizontal scaling across multiple instances -- **Real-time Data Streaming**: Kafka integration for high-throughput data distribution -- **Persistent Storage**: MongoDB integration for historical data retention and analysis +- **Real-time Data Streaming**: Kafka integration for historical data streaming +- **Persistent Storage**: MongoDB integration for historical data streaming - **Health Monitoring**: Comprehensive Prometheus metrics and health checks - **Fault Tolerance**: Automatic failover, reconnection, and error recovery @@ -47,7 +47,7 @@ The OPC Ingestor uses a modular, manager-based architecture: - **Ingestor**: Main application orchestrator managing the overall lifecycle - **IngestorManager**: Coordinates slot allocation, OPC server management, and load balancing - **OPC Manager**: Handles individual OPC UA server connections and tag subscriptions -- **Data Manager**: Manages data persistence (MongoDB) and streaming (Kafka) +- **Data Manager**: Manages data streaming (MongoDB | Kafka) - **Resource Manager**: Coordinates resource allocation and instance coordination via Redis ## 📋 Prerequisites @@ -253,14 +253,24 @@ OPC servers are configured through Redis with the following structure: "slot:opc_tags:1": { "server1": { "name": "server1", + "server_id": "1", "url": "opc.tcp://localhost:4841", "server_uri": "http://opcua-server.simulator", "tags": { "ns=2;i=2": { - "tag_name": "Counter", - "frequency": 1000, - "topics": ["opcua", "counter"] - } + "aggr_func": "avg", + "data_range": [ + -100, + 100 + ], + "frequency": "15000", + "server_id": "1", + "tag_address": "ns=2;i=2", + "tag_name": "Counter", + "topics": [ + "raw_scouter-opcua-orchestrated-pipeline", + "raw_scouter-basic-sum-model" + ] } } }