Skip to content

O
opcua-cloning
Commit f27700bd authored by yogesh.m's avatar yogesh.m
Browse files
Options

update

parent 8d0178af
Hide whitespace changes
Inline Side-by-side
Showing with 13 additions and 11 deletions
asyncua_server.py
View file @ f27700bd
...@@ -21,12 +21,14 @@ class asyncua_server(): ...@@ -21,12 +21,14 @@ class asyncua_server():
if(hierarchy[obj]["name"]=="String"): if(hierarchy[obj]["name"]=="String"):
var_obj= await self.server.nodes.objects.add_folder(self.idx,obj ) var_obj= await self.server.nodes.objects.add_folder(self.idx,obj )
val_array=pickle.loads(hierarchy[obj]["obj"]) val_array=pickle.loads(hierarchy[obj]["obj"])
if(val_array["datatype"]==11): print(val_array)
var = await var_obj.add_variable(ua.NodeId(val_array["identifier"],3),val_array["node_name"], ua.NodeId(ua.ObjectIds.Double)) for identifier in val_array:
await var.set_writable() if(val_array[identifier]["datatype"]==11):
if (val_array["datatype"] == 6): 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(val_array["identifier"],3), val_array["node_name"], ua.NodeId(ua.ObjectIds.Int32)) await var.set_writable()
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))
await var.set_writable()
else: else:
await self.server.nodes.objects.add_folder(self.idx, obj) await self.server.nodes.objects.add_folder(self.idx, obj)
......
opcua_receiver.py
View file @ f27700bd
...@@ -31,8 +31,8 @@ print("here") ...@@ -31,8 +31,8 @@ print("here")
opua=opcua_pack() opua=opcua_pack()
sock = opua.connect("opc.tcp://2.2.2.5:53531/myopc/free") sock = opua.connect("opc.tcp://2.2.2.5:53531/myopc/free")
# while (True): while (True):
# bytesAddressPair = UDPServerSocket.recvfrom(bufferSize) bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
# message = bytesAddressPair[0] message = bytesAddressPair[0]
# datatype,value,ns,nodeid = message.decode().split("&") datatype,value,ns,nodeid = message.decode().split("&")
# opua.write_opcua_value(sock,ns,nodeid, value,datatype) opua.write_opcua_value(sock,ns,nodeid, value,datatype)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment