|
@@ -2,6 +2,7 @@
|
|
import redis
|
|
import redis
|
|
import asyncio
|
|
import asyncio
|
|
import tracemalloc
|
|
import tracemalloc
|
|
|
|
+import aioredis
|
|
|
|
|
|
from asyncua import Client
|
|
from asyncua import Client
|
|
from datetime import datetime
|
|
from datetime import datetime
|
|
@@ -13,6 +14,7 @@ tracemalloc.start()
|
|
point_arr = [f"OPC.电液控.支架集.{num:03d}.立柱压力.前柱压力" for num in range(1, 138)]
|
|
point_arr = [f"OPC.电液控.支架集.{num:03d}.立柱压力.前柱压力" for num in range(1, 138)]
|
|
|
|
|
|
|
|
|
|
|
|
+# 连接opcua
|
|
async def connect_and_read_opcua_data():
|
|
async def connect_and_read_opcua_data():
|
|
ns = 2
|
|
ns = 2
|
|
result_arr = {}
|
|
result_arr = {}
|