OPC Studio User's Guide and Reference
UASubscribeDataSetArguments Class
'Declaration<CLSCompliantAttribute(True)> <ComDefaultInterfaceAttribute(OpcLabs.EasyOpc.UA.PubSub.OperationModel.ComTypes._UASubscribeDataSetArguments)> <ComVisibleAttribute(True)> <GuidAttribute("7A871DF3-1FE1-4D5F-BC84-961182C37347")> <TypeConverterAttribute(System.ComponentModel.ExpandableObjectConverter)> <ValueControlAttribute("OpcLabs.BaseLib.Forms.Common.UniversalValueControl, OpcLabs.BaseLibForms, Version=5.81.455.1, Culture=neutral, PublicKeyToken=6faddca41dacb409", Export=True, PageId=0)> <SerializableAttribute()> Public Class UASubscribeDataSetArguments Inherits OpcLabs.BaseLib.OperationModel.OperationArguments Implements LINQPad.ICustomMemberProvider, OpcLabs.BaseLib.ComTypes._Info, OpcLabs.BaseLib.ComTypes._Object2, OpcLabs.BaseLib.OperationModel.ComTypes._OperationArguments, OpcLabs.EasyOpc.UA.PubSub.OperationModel.ComTypes._UASubscribeDataSetArguments, System.ICloneable, System.Runtime.Serialization.ISerializable, System.Xml.Serialization.IXmlSerializable
'UsageDim instance As UASubscribeDataSetArguments
[CLSCompliant(true)] [ComDefaultInterface(OpcLabs.EasyOpc.UA.PubSub.OperationModel.ComTypes._UASubscribeDataSetArguments)] [ComVisible(true)] [Guid("7A871DF3-1FE1-4D5F-BC84-961182C37347")] [TypeConverter(System.ComponentModel.ExpandableObjectConverter)] [ValueControl("OpcLabs.BaseLib.Forms.Common.UniversalValueControl, OpcLabs.BaseLibForms, Version=5.81.455.1, Culture=neutral, PublicKeyToken=6faddca41dacb409", Export=true, PageId=0)] [Serializable()] public class UASubscribeDataSetArguments : OpcLabs.BaseLib.OperationModel.OperationArguments, LINQPad.ICustomMemberProvider, OpcLabs.BaseLib.ComTypes._Info, OpcLabs.BaseLib.ComTypes._Object2, OpcLabs.BaseLib.OperationModel.ComTypes._OperationArguments, OpcLabs.EasyOpc.UA.PubSub.OperationModel.ComTypes._UASubscribeDataSetArguments, System.ICloneable, System.Runtime.Serialization.ISerializable, System.Xml.Serialization.IXmlSerializable
[CLSCompliant(true)] [ComDefaultInterface(OpcLabs.EasyOpc.UA.PubSub.OperationModel.ComTypes._UASubscribeDataSetArguments)] [ComVisible(true)] [Guid("7A871DF3-1FE1-4D5F-BC84-961182C37347")] [TypeConverter(System.ComponentModel.ExpandableObjectConverter)] [ValueControl("OpcLabs.BaseLib.Forms.Common.UniversalValueControl, OpcLabs.BaseLibForms, Version=5.81.455.1, Culture=neutral, PublicKeyToken=6faddca41dacb409", Export=true, PageId=0)] [Serializable()] public ref class UASubscribeDataSetArguments : public OpcLabs.BaseLib.OperationModel.OperationArguments, LINQPad.ICustomMemberProvider, OpcLabs.BaseLib.ComTypes._Info, OpcLabs.BaseLib.ComTypes._Object2, OpcLabs.BaseLib.OperationModel.ComTypes._OperationArguments, OpcLabs.EasyOpc.UA.PubSub.OperationModel.ComTypes._UASubscribeDataSetArguments, System.ICloneable, System.Runtime.Serialization.ISerializable, System.Xml.Serialization.IXmlSerializable
If you are on Windows, you can also use the OPC UA PubSub Demo Application to experiment with various settings. This allows you to try out and determine the correct parameters before you put them into the code.
A subscription is initiated by calling the SubscribeDataSet Method on the EasyUASubscriber Class. In its basic form, the method takes a single argument which is an instance of the EasyUASubscribeDataSetArguments Class, and this argument contains all the information necessary to perform the subscription. The object and all the sub-objects it contains are rather complex.
The picture below is meant to give you at least a general overview about what this object contains. There are more "smaller" properties to the individual objects on the picture, but we do not care about them for now.
The main parts of the EasyUASubscribeDataSetArguments is the DataSetSubscriptionDescriptor: it describes the dataset(s) you want to subscribe to.
The ResolverDescriptor in the DataSetSubscriptionDescriptor is for OPC UA PubSub logical resolution, if used.
Inside the dataset subscription descriptor, you always need to specify the PubSub connection, using the ConnectionDescriptor Property. You will typically also need to fill in data in the Filter Property (see Message Filtering (OPC UA PubSub)), and sometimes provide the DataSetMetaData Property (see Dataset Metadata (OPC UA PubSub)). The CommunicationParameters Property is used to specify details about the communication, message receive timeout, and parameters specific to message or transport protocol mapping.
There are many (extension method) overloads of the SubscribeDataSet Method, with various combinations of arguments. These overloads allow you to bypass the construction of the whole EasyUASubscribeDataSetArguments hierarchy, and pass in simply the parts you need.
The example below subscribes to all dataset messages on an OPC-UA PubSub connection with UDP UADP mapping. The connection is specified by its physical parameters, using the scheme name "opc.udp" and the IP address of the multicast group to listen on.
The example specifies just the PubSub connection, and receives all PubSub messages it encounters. In .NET, it illustrates the use of a SubscribeDataSet Method overload that takes just the PubSub connection descriptor as an input.
The information you pass in to the SubscribeDataSet Method may either be used "as is", or it may be subject to OPC UA PubSub logical resolution first. As explained in OPC UA PubSub Descriptors, you can pass in the physical identifiers, the logical identifiers, or both. The OPC UA PubSub logical resolution mechanism will be invoked if the dataset subscription descriptor requires resolution (this term is explained in OPC UA PubSub Descriptors).
We can reformulate it so: If you have specified physical identifiers everywhere, they will be directly used, and no logical resolution will take place - even if there are logical identifies filled in as well. If, however, you have a PubSub object somewhere in the descriptors that is only specified by its logical identifier but no physical identifier, the logical resolution mechanism will be used.
There are two ways your program can be informed about dataset messages that you have subscribed to:
It is also possible to specify a non-null callback parameter, and hook an event handler as well. In this case, the callback method will be invoked in addition to the event handlers.
The event arguments of the DataSetMessage Event are of type EasyUADataSetMessageEventArgs. Because it is indirectly derived from the OperationEventArgs, it contains the Exception Property which is null for success notifications, and non-null in case of failure. You can use the Succeeded Property to make the corresponding test. The actual data of the dataset, if available, is in the DataSetData Property.
The EasyUADataSetMessageEventArgs also contain, in their Arguments Property, a copy of the arguments (EasyUASubscribeDataSetArguments Class) you have used when making the dataset subscription that caused this event or callback. You can use this property to identify the dataset subscription, in case you are using event handlers and have made more subscriptions on the same object, or if you have used the same callback methods with multiple subscriptions. Specifically, the State Property in the EasyUASubscribeDataSetArguments can be used for any information you need to pass from the code that makes the subscription to the code that handles the dataset messages.
The EasyUASubscriber invokes the DataSetMessage event or callback when a new dataset message (you have subscribed to) arrives, but also in some other cases. Below is a list of possible property value combinations and their meaning.
The main causes for failures are
If the OPC UA PubSub logical resolution took place, the ResolvedDataSetSubscriptionDescriptor Property is filled in with a dataset subscription descriptor that is derived from the one you have specified when calling the SubscribeDataSet Method, but with the logical identifiers resolved to physical ones.
The dataset message event notification has a PubSubLocators Property. This property is always non-null (even in case of errors), and contains the information that allows to relate the event to its "source" in the OPC UA PubSub model. The object (UAPubSubLocators Class) has properties for a publisher Id, writer group Id, writer group name, dataset writer Id, and dataset writer name. The component will fill in as many of these properties as possible, given the circumstances. Knowing such relation comes handy when the dataset subscription filter is not for a single dataset, but for multiple datasets. Note that all information contained in the PubSubLocators Property is also available inside the dataset data. The difference is that the PubSubLocators object is present even in cases when there is dataset data - such as in case of errors. The PubSubLocators thus allow to determine the "source" of the error programmatically.
A typical task when processing the dataset message is to extract one or more fields from the dataset and process them further. The field is identified by its name (or an index in its string form, such "#0", if field names are not available) in the FieldDataDictionary. The example below shows how it can be done.
If metadata is available, you can alternatively use the FieldDataDictionaryById Property, which also contains the data for each field of the dataset message, but keyed by a dataset field Id (a GUID).
Depending how OPC UA PubSub is configured, the publisher might be always sending all fields of the dataset with every dataset message, or it may use a combination of key frames and delta frames. While the key frame dataset message includes values for all fields of the dataset, the delta frame only contains values of the fields that have changed since the previous dataset message.
Key frames and delta frames are a concept that exists purely to spare the network bandwidth. When you subscribe with QuickOPC, the delta frames are interpreted internally, and a full dataset is always shipped to you in the dataset message event or callback. This way, you do not have to put in any additional code to handle the distinction between key frames and delta frames.
It is not necessary to unsubscribe and subscribe again, if you want to change some parameters of existing subscription, such as its filter (Message Filtering (OPC UA PubSub)) or the associated metadata (Dataset Metadata (OPC UA PubSub)). You change the parameters by calling the ChangeDataSetSubscription Method, passing it the dataset subscription handle, and the new parameters in form of an instance of the EasyUADataSetSubscriptionChangeArguments Class.
There is also an extension method (an overload - with the same name) that allows you to easily pass in just the dataset subscription handle, and a new filter.
If you no longer want to receive dataset messages, you need to unsubscribe. This is achieved by calling the UnsubscribeDataSet Method, passing it the dataset subscription handle obtained when calling the SubscribeDataSet Method.
Example:
You can also unsubscribe from all dataset messages you have previously subscribed to (on the same instance of the EasyUASubscriber Class) by calling the UnsubscribeAllDataSets Method.
QuickOPC merges together requests to the same PubSub objects. If, for example, you make multiple dataset subscriptions and they all use the same PubSub connection, QuickOPC will only make the connection once.
This merging is performed among all subscriptions on all EasyUASubscriber objects that have their Isolated Property set to 'false' (the default). If you set the Isolated Property on some EasyUASubscriber object to 'true', the merging is then performed on the subscriptions made on that object only.
Newer versions of OPC UA specification allow the publishers to inform interested parties about their status, either cyclically, or when the status changes. OPC Studio recognizes and processes the publisher status messages in UADP and JSON message mappings. Any non-operational publisher status is reported as an error through the dataset subscription event handler or callback.
This functionality is commonly used with OPC UA PubSub Topic Tree, in which case the topic tree rules prescribe the name of the topic where the status messages for a particular publisher are located.
// This example shows how to subscribe to all dataset messages with specific publisher Id, on an OPC-UA PubSub connection // with UDP UADP mapping. // // In order to produce network messages for this example, run the UADemoPublisher tool. For documentation, see // https://kb.opclabs.com/UADemoPublisher_Basics . In some cases, you may have to specify the interface name to be used. // // Find all latest examples here: https://opclabs.doc-that.com/files/onlinedocs/OPCLabs-OpcStudio/Latest/examples.html . // OPC client and subscriber examples in C# on GitHub: https://github.com/OPCLabs/Examples-QuickOPC-CSharp . // Missing some example? Ask us for it on our Online Forums, https://www.opclabs.com/forum/index ! You do not have to own // a commercial license in order to use Online Forums, and we reply to every post. using System; using System.Collections.Generic; using System.Threading; using OpcLabs.EasyOpc.UA.PubSub; using OpcLabs.EasyOpc.UA.PubSub.OperationModel; namespace UASubscriberDocExamples.PubSub._EasyUASubscriber { partial class SubscribeDataSet { public static void PublisherId() { // Define the PubSub connection we will work with. Uses implicit conversion from a string. UAPubSubConnectionDescriptor pubSubConnectionDescriptor = "opc.udp://239.0.0.1"; // In some cases you may have to set the interface (network adapter) name that needs to be used, similarly to // the statement below. Your actual interface name may differ, of course. //pubSubConnectionDescriptor.ResourceAddress.InterfaceName = "Ethernet"; // Define the arguments for subscribing to the dataset, where the filter is (unsigned 64-bit) publisher Id 31. var subscribeDataSetArguments = new UASubscribeDataSetArguments( pubSubConnectionDescriptor, UAPublisherId.CreateUInt64(31)); // Instantiate the subscriber object and hook events. var subscriber = new EasyUASubscriber(); subscriber.DataSetMessage += subscriber_DataSetMessage_PublisherId; Console.WriteLine("Subscribing..."); subscriber.SubscribeDataSet(subscribeDataSetArguments); Console.WriteLine("Processing dataset message events for 20 seconds..."); Thread.Sleep(20 * 1000); Console.WriteLine("Unsubscribing..."); subscriber.UnsubscribeAllDataSets(); Console.WriteLine("Waiting for 1 second..."); // Unsubscribe operation is asynchronous, messages may still come for a short while. Thread.Sleep(1 * 1000); Console.WriteLine("Finished."); } static void subscriber_DataSetMessage_PublisherId(object sender, EasyUADataSetMessageEventArgs e) { // Display the dataset. if (e.Succeeded) { // An event with null DataSetData just indicates a successful connection. if (!(e.DataSetData is null)) { Console.WriteLine(); Console.WriteLine($"Dataset data: {e.DataSetData}"); foreach (KeyValuePair<string, UADataSetFieldData> pair in e.DataSetData.FieldDataDictionary) Console.WriteLine(pair); } } else { Console.WriteLine(); Console.WriteLine($"*** Failure: {e.ErrorMessageBrief}"); } } // Example output: // //Subscribing... //Processing dataset message events for 20 seconds... // //Dataset data: Good; Event; publisher=(UInt64)31, writer=51, fields: 4 //[#0, True {System.Boolean}; Good] //[#1, 1237 {System.Int32}; Good] //[#2, 2514 {System.Int32}; Good] //[#3, 10/1/2019 9:03:59 AM {System.DateTime}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 //[#0, False {System.Boolean}; Good] //[#1, 1239 {System.Int32}; Good] //[#2, 2703 {System.Int32}; Good] //[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=4, fields: 16 //[#0, False {System.Boolean}; Good] //[#1, 215 {System.Byte}; Good] //[#2, 1239 {System.Int16}; Good] //[#3, 1239 {System.Int32}; Good] //[#4, 1239 {System.Int64}; Good] //[#5, 87 {System.Int16}; Good] //[#6, 1239 {System.Int32}; Good] //[#7, 1239 {System.Int64}; Good] //[#8, 1239 {System.Decimal}; Good] //[#9, 1239 {System.Single}; Good] //[#10, 1239 {System.Double}; Good] //[#11, Romeo {System.String}; Good] //[#12, [20] {175, 186, 248, 246, 215, ...} {System.Byte[]}; Good] //[#13, d4492ca8-35c8-4b98-8edf-6ffa5ca041ca {System.Guid}; Good] //[#14, 10/1/2019 9:04:01 AM {System.DateTime}; Good] //[#15, [10] {1239, 1240, 1241, 1242, 1243, ...} {System.Int64[]}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 //[#2, 2722 {System.Int32}; Good] //[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] //[#0, False {System.Boolean}; Good] //[#1, 1239 {System.Int32}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=3, fields: 100 //[#0, 39 {System.Int64}; Good] //[#1, 139 {System.Int64}; Good] //[#2, 239 {System.Int64}; Good] //[#3, 339 {System.Int64}; Good] //[#4, 439 {System.Int64}; Good] //[#5, 539 {System.Int64}; Good] //[#6, 639 {System.Int64}; Good] //[#7, 739 {System.Int64}; Good] //[#8, 839 {System.Int64}; Good] //[#9, 939 {System.Int64}; Good] //[#10, 1039 {System.Int64}; Good] //... } }
' This example shows how to subscribe to all dataset messages with specific publisher Id, on an OPC-UA PubSub connection ' with UDP UADP mapping. ' ' In order to produce network messages for this example, run the UADemoPublisher tool. For documentation, see ' https://kb.opclabs.com/UADemoPublisher_Basics . In some cases, you may have to specify the interface name to be used. ' ' Find all latest examples here: https://opclabs.doc-that.com/files/onlinedocs/OPCLabs-OpcStudio/Latest/examples.html . ' OPC client and subscriber examples in VB.NET on GitHub: https://github.com/OPCLabs/Examples-QuickOPC-VBNET . ' Missing some example? Ask us for it on our Online Forums, https://www.opclabs.com/forum/index ! You do not have to own ' a commercial license in order to use Online Forums, and we reply to every post. Imports OpcLabs.EasyOpc.UA.PubSub Imports OpcLabs.EasyOpc.UA.PubSub.OperationModel Namespace PubSub._EasyUASubscriber Partial Friend Class SubscribeDataSet Public Shared Sub PublisherId() ' Define the PubSub connection we will work with. Uses implicit conversion from a string. Dim pubSubConnectionDescriptor As UAPubSubConnectionDescriptor = "opc.udp://239.0.0.1" ' In some cases you may have to set the interface (network adapter) name that needs to be used, similarly to ' the statement below. Your actual interface name may differ, of course. ' pubSubConnectionDescriptor.ResourceAddress.InterfaceName = "Ethernet" ' Define the arguments for subscribing to the dataset, where the filter is (unsigned 64-bit) publisher Id 31. Dim subscribeDataSetArguments = New UASubscribeDataSetArguments( pubSubConnectionDescriptor, UAPublisherId.CreateUInt64(31)) ' Instantiate the subscriber object and hook events. Dim subscriber = New EasyUASubscriber() AddHandler subscriber.DataSetMessage, AddressOf subscriber_DataSetMessage_PublisherId Console.WriteLine("Subscribing...") subscriber.SubscribeDataSet(subscribeDataSetArguments) Console.WriteLine("Processing dataset message events for 20 seconds...") Threading.Thread.Sleep(20 * 1000) Console.WriteLine("Unsubscribing...") subscriber.UnsubscribeAllDataSets() Console.WriteLine("Waiting for 1 second...") ' Unsubscribe operation is asynchronous, messages may still come for a short while. Threading.Thread.Sleep(1 * 1000) Console.WriteLine("Finished...") End Sub Private Shared Sub subscriber_DataSetMessage_PublisherId(ByVal sender As Object, ByVal e As EasyUADataSetMessageEventArgs) ' Display the dataset. If e.Succeeded Then ' An event with null DataSetData just indicates a successful connection. If e.DataSetData IsNot Nothing Then Console.WriteLine() Console.WriteLine($"Dataset data: {e.DataSetData}") For Each pair As KeyValuePair(Of String, UADataSetFieldData) In e.DataSetData.FieldDataDictionary Console.WriteLine(pair) Next End If Else Console.WriteLine() Console.WriteLine($"*** Failure: {e.ErrorMessageBrief}") End If End Sub End Class ' Example output ' 'Subscribing... 'Processing dataset message events for 20 seconds... ' 'Dataset data: Good; Event; publisher=(UInt64)31, writer=51, fields: 4 '[#0, True {System.Boolean}; Good] '[#1, 1237 {System.Int32}; Good] '[#2, 2514 {System.Int32}; Good] '[#3, 10/1/2019 9:03:59 AM {System.DateTime}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 '[#0, False {System.Boolean}; Good] '[#1, 1239 {System.Int32}; Good] '[#2, 2703 {System.Int32}; Good] '[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=4, fields: 16 '[#0, False {System.Boolean}; Good] '[#1, 215 {System.Byte}; Good] '[#2, 1239 {System.Int16}; Good] '[#3, 1239 {System.Int32}; Good] '[#4, 1239 {System.Int64}; Good] '[#5, 87 {System.Int16}; Good] '[#6, 1239 {System.Int32}; Good] '[#7, 1239 {System.Int64}; Good] '[#8, 1239 {System.Decimal}; Good] '[#9, 1239 {System.Single}; Good] '[#10, 1239 {System.Double}; Good] '[#11, Romeo {System.String}; Good] '[#12, [20] {175, 186, 248, 246, 215, ...} {System.Byte[]}; Good] '[#13, d4492ca8-35c8-4b98-8edf-6ffa5ca041ca {System.Guid}; Good] '[#14, 10/1/2019 9:04:01 AM {System.DateTime}; Good] '[#15, [10] {1239, 1240, 1241, 1242, 1243, ...} {System.Int64[]}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 '[#2, 2722 {System.Int32}; Good] '[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] '[#0, False {System.Boolean}; Good] '[#1, 1239 {System.Int32}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=3, fields: 100 '[#0, 39 {System.Int64}; Good] '[#1, 139 {System.Int64}; Good] '[#2, 239 {System.Int64}; Good] '[#3, 339 {System.Int64}; Good] '[#4, 439 {System.Int64}; Good] '[#5, 539 {System.Int64}; Good] '[#6, 639 {System.Int64}; Good] '[#7, 739 {System.Int64}; Good] '[#8, 839 {System.Int64}; Good] '[#9, 939 {System.Int64}; Good] '[#10, 1039 {System.Int64}; Good] '... End Namespace
// This example shows how to subscribe to all dataset messages with specific publisher Id, on an OPC-UA PubSub connection // with UDP UADP mapping. // // In order to produce network messages for this example, run the UADemoPublisher tool. For documentation, see // https://kb.opclabs.com/UADemoPublisher_Basics . In some cases, you may have to specify the interface name to be used. // // Find all latest examples here: https://opclabs.doc-that.com/files/onlinedocs/OPCLabs-OpcStudio/Latest/examples.html . // OPC client and subscriber examples in Object Pascal (Delphi) on GitHub: https://github.com/OPCLabs/Examples-QuickOPC-OP . // Missing some example? Ask us for it on our Online Forums, https://www.opclabs.com/forum/index ! You do not have to own // a commercial license in order to use Online Forums, and we reply to every post. type TSubscriberEventHandlers80 = class procedure OnDataSetMessage( ASender: TObject; sender: OleVariant; const eventArgs: _EasyUADataSetMessageEventArgs); end; class procedure SubscribeDataSet.PublisherId; var ConnectionDescriptor: _UAPubSubConnectionDescriptor; SubscribeDataSetArguments: _EasyUASubscribeDataSetArguments; Subscriber: TEasyUASubscriber; SubscriberEventHandlers: TSubscriberEventHandlers80; begin // Define the PubSub connection we will work with. SubscribeDataSetArguments := CoEasyUASubscribeDataSetArguments.Create; ConnectionDescriptor := SubscribeDataSetArguments.DataSetSubscriptionDescriptor.ConnectionDescriptor; ConnectionDescriptor.ResourceAddress.ResourceDescriptor.UrlString := 'opc.udp://239.0.0.1'; // In some cases you may have to set the interface (network adapter) name that needs to be used, similarly to // the statement below. Your actual interface name may differ, of course. //ConnectionDescriptor.ResourceAddress.InterfaceName := 'Ethernet'; // Define the arguments for subscribing to the dataset, where the filter is (unsigned 64-bit) publisher Id 31. SubscribeDataSetArguments.DataSetSubscriptionDescriptor.Filter.PublisherId.SetIdentifier(UAPublisherIdType_UInt64, 31); // Instantiate the subscriber object and hook events. Subscriber := TEasyUASubscriber.Create(nil); SubscriberEventHandlers := TSubscriberEventHandlers80.Create; Subscriber.OnDataSetMessage := SubscriberEventHandlers.OnDataSetMessage; WriteLn('Subscribing...'); Subscriber.SubscribeDataSet(SubscribeDataSetArguments); WriteLn('Processing dataset message for 20 seconds...'); PumpSleep(20*1000); WriteLn('Unsubscribing...'); Subscriber.UnsubscribeAllDataSets; WriteLn('Waiting for 1 second...'); // Unsubscribe operation is asynchronous, messages may still come for a short while. PumpSleep(1*1000); WriteLn('Finished.'); FreeAndNil(Subscriber); FreeAndNil(SubscriberEventHandlers); end; procedure TSubscriberEventHandlers80.OnDataSetMessage( ASender: TObject; sender: OleVariant; const eventArgs: _EasyUADataSetMessageEventArgs); var Count: Cardinal; DictionaryEntry2: _DictionaryEntry2; Element: OleVariant; FieldDataDictionaryEnumerator: IEnumVariant; begin // Display the dataset. if eventArgs.Succeeded then begin // An event with null DataSetData just indicates a successful connection. if eventArgs.DataSetData <> nil then begin WriteLn; WriteLn('Dataset data: ', eventArgs.DataSetData.ToString); FieldDataDictionaryEnumerator := eventArgs.DataSetData.FieldDataDictionary.GetEnumerator; while (FieldDataDictionaryEnumerator.Next(1, Element, Count) = S_OK) do begin DictionaryEntry2 := IUnknown(Element) as _DictionaryEntry2; WriteLn(DictionaryEntry2.ToString); end; end; end else begin WriteLn; WriteLn('*** Failure: ', eventArgs.ErrorMessageBrief); end; end; // Example output: // //Subscribing... //Processing dataset message events for 20 seconds... // //Dataset data: Good; Event; publisher=(UInt64)31, writer=51, fields: 4 //[#0, True {System.Boolean}; Good] //[#1, 1237 {System.Int32}; Good] //[#2, 2514 {System.Int32}; Good] //[#3, 10/1/2019 9:03:59 AM {System.DateTime}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 //[#0, False {System.Boolean}; Good] //[#1, 1239 {System.Int32}; Good] //[#2, 2703 {System.Int32}; Good] //[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=4, fields: 16 //[#0, False {System.Boolean}; Good] //[#1, 215 {System.Byte}; Good] //[#2, 1239 {System.Int16}; Good] //[#3, 1239 {System.Int32}; Good] //[#4, 1239 {System.Int64}; Good] //[#5, 87 {System.Int16}; Good] //[#6, 1239 {System.Int32}; Good] //[#7, 1239 {System.Int64}; Good] //[#8, 1239 {System.Decimal}; Good] //[#9, 1239 {System.Single}; Good] //[#10, 1239 {System.Double}; Good] //[#11, Romeo {System.String}; Good] //[#12, [20] {175, 186, 248, 246, 215, ...} {System.Byte[]}; Good] //[#13, d4492ca8-35c8-4b98-8edf-6ffa5ca041ca {System.Guid}; Good] //[#14, 10/1/2019 9:04:01 AM {System.DateTime}; Good] //[#15, [10] {1239, 1240, 1241, 1242, 1243, ...} {System.Int64[]}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 //[#2, 2722 {System.Int32}; Good] //[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] //[#0, False {System.Boolean}; Good] //[#1, 1239 {System.Int32}; Good] // //Dataset data: Good; Data; publisher=(UInt64)31, writer=3, fields: 100 //[#0, 39 {System.Int64}; Good] //[#1, 139 {System.Int64}; Good] //[#2, 239 {System.Int64}; Good] //[#3, 339 {System.Int64}; Good] //[#4, 439 {System.Int64}; Good] //[#5, 539 {System.Int64}; Good] //[#6, 639 {System.Int64}; Good] //[#7, 739 {System.Int64}; Good] //[#8, 839 {System.Int64}; Good] //[#9, 939 {System.Int64}; Good] //[#10, 1039 {System.Int64}; Good] //...
REM This example shows how to subscribe to all dataset messages with specific publisher Id, on an OPC-UA PubSub connection REM with UDP UADP mapping. REM REM In order to produce network messages for this example, run the UADemoPublisher tool. For documentation, see REM https://kb.opclabs.com/UADemoPublisher_Basics . In some cases, you may have to specify the interface name to be used. REM REM Find all latest examples here: https://opclabs.doc-that.com/files/onlinedocs/OPCLabs-OpcStudio/Latest/examples.html . REM OPC client and subscriber examples in Visual Basic on GitHub: https://github.com/OPCLabs/Examples-QuickOPC-VB . REM Missing some example? Ask us for it on our Online Forums, https://www.opclabs.com/forum/index ! You do not have to own REM a commercial license in order to use Online Forums, and we reply to every post. ' The subscriber object, with events 'Public WithEvents Subscriber5 As EasyUASubscriber Private Sub EasyUASubscriber_SubscribeDataSet_PublisherId_Command_Click() OutputText = "" ' Define the PubSub connection we will work with. Dim subscribeDataSetArguments As New EasyUASubscribeDataSetArguments Dim ConnectionDescriptor As UAPubSubConnectionDescriptor Set ConnectionDescriptor = subscribeDataSetArguments.dataSetSubscriptionDescriptor.ConnectionDescriptor ConnectionDescriptor.ResourceAddress.ResourceDescriptor.UrlString = "opc.udp://239.0.0.1" ' In some cases you may have to set the interface (network adapter) name that needs to be used, similarly to ' the statement below. Your actual interface name may differ, of course. 'ConnectionDescriptor.ResourceAddress.InterfaceName := 'Ethernet'; ' Define the arguments for subscribing to the dataset, where the filter is (unsigned 64-bit) publisher Id 31. Call subscribeDataSetArguments.dataSetSubscriptionDescriptor.Filter.PublisherId.SetIdentifier(UAPublisherIdType_UInt64, 31) ' Instantiate the subscriber object and hook events. Set Subscriber5 = New EasyUASubscriber OutputText = OutputText & "Subscribing..." & vbCrLf Call Subscriber5.SubscribeDataSet(subscribeDataSetArguments) OutputText = OutputText & "Processing dataset message for 20 seconds..." & vbCrLf Pause 20000 OutputText = OutputText & "Unsubscribing..." & vbCrLf Subscriber5.UnsubscribeAllDataSets OutputText = OutputText & "Waiting for 1 second..." & vbCrLf ' Unsubscribe operation is asynchronous, messages may still come for a short while. Pause 1000 Set Subscriber5 = Nothing OutputText = OutputText & "Finished." & vbCrLf End Sub Private Sub Subscriber5_DataSetMessage(ByVal sender As Variant, ByVal eventArgs As EasyUADataSetMessageEventArgs) ' Display the dataset If eventArgs.Succeeded Then ' An event with null DataSetData just indicates a successful connection. If Not eventArgs.DataSetData Is Nothing Then OutputText = OutputText & vbCrLf OutputText = OutputText & "Dataset data: " & eventArgs.DataSetData & vbCrLf Dim dictionaryEntry2 : For Each dictionaryEntry2 In eventArgs.DataSetData.FieldDataDictionary OutputText = OutputText & dictionaryEntry2 & vbCrLf Next End If Else OutputText = OutputText & vbCrLf OutputText = OutputText & "*** Failure: " & eventArgs.ErrorMessageBrief & vbCrLf End If ' Example output: ' 'Subscribing... 'Processing dataset message events for 20 seconds... ' 'Dataset data: Good; Event; publisher=(UInt64)31, writer=51, fields: 4 '[#0, True {System.Boolean}; Good] '[#1, 1237 {System.Int32}; Good] '[#2, 2514 {System.Int32}; Good] '[#3, 10/1/2019 9:03:59 AM {System.DateTime}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 '[#0, False {System.Boolean}; Good] '[#1, 1239 {System.Int32}; Good] '[#2, 2703 {System.Int32}; Good] '[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=4, fields: 16 '[#0, False {System.Boolean}; Good] '[#1, 215 {System.Byte}; Good] '[#2, 1239 {System.Int16}; Good] '[#3, 1239 {System.Int32}; Good] '[#4, 1239 {System.Int64}; Good] '[#5, 87 {System.Int16}; Good] '[#6, 1239 {System.Int32}; Good] '[#7, 1239 {System.Int64}; Good] '[#8, 1239 {System.Decimal}; Good] '[#9, 1239 {System.Single}; Good] '[#10, 1239 {System.Double}; Good] '[#11, Romeo {System.String}; Good] '[#12, [20] {175, 186, 248, 246, 215, ...} {System.Byte[]}; Good] '[#13, d4492ca8-35c8-4b98-8edf-6ffa5ca041ca {System.Guid}; Good] '[#14, 10/1/2019 9:04:01 AM {System.DateTime}; Good] '[#15, [10] {1239, 1240, 1241, 1242, 1243, ...} {System.Int64[]}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 '[#2, 2722 {System.Int32}; Good] '[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] '[#0, False {System.Boolean}; Good] '[#1, 1239 {System.Int32}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=3, fields: 100 '[#0, 39 {System.Int64}; Good] '[#1, 139 {System.Int64}; Good] '[#2, 239 {System.Int64}; Good] '[#3, 339 {System.Int64}; Good] '[#4, 439 {System.Int64}; Good] '[#5, 539 {System.Int64}; Good] '[#6, 639 {System.Int64}; Good] '[#7, 739 {System.Int64}; Good] '[#8, 839 {System.Int64}; Good] '[#9, 939 {System.Int64}; Good] '[#10, 1039 {System.Int64}; Good] '... End Sub
Rem This example shows how to subscribe to all dataset messages with specific publisher Id, on an OPC-UA PubSub connection Rem with UDP UADP mapping. Rem Rem In order to produce network messages for this example, run the UADemoPublisher tool. For documentation, see Rem https://kb.opclabs.com/UADemoPublisher_Basics . In some cases, you may have to specify the interface name to be used. Rem Rem Find all latest examples here: https://opclabs.doc-that.com/files/onlinedocs/OPCLabs-OpcStudio/Latest/examples.html . Rem OPC client and subscriber examples in VBScript on GitHub: https://github.com/OPCLabs/Examples-QuickOPC-VBScript . Rem Missing some example? Ask us for it on our Online Forums, https://www.opclabs.com/forum/index ! You do not have to own Rem a commercial license in order to use Online Forums, and we reply to every post. Option Explicit Const UAPublisherIdType_UInt64 = 4 ' Define the PubSub connection we will work with. Dim SubscribeDataSetArguments: Set SubscribeDataSetArguments = CreateObject("OpcLabs.EasyOpc.UA.PubSub.OperationModel.EasyUASubscribeDataSetArguments") Dim ConnectionDescriptor: Set ConnectionDescriptor = SubscribeDataSetArguments.DataSetSubscriptionDescriptor.ConnectionDescriptor ConnectionDescriptor.ResourceAddress.ResourceDescriptor.UrlString = "opc.udp://239.0.0.1" ' In some cases you may have to set the interface (network adapter) name that needs to be used, similarly to ' the statement below. Your actual interface name may differ, of course. ' ConnectionDescriptor.ResourceAddress.InterfaceName = "Ethernet" ' Define the arguments for subscribing to the dataset, where the filter is (unsigned 64-bit) publisher Id 31. SubscribeDataSetArguments.DataSetSubscriptionDescriptor.Filter.PublisherId.SetIdentifier UAPublisherIdType_UInt64, 31 ' Instantiate the subscriber object and hook events. Dim Subscriber: Set Subscriber = CreateObject("OpcLabs.EasyOpc.UA.PubSub.EasyUASubscriber") WScript.ConnectObject Subscriber, "Subscriber_" WScript.Echo "Subscribing..." Subscriber.SubscribeDataSet SubscribeDataSetArguments WScript.Echo "Processing dataset message events for 20 seconds..." WScript.Sleep 20*1000 WScript.Echo "Unsubscribing..." Subscriber.UnsubscribeAllDataSets WScript.Echo "Waiting for 1 second..." ' Unsubscribe operation is asynchronous, messages may still come for a short while. WScript.Sleep 1*1000 WScript.Echo "Finished." Sub Subscriber_DataSetMessage(Sender, e) ' Display the dataset. If e.Succeeded Then ' An event with null DataSetData just indicates a successful connection. If Not (e.DataSetData Is Nothing) Then WScript.Echo WScript.Echo "Dataset data: " & e.DataSetData Dim Pair: For Each Pair in e.DataSetData.FieldDataDictionary WScript.Echo Pair Next End If Else WScript.Echo WScript.Echo "*** Failure: " & e.ErrorMessageBrief End If End Sub ' Example output: ' 'Subscribing... 'Processing dataset message events for 20 seconds... ' 'Dataset data: Good; Event; publisher=(UInt64)31, writer=51, fields: 4 '[#0, True {System.Boolean}; Good] '[#1, 1237 {System.Int32}; Good] '[#2, 2514 {System.Int32}; Good] '[#3, 10/1/2019 9:03:59 AM {System.DateTime}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 '[#0, False {System.Boolean}; Good] '[#1, 1239 {System.Int32}; Good] '[#2, 2703 {System.Int32}; Good] '[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=4, fields: 16 '[#0, False {System.Boolean}; Good] '[#1, 215 {System.Byte}; Good] '[#2, 1239 {System.Int16}; Good] '[#3, 1239 {System.Int32}; Good] '[#4, 1239 {System.Int64}; Good] '[#5, 87 {System.Int16}; Good] '[#6, 1239 {System.Int32}; Good] '[#7, 1239 {System.Int64}; Good] '[#8, 1239 {System.Decimal}; Good] '[#9, 1239 {System.Single}; Good] '[#10, 1239 {System.Double}; Good] '[#11, Romeo {System.String}; Good] '[#12, [20] {175, 186, 248, 246, 215, ...} {System.Byte[]}; Good] '[#13, d4492ca8-35c8-4b98-8edf-6ffa5ca041ca {System.Guid}; Good] '[#14, 10/1/2019 9:04:01 AM {System.DateTime}; Good] '[#15, [10] {1239, 1240, 1241, 1242, 1243, ...} {System.Int64[]}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=1, fields: 4 '[#2, 2722 {System.Int32}; Good] '[#3, 10/1/2019 9:04:01 AM {System.DateTime}; Good] '[#0, False {System.Boolean}; Good] '[#1, 1239 {System.Int32}; Good] ' 'Dataset data: Good; Data; publisher=(UInt64)31, writer=3, fields: 100 '[#0, 39 {System.Int64}; Good] '[#1, 139 {System.Int64}; Good] '[#2, 239 {System.Int64}; Good] '[#3, 339 {System.Int64}; Good] '[#4, 439 {System.Int64}; Good] '[#5, 539 {System.Int64}; Good] '[#6, 639 {System.Int64}; Good] '[#7, 739 {System.Int64}; Good] '[#8, 839 {System.Int64}; Good] '[#9, 939 {System.Int64}; Good] '[#10, 1039 {System.Int64}; Good] '...
# This example shows how to subscribe to all dataset messages with specific publisher Id, on an OPC-UA PubSub connection # with UDP UADP mapping. # # In order to produce network messages for this example, run the UADemoPublisher tool. For documentation, see # https://kb.opclabs.com/UADemoPublisher_Basics . In some cases, you may have to specify the interface name to be used. # # Find all latest examples here: https://opclabs.doc-that.com/files/onlinedocs/OPCLabs-OpcStudio/Latest/examples.html . # OPC client and subscriber examples in Python on GitHub: https://github.com/OPCLabs/Examples-QuickOPC-Python . # Missing some example? Ask us for it on our Online Forums, https://www.opclabs.com/forum/index ! You do not have to own # a commercial license in order to use Online Forums, and we reply to every post. # The QuickOPC package is needed. Install it using "pip install opclabs_quickopc". import opclabs_quickopc import time # Import .NET namespaces. from System import * from OpcLabs.EasyOpc.UA.PubSub import * from OpcLabs.EasyOpc.UA.PubSub.Configuration import * from OpcLabs.EasyOpc.UA.PubSub.OperationModel import * def dataSetMessage(sender, e): # Display the dataset. if e.Succeeded: # An event with null DataSetData just indicates a successful connection. if e.DataSetData is not None: print('') print('Dataset data: ', e.DataSetData, sep='') for pair in e.DataSetData.FieldDataDictionary: print(pair) else: print('') print('*** Failure: ', e.ErrorMessageBrief, sep='') # Define the PubSub connection we will work with. Uses implicit conversion from a string. pubSubConnectionDescriptor = UAPubSubConnectionDescriptor.op_Implicit('opc.udp://239.0.0.1') # In some cases you may have to set the interface (network adapter) name that needs to be used, similarly to # the statement below. Your actual interface name may differ, of course. #pubSubConnectionDescriptor.ResourceAddress.InterfaceName = 'Ethernet' # Define the arguments for subscribing to the dataset, where the filter is (unsigned 64-bit) publisher Id 31. subscribeDataSetArguments = UASubscribeDataSetArguments( pubSubConnectionDescriptor, UASubscribeDataSetFilter(UAPublisherId.CreateUInt64(Decimal(31)))) # Instantiate the subscriber object and hook events. subscriber = EasyUASubscriber() subscriber.DataSetMessage += dataSetMessage print('Subscribing...') IEasyUASubscriberExtension.SubscribeDataSet(subscriber, subscribeDataSetArguments) print('Processing dataset message events for 20 seconds...') time.sleep(20) print('Unsubscribing...') subscriber.UnsubscribeAllDataSets() print('Waiting for 1 second...') # Unsubscribe operation is asynchronous, messages may still come for a short while. time.sleep(1) subscriber.DataSetMessage -= dataSetMessage print('Finished.')
System.Object
OpcLabs.BaseLib.Object2
OpcLabs.BaseLib.Info
OpcLabs.BaseLib.OperationModel.OperationArguments
OpcLabs.EasyOpc.UA.PubSub.OperationModel.UASubscribeDataSetArguments
OpcLabs.EasyOpc.UA.PubSub.OperationModel.EasyUASubscribeDataSetArguments
OpcLabs.EasyOpc.UA.PubSub.OperationModel.EasyUASubscribeDataSetFieldArguments