适用于 Azure Functions 的 Azure Database for MySQL 触发器绑定（预览版）

GitHub 存储库中提供了 Azure Database for MySQL 触发器的更多示例。

该示例引用类 Product 、 MySqlChangeProduct 类、 MySqlChangeOperation 枚举和相应的数据库表。

在名为Product.java的单独文件中：

package com.function.Common;

import com.fasterxml.jackson.annotation.JsonProperty;

public class Product {
    @JsonProperty("ProductId")
    private int ProductId;
    @JsonProperty("Name")
    private String Name;
    @JsonProperty("Cost")
    private int Cost;

    public Product() {
    }

    public Product(int productId, String name, int cost) {
        ProductId = productId;
        Name = name;
        Cost = cost;
    }
}

在名为MySqlChangeProduct.java的单独文件中：

package com.function.Common;

public class MySqlChangeProduct {
    private MySqlChangeOperation Operation;
    private Product Item;

    public MySqlChangeProduct() {
    }

    public MySqlChangeProduct(MySqlChangeOperation operation, Product item) {
        this.Operation = operation;
        this.Item = item;
    }
}

在名为MySqlChangeOperation.java的单独文件中：

package com.function.Common;

import com.google.gson.annotations.SerializedName;

public enum MySqlChangeOperation {
    @SerializedName("0")
    Update
}

DROP TABLE IF EXISTS Products;

CREATE TABLE Products (
  ProductId int PRIMARY KEY,
  Name varchar(100) NULL,
  Cost int NULL
);

通过将以下列添加到表中，对数据库启用更改跟踪：

ALTER TABLE <table name>  
ADD COLUMN az_func_updated_at TIMESTAMP 
DEFAULT CURRENT_TIMESTAMP 
ON UPDATE CURRENT_TIMESTAMP;

Azure Database for MySQL 触发器绑定到 MySqlChangeProduct[]，这是一组 MySqlChangeProduct 对象。 每个对象都有两个属性：

• item：已更改的项。 项的类型应遵循表架构，如类中 Product 所示。
• operation：枚举中的 MySqlChangeOperation 值。 可能的值为 Update 插入和更新。

以下示例演示在表中发生更改时调用的 Product Java 函数：

/**
 * Copyright (c) Microsoft Corporation. All rights reserved.
 * Licensed under the MIT License. See License.txt in the project root for
 * license information.
 */

package com.function;

import com.microsoft.azure.functions.ExecutionContext;
import com.microsoft.azure.functions.annotation.FunctionName;
import com.microsoft.azure.functions.mysql.annotation.MySqlTrigger;
import com.function.Common.MySqlChangeProduct;
import com.google.gson.Gson;

import java.util.logging.Level;

public class ProductsTrigger {
    @FunctionName("ProductsTrigger")
    public void run(
            @MySqlTrigger(
                name = "changes",
                tableName = "Products",
                connectionStringSetting = "MySqlConnectionString")
                MySqlChangeProduct[] changes,
            ExecutionContext context) {

        context.getLogger().log(Level.INFO, "MySql Changes: " + new Gson().toJson(changes));
    }
}

GitHub 存储库中提供了 Azure Database for MySQL 触发器的更多示例。

该示例引用 Product 数据库表：

DROP TABLE IF EXISTS Products;

CREATE TABLE Products (
  ProductId int PRIMARY KEY,
  Name varchar(100) NULL,
  Cost int NULL
);

通过向表添加一列，对数据库启用更改跟踪：

ALTER TABLE <table name>  
ADD COLUMN az_func_updated_at TIMESTAMP 
DEFAULT CURRENT_TIMESTAMP 
ON UPDATE CURRENT_TIMESTAMP;

Azure Database for MySQL 触发器绑定到 Product其中列出了对象。 每个对象都有两个属性：

• item：已更改的项。 项的结构遵循表架构。
• operation：可能的值为 Update 插入和更新。

以下示例演示在表中发生 Product 更改时调用的 PowerShell 函数。

以下示例是 function.json 文件中的绑定数据：

{
    "bindings": [
      {
        "name": "changes",
        "type": "mysqlTrigger",
        "direction": "in",
        "tableName": "Products",
        "connectionStringSetting": "MySqlConnectionString"
      }
    ],
    "disabled": false
  }

“配置”部分介绍了这些属性。

以下示例是 run.ps1 文件中函数的示例 PowerShell 代码：

using namespace System.Net

param($changes)
# The output is used to inspect the trigger binding parameter in test methods.
# Use -Compress to remove new lines and spaces for testing purposes.
$changesJson = $changes | ConvertTo-Json -Compress
Write-Host "MySql Changes: $changesJson"

GitHub 存储库中提供了 Azure Database for MySQL 触发器的更多示例。

该示例引用 Product 数据库表：

DROP TABLE IF EXISTS Products;

CREATE TABLE Products (
  ProductId int PRIMARY KEY,
  Name varchar(100) NULL,
  Cost int NULL
);

通过向表添加一列，对数据库启用更改跟踪：

ALTER TABLE <table name>  
ADD COLUMN az_func_updated_at TIMESTAMP 
DEFAULT CURRENT_TIMESTAMP 
ON UPDATE CURRENT_TIMESTAMP;

Azure Database for MySQL 触发器绑定到 Changes，这是一组对象。 每个对象都有两个属性：

• item：已更改的项。 项的结构遵循表架构。
• operation：可能的值为 Update 插入和更新。

以下示例演示在表中发生更改时调用的 Product JavaScript 函数。

以下示例是 function.json 文件中的绑定数据：

{
    "bindings": [
      {
        "name": "changes",
        "type": "mysqlTrigger",
        "direction": "in",
        "tableName": "Products",
        "connectionStringSetting": "MySqlConnectionString",
      }
    ],
    "disabled": false
  }

“配置”部分介绍了这些属性。

以下示例是文件中函数 index.js 的示例 JavaScript 代码：

module.exports = async function (context, changes) {
    context.log(`MySql Changes: ${JSON.stringify(changes)}`)
}

GitHub 存储库中提供了 Azure Database for MySQL 触发器的更多示例。

该示例引用 Product 数据库表：

DROP TABLE IF EXISTS Products;

CREATE TABLE Products (
  ProductId int PRIMARY KEY,
  Name varchar(100) NULL,
  Cost int NULL
);

通过向表添加一列，对数据库启用更改跟踪：

ALTER TABLE <table name>  
ADD COLUMN az_func_updated_at TIMESTAMP 
DEFAULT CURRENT_TIMESTAMP 
ON UPDATE CURRENT_TIMESTAMP;

Azure Database for MySQL 触发器绑定到一个名为 Product，其中列出了对象的变量。 每个对象都有两个属性：

• item：已更改的项。 项的结构遵循表架构。
• operation：可能的值为 Update 插入和更新。

以下示例演示在表中发生更改时调用的 Product Python 函数。

import json
import logging
import azure.functions as func

app = func.FunctionApp()

# The function is triggered when a change (insert, update)
# is made to the Products table.
@app.function_name(name="ProductsTrigger")
@app.mysql_trigger(arg_name="products",
table_name="Products",
connection_string_setting="MySqlConnectionString")

def products_trigger(products: str) -> None:
logging.info("MySQL Changes: %s", json.loads(products))

{
    "bindings": [
      {
        "name": "changes",
        "type": "mysqlTrigger",
        "direction": "in",
        "tableName": "Products",
        "connectionStringSetting": "MySqlConnectionString"
      }
    ],
    "disabled": false
  }

import json
import logging

def main(changes):
    logging.info("MySql Changes: %s", json.loads(changes))

在 Java 函数运行时库中，对 @MySQLTrigger 其值来自 Azure Database for MySQL 的参数使用注释。 此批注支持以下元素：

下表介绍了在 function.json 文件中设置的绑定配置属性：