Connect to 2 servers and subscribe to nodes

[sahebdatta]

Dear all,

I was trying to connect to 2 OPC UA servers and create a handler for subscription with a few nodes. The setup is as follows:

1. There are 2 OPC UA servers in the same network to which I am able to connect with one python script by creating two client instances
2. Both the servers have the same variables with the same node id.

I have attached a few important lines from my code

class ButtonHandler(object):
    def datachange_notification(self, node, val, data):
        print(str(node)+" New State: "+str(val))

def connectToServer(index):
    current_client = clients[index]
    client[index] = Client(current_client["opcuaServer"])
    print("Connecting to "+str(current_client["name"]))
    try:
        client[index].connect()
    except:
        print(current_client['name']+" Connection not established")
    else:
        print(f"{current_client['name']} is connected. Reading data")
        sub[index] = client[index].create_subscription(500, ButtonHandler())
        createHandler(index)

def createHandler(index):
    for index3 in range(len(clients[index]["table"])):
        triggerParam = clients[index]["table"][index3]["trigger"]
        handle[index][index3] = sub[index].subscribe_data_change(client[index].get_node(triggerParam))

if __name__ == "__main__":
    for index1 in range(len(clients)):
        connectToServer(index1)

This code can subscribe to all the required variables and print the node id when the value for the respective node changes, but I am unable to trace the server.
Please help me with this,

Thanks in advance.
SD

[sahebdatta]

SOLVED

class ButtonHandler(object):
    def __init__(self, server):
        self.server = server
    def datachange_notification(self, node, val, data):
        print(str(self.server)+" New State: "+str(val))

def connectToServer(index):
    current_client = clients[index]
    client[index] = Client(current_client["opcuaServer"])
    print("Connecting to "+str(current_client["name"]))
    try:
        client[index].connect()
    except:
        print(current_client['name']+" Connection not established")
    else:
        print(f"{current_client['name']} is connected. Reading data")
        sub[index] = client[index].create_subscription(500, ButtonHandler(current_client['name']))
        createHandler(index)