11

import asyncio

    13

from asyncua import Server

    15

async def main():

    16

    server = Server()

    17

    host = os.environ.get("OPCUA_DEFAULT_HOST", "127.0.0.1")

    18

    endpoint = "opc.tcp://"+host+":4840/freeopcua/server/"

    19

    await server.init()

    20

    server.set_endpoint(endpoint)

    22

    uri = "http://beremiz.github.io"

    23

    idx = await server.register_namespace(uri)

    25

    objects = server.get_objects_node()

    27

    testobj = await objects.add_object(idx, "TestObject")

    28

    testvarout = await testobj.add_variable(idx, "TestOut", 1.2)

    29

    testvar = await testobj.add_variable(idx, "TestIn", 5.6)

    30

    await testvar.set_writable()

    32

    await server.start()

    33

    try:

    34

        while True:

    35

            await asyncio.sleep(1)

    36

            inval = await testvar.get_value()

    37

            print(inval)

    38

            await testvarout.set_value(inval*2)

    39

            sys.stdout.flush()

    40

    finally:

    41

        await server.stop()

    43

asyncio.run(main())

    44