FreeOpcUa / python-opcua

        # insert monitored item into map to avoid notification arrive before result return

        # server_handle is left as None in purpose as we don't get it yet.

        with self._lock:

            for mi in monitored_items:

                data = SubscriptionItemData()

                data.client_handle = mi.RequestedParameters.ClientHandle

                data.node = Node(self.server, mi.ItemToMonitor.NodeId)

                data.attribute = mi.ItemToMonitor.AttributeId

                data.mfilter = mi.RequestedParameters.Filter

                self._monitoreditems_map[mi.RequestedParameters.ClientHandle] = data

        results = self.server.create_monitored_items(params)

        mids = []

        # process result, add server_handle, or remove it if failed

        with self._lock:

            for idx, result in enumerate(results):

            def __init__(self):

                super(CustomEvent, self).__init__(extended=True)

                self.EventType = node.nodeid

                curr_node = node

                while curr_node.nodeid.Identifier != parent_identifier:

                    for prop in curr_node.get_properties():

                        setattr(self, prop.get_browse_name().Name, prop.get_value())

                    parents = curr_node.get_referenced_nodes(refs=ua.ObjectIds.HasSubtype, direction=ua.BrowseDirection.Inverse, includesubtypes=False)

                    if len(parents) != 1: # Something went wrong

                        return None

                    curr_node = parents[0]