This tutorial demonstrates how to use machine learning for real-time anomaly detection on sensor data using FrameworX Script Classes.
Edge AI with ML.NET (Tutorial) teaches you to create an MCP (Model Context Protocol) Tool that exposes production KPIs and historical data to AI models, enabling intelligent analysis of your industrial processes.
Prerequisites:
Table of Contents maxLevel 2 minLevel 2 indent 10px exclude Steps style none
ProductionData
Tag.ProductionRate
Tag.Efficiency
Tag.QualityScore
Tag.DowntimeMinutes
KPICalculator
csharp
public double CalculateOEE(double availability, double performance, double quality)
{
return availability * performance * quality * 100;
}
public double GetAverageProduction(DateTime startTime, DateTime endTime)
{
// Calculate average production rate over period
double totalProduction = @Tag.TotalUnits;
double hours = (endTime - startTime).TotalHours;
return hours > 0 ? totalProduction / hours : 0;
}
public string GetProductionStatus()
{
if (@Tag.ProductionRate > 100)
return "High Performance";
else if (@Tag.ProductionRate > 80)
return "Normal";
else
return "Below Target";
}
ProductionMCPTool
csharp
[MCPMethod(Description = "Get current production KPIs")]
public object GetCurrentKPIs()
{
return new {
ProductionRate = @Tag.ProductionRate,
Efficiency = @Tag.Efficiency,
OEE = @Script.Class.KPICalculator.CalculateOEE(
@Tag.Availability, @Tag.Performance, @Tag.Quality),
Status = @Script.Class.KPICalculator.GetProductionStatus(),
Timestamp = DateTime.Now
};
}
[MCPMethod(Description = "Get production history for specified hours")]
public object GetProductionHistory(
[MCPParameter(Description = "Hours to look back")] int hours)
{
var endTime = DateTime.Now;
var startTime = endTime.AddHours(-hours);
// Query historian
var data = @Historian.Table.ProductionData.GetData(startTime, endTime);
return new {
Period = $"Last {hours} hours",
AverageRate = @Script.Class.KPICalculator.GetAverageProduction(startTime, endTime),
TotalUnits = @Tag.TotalUnits,
DataPoints = data.Rows.Count
};
}
[MCPMethod(Description = "Analyze production trend")]
public string AnalyzeProductionTrend(
[MCPParameter(Description = "Time period in hours")] int periodHours)
{
var current = @Tag.ProductionRate;
var average = @Script.Class.KPICalculator.GetAverageProduction(
DateTime.Now.AddHours(-periodHours), DateTime.Now);
if (current > average * 1.1)
return "Trending Up - Production improving";
else if (current < average * 0.9)
return "Trending Down - Requires attention";
else
return "Stable - Within normal range";
}
This tutorial demonstrates using ML.NET 4.0 for real-time anomaly detection on sensor data using Script Tasks.
Prerequisites:
Tag.SensorValue
(Double) - Current readingTag.AnomalyScore
(Double) - Detection scoreTag.IsAnomaly
(Boolean) - Alert flagTag.Threshold
(Double) - Detection threshold (default: 0.3)AnomalyDetector
csharp
// Simple spike detection using ML.NET
using Microsoft.ML;
using Microsoft.ML.Data;
// Static ML context (initialized once)
if (@Tag.MLContext == null)
{
@Tag.MLContext = new MLContext(seed: 0);
@Tag.DetectionEngine = InitializeDetector();
}
// Data class for ML model
public class SensorData
{
public float Value { get; set; }
}
public class AnomalyPrediction
{
[VectorType(3)]
public double[] Prediction { get; set; }
}
// Initialize detector (runs once)
private ITransformer InitializeDetector()
{
var dataView = @Tag.MLContext.Data.LoadFromEnumerable(new List<SensorData>());
var pipeline = @Tag.MLContext.Transforms
.DetectSpikeBySsa(
outputColumnName: "Prediction",
inputColumnName: "Value",
confidence: 95,
pvalueHistoryLength: 30,
trainingWindowSize: 90,
seasonalityWindowSize: 30);
return pipeline.Fit(dataView);
}
// Detection logic (runs every second)
var currentValue = (float)@Tag.SensorValue;
var data = new SensorData { Value = currentValue };
var prediction = @Tag.DetectionEngine.Transform(
@Tag.MLContext.Data.LoadFromEnumerable(new[] { data }));
var result = @Tag.MLContext.Data
.CreateEnumerable<AnomalyPrediction>(prediction, false)
.First();
// Update tags with results
@Tag.AnomalyScore = result.Prediction[0]; // Spike score
@Tag.IsAnomaly = result.Prediction[0] > @Tag.Threshold;
// Log anomalies
if (@Tag.IsAnomaly)
{
@Alarm.GlobalSettings.AuditTrail.AddCustomMessage(
$"Anomaly detected: Sensor={currentValue:F2}, Score={result.Prediction[0]:F3}");
}
SensorSimulator
csharp
// Simulate normal sensor data with occasional spikes
Random rand = new Random();
double baseValue = 50.0;
double noise = rand.NextDouble() * 5 - 2.5;
// Inject anomaly occasionally (5% chance)
if (rand.NextDouble() < 0.05)
{
@Tag.SensorValue = baseValue + (rand.NextDouble() * 30 + 20); // Spike
}
else
{
@Tag.SensorValue = baseValue + noise; // Normal variation
}
With these tags created: Pressure (Integer) and AnomalyBuffer (Text Array 9 position)
In Devices → Protocols, select the Value Simulator and click the "New Channel..." button.
In Devices → Points, create points to generate simulated data.
TagName | Node | Address | DataType | AccessType |
---|---|---|---|---|
Tag.Pressure | Node.ValueSimulator1Node1 | INTEGER:0,100,1 | Native | AccessType.Read |
For more information about the Value Simulator, see: Value Simulator Connector
Navigate to Scripts → Classes
Click the "Create a New Class" button
In "Import code from Library:", select AnomalyML
Open the script and uncomment the line that returns the detection to the AnomalyBuffer tag in Check() method.
This expression will check for anomalies each time the tag value changes.
Go to Scripts → Expressions
Create the following expression:
ObjectName | Expression | Execution |
---|---|---|
Script.Class.AnomalyML.Check(<DesiredTag>) | OnChange |
Where:
<DesiredTag> is the tag you want to monitor for anomalies
Example:
ObjectName | Expression | Execution |
---|---|---|
Script.Class.AnomalyML.Check(Tag.Pressure) | OnChange |
Go in Runtime → “Run Startup”
Wait a couple minutes to have some data in the model.
Open the PropertyWatch
See the values in the AnomalyBuffer, to see the predictions.
Page Tree | ||||
---|---|---|---|---|
|