// This example subscribes to changes of 2 items separately, and displays rich information available with each item changed
// event notification.
using System;
using System.Diagnostics;
using System.Threading;
using OpcLabs.EasyOpc.DataAccess;
using OpcLabs.EasyOpc.DataAccess.OperationModel;
namespace DocExamples.DataAccess._EasyDAItemChangedEventArgs
{
class General
{
public static void Main1()
{
// Instantiate the client object.
using (var client = new EasyDAClient())
{
var eventHandler = new EasyDAItemChangedEventHandler(client_ItemChanged);
client.ItemChanged += eventHandler;
Console.WriteLine("Subscribing items...");
client.SubscribeItem("", "OPCLabs.KitServer.2", "Simulation.Random", 5 * 1000);
client.SubscribeItem("", "OPCLabs.KitServer.2", "Trends.Ramp (1 min)", 5 * 1000);
Console.WriteLine("Processing item changed events for 1 minute...");
Thread.Sleep(60 * 1000);
}
}
static void client_ItemChanged(object sender, EasyDAItemChangedEventArgs e)
{
Console.WriteLine();
Console.WriteLine($"e.Arguments.State: {e.Arguments.State}");
Console.WriteLine($"e.Arguments.ServerDescriptor.MachineName: {e.Arguments.ServerDescriptor.MachineName}");
Console.WriteLine($"e.Arguments.ServerDescriptor.ServerClass: {e.Arguments.ServerDescriptor.ServerClass}");
Console.WriteLine($"e.Arguments.ItemDescriptor.ItemId: {e.Arguments.ItemDescriptor.ItemId}");
Console.WriteLine($"e.Arguments.ItemDescriptor.AccessPath: {e.Arguments.ItemDescriptor.AccessPath}");
Console.WriteLine($"e.Arguments.ItemDescriptor.RequestedDataType: {e.Arguments.ItemDescriptor.RequestedDataType}");
Console.WriteLine($"e.Arguments.GroupParameters.Locale: {e.Arguments.GroupParameters.Locale}");
Console.WriteLine($"e.Arguments.GroupParameters.RequestedUpdateRate: {e.Arguments.GroupParameters.RequestedUpdateRate}");
Console.WriteLine($"e.Arguments.GroupParameters.PercentDeadband: {e.Arguments.GroupParameters.PercentDeadband}");
if (e.Succeeded)
{
Debug.Assert(!(e.Vtq is null));
Console.WriteLine($"e.Vtq.Value: {e.Vtq.Value}");
Console.WriteLine($"e.Vtq.Timestamp: {e.Vtq.Timestamp}");
Console.WriteLine($"e.Vtq.TimestampLocal: {e.Vtq.TimestampLocal}");
Console.WriteLine($"e.Vtq.Quality: {e.Vtq.Quality}");
}
else
{
Debug.Assert(!(e.Exception is null));
Console.WriteLine($"e.Exception.Message: {e.Exception.Message}");
Console.WriteLine($"e.Exception.Source: {e.Exception.Source}");
}
}
// Example output:
//
//Processing item changed events for 1 minute...
//
//e.Arguments.State:
//e.Arguments.ServerDescriptor.MachineName:
//e.Arguments.ServerDescriptor.ServerClass: OPCLabs.KitServer.2
//e.Arguments.ItemDescriptor.ItemId: Simulation.Random
//e.Arguments.ItemDescriptor.AccessPath:
//e.Arguments.ItemDescriptor.RequestedDataType: Empty
//e.Arguments.GroupParameters.Locale: 0
//e.Arguments.GroupParameters.RequestedUpdateRate: 5000
//e.Arguments.GroupParameters.PercentDeadband: 0
//e.Vtq.Value: 0.00125125888851588
//e.Vtq.Timestamp: 4/10/2020 4:35:25 PM
//e.Vtq.TimestampLocal: 4/10/2020 6:35:25 PM
//e.Vtq.Quality: GoodNonspecific (192)
//
//e.Arguments.State:
//e.Arguments.ServerDescriptor.MachineName:
//e.Arguments.ServerDescriptor.ServerClass: OPCLabs.KitServer.2
//e.Arguments.ItemDescriptor.ItemId: Trends.Ramp(1 min)
//e.Arguments.ItemDescriptor.AccessPath:
//e.Arguments.ItemDescriptor.RequestedDataType: Empty
//e.Arguments.GroupParameters.Locale: 0
//e.Arguments.GroupParameters.RequestedUpdateRate: 5000
//e.Arguments.GroupParameters.PercentDeadband: 0
//e.Vtq.Value: 0.431881904602051
//e.Vtq.Timestamp: 4/10/2020 4:35:25 PM
//e.Vtq.TimestampLocal: 4/10/2020 6:35:25 PM
//e.Vtq.Quality: GoodNonspecific (192)
//
//...
}
}
# This example subscribes to changes of 2 items separately, and displays rich information available with each item
# changed event notification.
# The QuickOPC package is needed. Install it using "pip install opclabs_quickopc".
import opclabs_quickopc
import time
# Import .NET namespaces.
from OpcLabs.EasyOpc.DataAccess import *
# Item changed event handler.
def itemChanged(sender, e):
assert e is not None
print()
print('e.Arguments.State: ', e.Arguments.State, sep='')
print('e.Arguments.ServerDescriptor.MachineName: ', e.Arguments.ServerDescriptor.MachineName, sep='')
print('e.Arguments.ServerDescriptor.ServerClass: ', e.Arguments.ServerDescriptor.ServerClass, sep='')
print('e.Arguments.ItemDescriptor.ItemId: ', e.Arguments.ItemDescriptor.ItemId, sep='')
print('e.Arguments.ItemDescriptor.AccessPath: ', e.Arguments.ItemDescriptor.AccessPath, sep='')
print('e.Arguments.ItemDescriptor.RequestedDataType: ', e.Arguments.ItemDescriptor.RequestedDataType, sep='')
print('e.Arguments.GroupParameters.Locale: ', e.Arguments.GroupParameters.Locale, sep='')
print('e.Arguments.GroupParameters.RequestedUpdateRate: ', e.Arguments.GroupParameters.RequestedUpdateRate, sep='')
print('e.Arguments.GroupParameters.PercentDeadband: ', e.Arguments.GroupParameters.PercentDeadband, sep='')
if e.Succeeded:
assert e.Vtq is not None
print('e.Vtq.Value: ', e.Vtq.Value, sep='')
print('e.Vtq.Timestamp: ', e.Vtq.Timestamp, sep='')
print('e.Vtq.TimestampLocal: ', e.Vtq.TimestampLocal, sep='')
print('e.Vtq.Quality: ', e.Vtq.Quality, sep='')
else:
assert e.Exception is not None
print('e.Exception.Message: ', e.Exception.Message, sep='')
print('e.Exception.Source: ', e.Exception.Source, sep='')
# Instantiate the client object.
client = EasyDAClient()
client.ItemChanged += itemChanged
print('Subscribing item changes for 2 items...')
IEasyDAClientExtension.SubscribeItem(client, '', 'OPCLabs.KitServer.2', 'Simulation.Random', 5*1000)
IEasyDAClientExtension.SubscribeItem(client, '', 'OPCLabs.KitServer.2', 'Trends.Ramp (1 min)', 5*1000)
print('Processing item change notifications for 1 minute...')
time.sleep(60)
print('Unsubscribing all items...')
client.UnsubscribeAllItems()
client.ItemChanged -= itemChanged
print('Finished.')