update

.idea/misc.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
-  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.9" project-jdk-type="Python SDK" />
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.9 (pythonProject)" project-jdk-type="Python SDK" />
 </project>
\ No newline at end of file

.idea/opcua-cloning.iml

@@ -2,7 +2,7 @@
 <module type="PYTHON_MODULE" version="4">
   <component name="NewModuleRootManager">
     <content url="file://$MODULE_DIR$" />
-    <orderEntry type="jdk" jdkName="Python 3.9" jdkType="Python SDK" />
+    <orderEntry type="jdk" jdkName="Python 3.9 (pythonProject)" jdkType="Python SDK" />
     <orderEntry type="sourceFolder" forTests="false" />
   </component>
 </module>
\ No newline at end of file

opcua_receiver.py

@@ -26,11 +26,10 @@ UDPServerSocket.bind((localIP, localPort))
 print("UDP server up and listening")
 opua=opcua_pack()
 sock = opua.connect("opc.tcp://2.2.2.5:53530/OPCUA/SimulationServer")
-opua.write_opcua_value(sock,3, 1002, 11)
 
 while (True):
     bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
     message = bytesAddressPair[0]
     datatype,value,ns,nodeid = message.decode().split("&")
     print(nodeid)
-    opua.write_opcua_value(sock,int(ns), int(nodeid), value,datatype)
+    opua.write_opcua_value(sock,ns,nodeid, value,datatype)

opcua_subscriber/opcua_subscribe.py

@@ -13,6 +13,7 @@ class opcua_pack():
         self.identifier_string = ""
         self.int_chunk_seq = 5
         self.float_chunk_seq = 4
+        self.cs=5
 
 
     def helf(self,address):
@@ -377,7 +378,8 @@ class opcua_pack():
         else:
             Message_Size = 123
             vt_type=6
-            vt_value = struct.pack('i', value)
+            print(value)
+            vt_value = struct.pack('i', int(value))
         statuscode=binascii.unhexlify("00000000")
 
 
@@ -452,6 +454,9 @@ class opcua_pack():
 
     def write_opcua_value(self,sock,ns,nodeid,val,datatype):
         if(datatype=="<class 'float'>"):
-            sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, self.int_chunk_seq, ns, nodeid, val, datatype))
+            sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, self.cs, int(ns), int(nodeid), float(val), datatype))
+            self.cs=self.cs+1
         else:
-            sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, self.float_chunk_seq, ns,nodeid, val, datatype))
+            sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, self.cs, int(ns),int(nodeid),float(val), datatype))
+            self.cs=self.cs+1
+        print(sock.recv(1024))