|
@@ -43,7 +43,7 @@ async def get_opc_data(sys_url, point_arr, ns=2):
|
|
tag = client.get_node(node)
|
|
tag = client.get_node(node)
|
|
value = await tag.read_value()
|
|
value = await tag.read_value()
|
|
# redis值
|
|
# redis值
|
|
- redis_conn.set(str(node), str(value))
|
|
|
|
|
|
+ redis_conn.set(str(point_arr[i]), str(value))
|
|
arr_key = node.split("=")
|
|
arr_key = node.split("=")
|
|
result_arr[arr_key[2]] = value
|
|
result_arr[arr_key[2]] = value
|
|
finally:
|
|
finally:
|