mysql_request外掛程式

外掛程式 mysql_request 會將 SQL 查詢傳送至 Azure MySQL Server 網路端點,並傳回結果中的第一個數據列集。 查詢可能會傳回一個以上的數據列集,但只有第一個數據列集可供 Kusto 查詢的其餘部分使用。

外掛程式是使用運算子叫 evaluate 用的。

重要

外掛程式 mysql_request 預設為停用。 若要啟用外掛程式,請 .enable plugin mysql_request 執行 命令。 若要查看已啟用哪些外掛程式,請使用 .show plugin 管理命令

語法

evaluatemysql_request(連線 ionString,SqlQuery [,SqlParameters] ) [:OutputSchema]

深入瞭解 語法慣例

參數

姓名 類型​​ 必要 描述
ConnectionString string ✔️ 指向 MySQL 伺服器端點的 連接字串。 請參閱 驗證 ,以及如何指定 網路端點
SqlQuery string ✔️ 要針對 SQL 端點執行的查詢。 必須傳回一或多個數據列集。 只有第一組可供其餘查詢使用。
SqlParameters dynamic 屬性包物件,保存索引鍵/值組,以作為參數與查詢一起傳遞。
OutputSchema 外掛程式輸出之預期 mysql_request 數據行的名稱和類型。

語法(ColumnName:ColumnType [, ...])

注意

  • 強烈建議指定 OutputSchema,因為它可讓外掛程式用於若沒有外掛程式的情況下可能無法運作,例如跨叢集查詢。 OutputSchema 也可以啟用多個查詢優化。
  • 如果 SQL 網路端點所傳回之第一個數據列集的運行時間架構不符合 OutputSchema 架構,就會引發錯誤。

驗證與授權

若要授權 MySQL Server 網路端點,您必須在 連接字串 中指定授權資訊。 支援的授權方法是透過使用者名稱和密碼。

設定註標原則

外掛程式會向 MySql 資料庫發出註標。 請確定叢集的圖說原則會啟用目標 MySqlDbUri 類型的mysql呼叫。

下列範例示範如何定義 MySQL 資料庫的註標原則。 我們建議將圖說文字原則限制為特定端點 (my_endpoint1my_endpoint2

[
  {
    "CalloutType": "mysql",
    "CalloutUriRegex": "my_endpoint1\\.mysql\\.database\\.azure\\.com",
    "CanCall": true
  },
  {
    "CalloutType": "mysql",
    "CalloutUriRegex": "my_endpoint2\\.mysql\\.database\\.azure\\.com",
    "CanCall": true
  }
]

下列範例顯示 .alter callout policy CalloutTypemysql命令:

.alter cluster policy callout @'[{"CalloutType": "mysql", "CalloutUriRegex": "\\.mysql\\.database\\.azure\\.com", "CanCall": true}]'

使用者名稱和密碼驗證

外掛程式 mysql_request 僅支援 MySQL 伺服器端點的使用者名稱和密碼驗證,且不會與 Microsoft Entra 驗證整合。

使用者名稱與密碼是使用下列參數作為連接字串的一部分提供:

User ID=...; Password=...;

警告

機密或受防護的信息應該從 連接字串 和查詢模糊化,以便從任何 Kusto 追蹤中省略它們。 如需詳細資訊,請參閱 模糊字串常值

加密和伺服器驗證

為了安全性,在連線到 MySQL 伺服器端點時, SslMode 會無條件地設定為 Required 。 因此,伺服器必須使用有效的 SSL/TLS 伺服器證書進行設定。

指定網路端點

將 MySQL 網路端點指定為 連接字串 的一部分。

語法:

Server=FQDN [Port=連接埠]

其中:

  • FQDN 是端點的完整功能變數名稱。
  • 是連接點的 TCP 連接埠。 預設會採用 3306

範例

Azure MySQL DB 的 SQL 查詢

下列範例會將 SQL 查詢傳送至 Azure MySQL 資料庫。 它會從 [dbo].[Table]擷取所有記錄,然後處理結果。

注意

此範例不應以此方式作為篩選或專案數據的建議。 應該建構 SQL 查詢,以傳回可能最小的數據集。

evaluate mysql_request(
    'Server=contoso.mysql.database.azure.com; Port = 3306;'
    'Database=Fabrikam;'
    h'UID=USERNAME;'
    h'Pwd=PASSWORD;',
    'select * from `dbo`.`Table`') : (Id: int, Name: string)
| where Id > 0
| project Name

使用修改對 Azure MySQL 資料庫的 SQL 查詢

下列範例會將 SQL 查詢傳送至從 擷取所有記錄 [dbo].[Table]的 Azure MySQL 資料庫,同時附加另一個 datetime 數據行,然後在 Kusto 端處理結果。 它會指定要用於 SQL 查詢中的 SQL 參數 (@param0)。

evaluate mysql_request(
    'Server=contoso.mysql.database.azure.com; Port = 3306;'
    'Database=Fabrikam;'
    h'UID=USERNAME;'
    h'Pwd=PASSWORD;',
    'select *, @param0 as dt from `dbo`.`Table`',
    dynamic({'param0': datetime(2020-01-01 16:47:26.7423305)})) : (Id:long, Name:string, dt: datetime)
| where Id > 0
| project Name

沒有查詢定義輸出架構的 Azure MySQL 資料庫的 SQL 查詢

下列範例會將 SQL 查詢傳送至沒有輸出架構的 Azure MySQL 資料庫。 除非架構未知,否則不建議這麼做,因為它可能會影響查詢的效能。

evaluate mysql_request(
    'Server=contoso.mysql.database.azure.com; Port = 3306;'
    'Database=Fabrikam;'
    h'UID=USERNAME;'
    h'Pwd=PASSWORD;',
    'select * from `dbo`.`Table`')
| where Id > 0
| project Name

Azure 監視器不支援此功能。