Azure IoT Edge入門（10）遠端在IoT Edge裝置上部署SQL資料庫-Deploy Azure SQL Edge to Azure IoT Edge

阿新 • • 發佈：2020-11-18

本文介紹：

遠端在IoT Edge裝置上部署 Azure SQL Edge的幾種方法；

連線到Azure SQL Edge的方法（Edge裝置物理機 / Edge裝置Module容器內）；

Azure Data Studio連線到Azure SQL Edge；

視訊：

https://www.51azure.cloud/post/2020/11/15/azure-iot-edge-10-iot-edge-sql-deploy-azure-sql-edge-to-azure-iot-edge

重點圖文：

遠端在IoT Edge裝置上部署 Azure SQL Edge的幾種方法；

方法1.在Azure Portal上的IoT edge裝置上新增市場模組：

進入IoT Hub 選中要部署SQL EDGE的iot edge裝置：

點選模組設定：

點選新增市場模組：

在市場中選擇SQL Server Module：

方法2.在Azure Portal上的Marketplace中選擇Azure SQL Edge，然後選擇待部署到的IoT Edge裝置，然後進行部署；

找到Azure SQL Edge，然後點選進入下一個頁面：

選擇某個訂閱下的某個hub的某個Edge裝置，然後按照提示進行安裝：

方法三.在VS Code或者visual studio中通過deployment.templete.json 部署檔案部署；

連線到Azure SQL Edge的方法（Edge裝置物理機 / Edge裝置Module容器內）；

參考：

在edge 裝置物理機上或其他物理機上進行連線，使用edge裝置物理機IP地址和埠的方式：

如下圖中的1600表示埠，埠是可配置的選項。

如下圖Python語言：

import pyodbc
server = 'xxx.xxx.xxx.xxx,1600' # Replace this with the actual name of your SQL Edge Docker container
username = 'sa' # SQL Server username
password = 'MyStrongestP@ssword' # Replace this with the actual SA password from your deployment
database = 'MyEdgeDatabase' # Replace this with the actual database name from your deployment. If you do not have a database created, you can use Master database.
db_connection_string = "Driver={ODBC Driver 17 for SQL Server};Server=" + server + ";Database=" + database + ";UID=" + username + ";PWD=" + password + ";"
conn = pyodbc.connect(db_connection_string, autocommit=True)

在部署 sql edge時可指定對映到物理機的埠，如下圖，將容器的1433繫結到物理機的1600埠：

{
    "PortBindings": {
      "1433/tcp": [
        {
          "HostPort": "1600"
        }
      ]
    }
}

如下圖在管理工具中：

在Edge裝置上不同的Module中連線，即同一個裝置上的不同模組（容器）間連線，採用 SQL EDGE模組名的方式：

如下圖python語言：

import pyodbc
server = 'SQLServerModule' # Replace this with the actual name of your SQL Edge Docker container
username = 'sa' # SQL Server username
password = 'MyStrongestP@ssword' # Replace this with the actual SA password from your deployment
database = 'MyEdgeDatabase' # Replace this with the actual database name from your deployment. If you do not have a database created, you can use Master database.
db_connection_string = "Driver={ODBC Driver 17 for SQL Server};Server=" + server + ";Database=" + database + ";UID=" + username + ";PWD=" + password + ";"
conn = pyodbc.connect(db_connection_string, autocommit=True)

如下圖C#語言中：

 var dbstring="Data Source=SQLServerModule;Initial Catalog=master;User Id=SA;Password=Strong!Passw0rd;TrustServerCertificate=False;Connection Timeout=30;";            
      
            try
            {
                 
                 var sensorData=new SensorData();
                 try
                    {
                     sensorData= JsonConvert.DeserializeObject<SensorData>(messageString);
                   
                    }
                    catch(Exception ex)
                    {
                        Console.WriteLine($"error{ex.Message}");
                    }
                
                using (SqlConnection con = new SqlConnection(dbstring))
                {
                    con.Open();
                    if (con.State ==   System.Data.ConnectionState.Open)
                    {
                    
                        string strCmd = $"insert into dbo.Telemetry(temperature,humidity,funcsavedt,deviceid) values ({sensorData.Temperature},{sensorData.Humidity},'{System.DateTime.Now}','{messageReceived.ConnectionDeviceId}' )";


                        SqlCommand sqlcmd = new SqlCommand(strCmd, con);
                        int   n = sqlcmd.ExecuteNonQuery();
                        if (n > 0)
                        {
                            logger.LogInformation("save to sql edge db successfully");
                        }
                        else
                        {
                            logger.LogError("save to sql edge db error");
                        }
                      
                }  
               con.Close();
               }
            }
            catch (Exception ex)
            {
               logger.LogInformation(ex.StackTrace);
            }

其中的“SQLServerModule” 為配置的容器名稱：