update

asyncua_server.py

@@ -17,17 +17,15 @@ class asyncua_server():
         self.idx=None
 
     async def add_object(self,obj,hierarchy):
-        print(hierarchy[obj])
         if(hierarchy[obj]["name"]=="String"):
             var_obj= await self.server.nodes.objects.add_folder(self.idx,obj )
             val_array=pickle.loads(hierarchy[obj]["obj"])
-            print(val_array)
             for identifier in val_array:
                 if(val_array[identifier]["datatype"]==11):
-                   var = await var_obj.add_variable(ua.NodeId(identifier,3),val_array[identifier]["node_name"], ua.NodeId(ua.ObjectIds.Double))
+                   var = await var_obj.add_variable(ua.NodeId(identifier,3),val_array[identifier]["node_name"], float(0.0))#ua.NodeId(ua.ObjectIds.Double))
                    await var.set_writable()
                 if (val_array[identifier]["datatype"] == 6):
-                   var = await var_obj.add_variable(ua.NodeId(identifier,3), val_array[identifier]["node_name"], ua.NodeId(ua.ObjectIds.Int32))
+                   var = await var_obj.add_variable(ua.NodeId(identifier,3), val_array[identifier]["node_name"], 0,ua.VariantType.Int32)#ua.NodeId(ua.ObjectIds.Int32))
                    await var.set_writable()
         else:
             await self.server.nodes.objects.add_folder(self.idx, obj)
@@ -38,7 +36,6 @@ class asyncua_server():
         return var
 
     async def start_server(self,url,uri):
-        print(url)
         # create a server
         self.server = Server()
         await self.server.init()
@@ -70,7 +67,6 @@ def hash_receive():
         bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
         message = bytesAddressPair[0]
         hierarchy=pickle.loads(message)
-        print(hierarchy["hash"])
         if(prev_hash!=hierarchy["hash"]):
             for object in hierarchy:
                 if(object!="hash"):

opcua_receiver.py

@@ -35,4 +35,6 @@ while (True):
     bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
     message = bytesAddressPair[0]
     datatype,value,ns,nodeid = message.decode().split("&")
+    if("int" in datatype):
+        print(value)
     opua.write_opcua_value(sock,ns,nodeid, value,datatype)
\ No newline at end of file

opcua_subscriber/opcua_subscribe.py

@@ -383,7 +383,6 @@ class opcua_pack():
         else:
             Message_Size = 123
             vt_type=6
-            print(value)
             vt_value = struct.pack('i', int(value))
         statuscode=binascii.unhexlify("00000000")
 
@@ -448,14 +447,12 @@ class opcua_pack():
                 if count == 0:
                     self.identifier_string = data.hex()[156:156 + 64]
                     count = count + 1
-                print('Received:', data)
             except:
                 break
         data = self.start_session(self.SecureChannelId, self.TokenId, self.identifier_string)
         sock.sendall(data)
         res = sock.recv(1024)
         sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, 4, 3, 1002, 1, "<class 'int'>"))
-        print(sock.recv(1024))
         return sock
 
     def write_opcua_value(self,sock,ns,nodeid,val,datatype):