MySQL是一個流行的開源關系型數據庫,可以用于存儲和管理應用程序中的數據。OPC是一種工業通信協議,用于實時數據傳輸和監測。在一些工業應用場景中,需要將MySQL和OPC連接起來,以實現數據監測、記錄、查詢等功能。
下面是一個使用Python編寫的MySQL和OPC連接的示例:
import mysql.connector import open62541 as opc # 創建MySQL連接 mydb = mysql.connector.connect( host="localhost", user="root", password="password", database="testdb" ) # 創建OPC UA客戶端 client = opc.Client("opc.tcp://localhost:4840") # 連接到OPC服務器 client.connect() # 獲取OPC UA節點數據 node = client.get_node("ns=2;s=Random_Number") value = node.get_value() # 將數據存儲到MySQL數據庫中 mycursor = mydb.cursor() sql = "INSERT INTO data (value) VALUES (%s)" val = (value,) mycursor.execute(sql, val) mydb.commit() # 關閉MySQL連接和OPC UA客戶端 mycursor.close() mydb.close() client.disconnect()
在示例中,首先創建了一個MySQL連接,并建立了一個名為"testdb"的數據庫。然后創建了一個OPC UA客戶端,并連接到本地的OPC服務器。通過"get_node"方法獲取了名為"Random_Number"的節點的值,并將其存儲到MySQL數據庫中。
通過MySQL和OPC的連接,我們可以實現工業應用中的實時數據監測、記錄、查詢等功能。同時,也使得數據處理更加便捷、高效。