Commit 127e43c3 authored by yogesh.m's avatar yogesh.m

update

parent d33a082b
from asyncua import Client from asyncua import Client
import asyncio import asyncio
import socket import socket
from time import sleep
ENDPOINT = 'opc.tcp://2.2.2.7:53530/OPCUA/SimulationServer' ENDPOINT = 'opc.tcp://2.2.2.7:53530/OPCUA/SimulationServer'
NAMESPACE = 'http://www.prosysopc.com/OPCUA/SimulationServer/' NAMESPACE = 'http://www.prosysopc.com/OPCUA/SimulationServer/'
...@@ -16,14 +17,21 @@ async def get_send_hash(): ...@@ -16,14 +17,21 @@ async def get_send_hash():
root_objects = await root.get_children() root_objects = await root.get_children()
nm_no = await client.get_namespace_index("http://www.prosysopc.com/OPCUA/SimulationNodes/") nm_no = await client.get_namespace_index("http://www.prosysopc.com/OPCUA/SimulationNodes/")
while True: while True:
sleep(1)
main_obj = [] main_obj = []
hierarchy = {}
Objects = await root_objects[0].get_children() Objects = await root_objects[0].get_children()
for sub_obj in Objects: for sub_obj in Objects:
if (sub_obj.nodeid.NamespaceIndex == nm_no): if (sub_obj.nodeid.NamespaceIndex == nm_no):
display_name=await sub_obj.read_display_name()
identifier_type = sub_obj.nodeid.NodeIdType._name_
ch = await sub_obj.get_children() ch = await sub_obj.get_children()
main_obj = main_obj + ch main_obj = main_obj + ch
UDPClientSocket.sendto(str.encode(str(hash(str(main_obj)))), serverAddressPort) hierarchy[display_name.Text] = {}
print(hash(str(main_obj))) hierarchy[display_name.Text]["name"]=identifier_type
hierarchy[display_name.Text]["obj"]=main_obj
UDPClientSocket.sendto(str.encode(str(hash(str(main_obj)))+"&"+str(hierarchy)), serverAddressPort)
print(str(hash(str(main_obj)))+"&"+str(hierarchy))
if __name__ == '__main__': if __name__ == '__main__':
asyncio.run(get_send_hash()) asyncio.run(get_send_hash())
\ No newline at end of file
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