12 lines
342 B
Python
12 lines
342 B
Python
import asyncio
|
|
from asyncua import Client
|
|
from asyncua.common.subscription import Subscription
|
|
|
|
opc_ua_client: Client
|
|
clients = {} # {WebSocket: set(subscribed_tags)}
|
|
node_storage = {}
|
|
event_storage = {}
|
|
queue = asyncio.Queue(maxsize=10000)
|
|
event_queue = asyncio.Queue(maxsize=1000)
|
|
subscription_handler: Subscription
|
|
subscribed_nodes = set() |