Commit ffaf4405 authored by oroulet's avatar oroulet Committed by oroulet

linting of server-callback example

parent d5c7acb2
import sys
sys.path.insert(0, "..")
import logging
from datetime import datetime
import asyncio
try:
......@@ -16,38 +13,37 @@ except ImportError:
shell.interact()
from asyncua import ua, uamethod, Server
from asyncua import ua, Server
from asyncua.common.callback import CallbackType
def create_monitored_items(event, dispatcher):
print("Monitored Item")
for idx in range(len(event.response_params)) :
if (event.response_params[idx].StatusCode.is_good()) :
for idx in range(len(event.response_params)):
if event.response_params[idx].StatusCode.is_good():
nodeId = event.request_params.ItemsToCreate[idx].ItemToMonitor.NodeId
print(f"Node {nodeId} was created")
def modify_monitored_items(event, dispatcher):
print('modify_monitored_items')
print("modify_monitored_items")
def delete_monitored_items(event, dispatcher):
print('delete_monitored_items')
print("delete_monitored_items")
async def main():
# optional: setup logging
logging.basicConfig(level=logging.WARN)
#logger = logging.getLogger("asyncua.address_space")
# logger = logging.getLogger("asyncua.address_space")
# logger.setLevel(logging.DEBUG)
#logger = logging.getLogger("asyncua.internal_server")
# logger = logging.getLogger("asyncua.internal_server")
# logger.setLevel(logging.DEBUG)
#logger = logging.getLogger("asyncua.binary_server_asyncio")
# logger = logging.getLogger("asyncua.binary_server_asyncio")
# logger.setLevel(logging.DEBUG)
#logger = logging.getLogger("asyncua.uaprocessor")
# logger = logging.getLogger("asyncua.uaprocessor")
# logger.setLevel(logging.DEBUG)
logger = logging.getLogger("asyncua.subscription_service")
logger.setLevel(logging.DEBUG)
......@@ -55,8 +51,8 @@ async def main():
# now setup our server
server = Server()
await server.init()
#await server.disable_clock()
#server.set_endpoint("opc.tcp://localhost:4840/freeopcua/server/")
# await server.disable_clock()
# server.set_endpoint("opc.tcp://localhost:4840/freeopcua/server/")
server.set_endpoint("opc.tcp://0.0.0.0:4840/freeopcua/server/")
server.set_server_name("FreeOpcUa Example Server")
......@@ -73,7 +69,6 @@ async def main():
myvar = await myobj.add_variable(idx, "MyVariable", 6.7)
await myvar.set_writable() # Set MyVariable to be writable by clients
# starting!
await server.start()
......@@ -86,5 +81,5 @@ async def main():
await asyncio.sleep(1)
if __name__ == '__main__':
if __name__ == "__main__":
asyncio.run(main())
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