update

asyncua_server.py

@@ -3,9 +3,10 @@ import pickle
 from asyncua import ua, Server
 import socket
 import threading
-from time import sleep
 import json
 
+server_up=False
+
 class asyncua_server():
     def __init__(self):
         self.server=None

opc_ua_receiver_config.yaml

 configuration:
-  endpoint_url: opc.tcp://2.2.2.5:53531/myopc/free
+  endpoint_url: opc.tcp://2.2.2.5:53530/OPUA/SimulationServer
   namespace_server: http://klopc.com
   udp_hash_receiver_ip: 2.2.2.5
   udp_hash_receiver_port: 20002

opcua_receiver.py

+import os
 import socket
-from time import sleep
 from opcua_subscriber.opcua_subscribe import opcua_pack
 from asyncua_server import st
 import threading
@@ -18,15 +18,30 @@ bufferSize = 1024
 UDPServerSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
 UDPServerSocket.bind((localIP, localPort))
 
-print("UDP server up and listening")
+
 t1=threading.Thread(target=st,args=(Endpoint_Url,Namespace_Server,udp_hash_receiver_ip,udp_hash_receiver_port,))
 t1.start()
-sleep(5)
-opua=opcua_pack()
-sock = opua.connect(Endpoint_Url)
 
-while (True):
+opua=None
+sock=None
+def start_server():
+    global sock
+    global opua
+    try:
+        opua=opcua_pack()
+        sock = opua.connect(Endpoint_Url)
+    except:
+        start_server()
+    return opua, sock
+
+def receive_packets():
+    print("wait until server starts ...")
+    opua,sock=start_server()
+    print("receiving packets ...")
+    while (True):
         bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
         message = bytesAddressPair[0]
         datatype,value,ns,nodeid = message.decode().split("&")
         opua.write_opcua_value(sock,ns,nodeid, value,datatype)
+
+receive_packets()
\ No newline at end of file