你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

Azure Functions 触发器和绑定概念

本文概要介绍有关函数触发器和绑定的概念。

触发器会导致函数运行。 触发器定义函数的调用方式,一个函数必须刚好有一个触发器。 触发器还可以将数据传入函数,就像使用方法调用一样。

绑定到函数是一种以声明方式将函数连接到其他资源的方法;绑定将数据传入函数(输入绑定),或者允许使用绑定参数从函数(输出绑定)中写出数据。 函数触发器本质上是一种特殊的输入绑定类型。

可以混合搭配不同的绑定,以满足函数的特定方案。 绑定是可选的,一个函数可以有一个或多个输入绑定和/或输出绑定。

使用触发器和绑定可以避免对其他服务进行硬编码访问。 函数接收函数参数中的数据(例如,队列消息内容)。 使用函数的返回值发送数据(例如,用于创建队列消息)。

以下示例演示如何实现不同的函数。

示例方案 触发器 输入绑定 输出绑定
新的队列消息抵达,此时会运行一个函数来写入到另一个队列。 队列* 队列*
计划的作业读取 Blob 存储内容,并创建新的 Azure Cosmos DB 文档。 Timer Blob 存储 Azure Cosmos DB
事件网格用于读取 Blob 存储中的映像以及 Azure Cosmos DB 中的文档以发送电子邮件。 事件网格 Blob 存储和 Azure Cosmos DB SendGrid

* 表示不同的队列

这些示例并不详尽,旨在演示如何同时使用触发器和绑定。 有关更全面的方案集,请参阅 Azure Functions 方案

提示

Functions 不需要使用输入和输出绑定连接到 Azure 服务。 始终可以在代码中创建 Azure SDK 客户端,并将其用于数据传输。 有关详细信息,请参阅连接到服务

触发器和绑定的定义

函数具有单个触发器和一个或多个绑定。 绑定的类型是输入或输出。 并非所有服务都支持输入和输出绑定。 请参阅特定绑定扩展,了解特定绑定代码示例

触发器和绑定的定义根据开发语言的不同而异。 确保在文章顶部选择语言。

此示例显示了一个 HTTP 触发的函数,其中包含将消息写入 Azure 存储队列的输出绑定。

对于 C# 类库函数,触发器和绑定是通过使用 C# 属性修饰方法和参数配置的,其中应用的特定属性可能取决于 C# 运行时模型:

HTTP 触发器 (HttpTrigger) 是在 Run 方法上为返回 MultiResponse 对象的名为 HttpExample 的函数定义的:

[Function("HttpExample")]
public static MultiResponse Run([HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequestData req,
    FunctionContext executionContext)
{

此示例显示了 MultiResponse 对象定义,这两者都会向 HTTP 请求返回 HttpResponse,并使用 QueueOutput 绑定将消息写入存储队列:

public class MultiResponse
{
    [QueueOutput("outqueue",Connection = "AzureWebJobsStorage")]
    public string[] Messages { get; set; }
    public HttpResponseData HttpResponse { get; set; }
}

有关详细信息,请参阅 C# 独立辅助角色模型指南

旧 C# 脚本函数会使用 function.json 定义文件。 有关详细信息,请参阅 Azure Functions C# 脚本 (.csx) 开发人员参考

对于 Java 函数,触发器和绑定是通过批注特定方法和参数配置的。 此 HTTP 触发器 (@HttpTrigger) 是在名为 HttpTriggerQueueOutput 的函数的 run 方法上定义的,该方法会写入 message 参数上由 @QueueOutput 注释定义的存储队列:

@FunctionName("HttpExample")
public HttpResponseMessage run(
        @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) 
        HttpRequestMessage<Optional<String>> request, 
        @QueueOutput(name = "msg", queueName = "outqueue", 
        connection = "AzureWebJobsStorage") OutputBinding<String> msg, 
        final ExecutionContext context) {
    context.getLogger().info("Java HTTP trigger processed a request.");

有关详细信息,请参阅 Java 开发人员指南

为 Node.js 函数定义触发器和绑定的方式取决于 Functions 的特定版本的 Node.js:

在 Functions 版本 4 的 Node.js中,可以使用从 @azure/functions 模块导出的对象配置触发器和绑定。 有关详细信息,请参阅 Node.js 开发人员指南

此示例是一个 HTTP 触发的函数,它为收到的每个 HTTP 请求创建队列项。

导出 app 对象上的 http 方法会定义 HTTP 触发器,output 上的 storageQueue 方法会定义此触发器的输出绑定。

const { app, output } = require('@azure/functions');

const queueOutput = output.storageQueue({
    queueName: 'outqueue',
    connection: 'MyStorageConnectionAppSetting',
});

app.http('httpTrigger1', {
    methods: ['GET', 'POST'],
    authLevel: 'anonymous',
    extraOutputs: [queueOutput],
    handler: async (request, context) => {
        const body = await request.text();
        context.extraOutputs.set(queueOutput, body);
        return { body: 'Created queue item.' };
    },
});

导出 app 对象上的 http 方法会定义 HTTP 触发器,output 上的 storageQueue 方法会定义此触发器的输出绑定。

import { app, HttpRequest, HttpResponseInit, InvocationContext, output } from '@azure/functions';

const queueOutput = output.storageQueue({
    queueName: 'outqueue',
    connection: 'MyStorageConnectionAppSetting',
});

export async function httpTrigger1(request: HttpRequest, context: InvocationContext): Promise<HttpResponseInit> {
    const body = await request.text();
    context.extraOutputs.set(queueOutput, body);
    return { body: 'Created queue item.' };
}

app.http('httpTrigger1', {
    methods: ['GET', 'POST'],
    authLevel: 'anonymous',
    extraOutputs: [queueOutput],
    handler: httpTrigger1,
});

此示例 function.json 文件会定义函数:

    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "Request",
      "methods": [
        "get",
        "post"
      ]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "Response"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "msg",
      "queueName": "outqueue",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

有关详细信息,请参阅 PowerShell 开发人员指南

定义函数的方式取决于适用于 Functions 的 Python 版本:

在 Python for Functions 版本 2 中,使用修饰器直接在代码中定义函数。

app = func.FunctionApp(http_auth_level=func.AuthLevel.ANONYMOUS)

@app.route(route="HttpExample")
@app.queue_output(arg_name="msg", queue_name="outqueue", connection="AzureWebJobsStorage")
def HttpExample(req: func.HttpRequest, msg: func.Out [func.QueueMessage]) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')

向函数添加绑定

可以使用输入或输出绑定将函数连接到其他服务。 通过向函数添加绑定的具体定义来添加绑定。 若要了解如何操作,请参阅向 Azure Functions 中的现有函数添加绑定

Azure Functions 支持多个绑定,这些绑定必须正确配置。 例如,函数可以从队列(输入绑定)读取数据,并将数据同时写入数据库(输出绑定)。

支持的绑定

下表显示了 Azure Functions 运行时的主版本支持的绑定:

类型 1.x1 2.x 及更高版本2 触发器 输入 输出
Blob 存储
Azure Cosmos DB
Azure 数据资源管理器
Azure SQL
Dapr4
事件网格
事件中心
HTTP 和 Webhook
IoT 中心
Kafka3
移动应用
通知中心
队列存储
Redis
RabbitMQ3
SendGrid
服务总线
SignalR
表存储
计时器
Twilio

注意:

  1. 对 Azure Functions 运行时版本 1.x 的支持将于 2026 年 9 月 14 日结束。 强烈建议将应用迁移到版本 4.x 以获得完全支持。
  2. 从版本 2.x 运行时开始,除 HTTP 和 Timer 以外,必须注册所有绑定。 请参阅注册绑定扩展
  3. 消耗计划不支持触发器。 需要运行时驱动的触发器
  4. 仅 Kubernetes、IoT Edge 和其他自托管模式支持使用触发器。

有关哪些绑定处于预览状态或已批准在生产环境中使用的信息,请参阅支持的语言

仅在支持基础服务 SDK 时,才支持特定绑定扩展版本。 基础服务 SDK 版本中对支持的更改会影响对使用扩展的支持。

绑定代码示例

使用下表查找特定绑定类型的更多示例,这些示例演示如何在函数中使用绑定。 首先,选择与你的项目相对应的语言选项卡。

C# 的绑定代码取决于特定的进程模型

服务 示例 示例
Blob 存储 触发器
输入
输出
链接
Azure Cosmos DB 触发器
输入
输出
链接
Azure 数据资源管理器 输入
输出
链接
Azure SQL 触发器
输入
输出
链接
事件网格 触发器
输出
链接
事件中心 触发器
输出
IoT 中心 触发器
输出
HTTP 触发器 链接
队列存储 触发器
输出
链接
RabbitMQ 触发器
输出
SendGrid 输出
服务总线 触发器
输出
链接
SignalR 触发器
输入
输出
表存储 输入
输出
计时器 触发器 链接
Twilio 输出 链接
服务 示例 示例
Blob 存储 触发器
输入
输出
链接
Azure Cosmos DB 触发器
输入
输出
链接
Azure 数据资源管理器 输入
输出
链接
Azure SQL 触发器
输入
输出
事件网格 触发器
输出
链接
事件中心 触发器
输出
IoT 中心 触发器
输出
HTTP 触发器 链接
队列存储 触发器
输出
链接
RabbitMQ 触发器
输出
SendGrid 输出
服务总线 触发器
输出
链接
SignalR 触发器
输入
输出
表存储 输入
输出
计时器 触发器 链接
Twilio 输出 链接
服务 示例 示例
Blob 存储 触发器
输入
输出
链接
Azure Cosmos DB 触发器
输入
输出
链接
Azure 数据资源管理器 输入
输出
Azure SQL 触发器
输入
输出
链接
事件网格 触发器
输出
链接
事件中心 触发器
输出
IoT 中心 触发器
输出
HTTP 触发器 链接
队列存储 触发器
输出
链接
RabbitMQ 触发器
输出
SendGrid 输出
服务总线 触发器
输出
链接
SignalR 触发器
输入
输出
表存储 输入
输出
计时器 触发器 链接
Twilio 输出 链接
服务 示例 示例
Blob 存储 触发器
输入
输出
链接
Azure Cosmos DB 触发器
输入
输出
链接
Azure SQL 触发器
输入
输出
事件网格 触发器
输出
链接
事件中心 触发器
输出
IoT 中心 触发器
输出
HTTP 触发器 链接
队列存储 触发器
输出
链接
RabbitMQ 触发器
输出
SendGrid 输出
服务总线 触发器
输出
链接
SignalR 触发器
输入
输出
表存储 输入
输出
计时器 触发器 链接
Twilio 输出 链接

Python 的绑定代码取决于 Python 模型版本。

服务 示例 示例
Blob 存储 触发器
输入
输出
链接
Azure Cosmos DB 触发器
输入
输出
链接
Azure 数据资源管理器 输入
输出
Azure SQL 触发器
输入
输出
链接
事件网格 触发器
输出
链接
事件中心 触发器
输出
IoT 中心 触发器
输出
HTTP 触发器 链接
队列存储 触发器
输出
链接
RabbitMQ 触发器
输出
SendGrid 输出
服务总线 触发器
输出
链接
SignalR 触发器
输入
输出
表存储 输入
输出
计时器 触发器 链接
Twilio 输出 链接

自定义绑定

可以创建自定义输入和输出绑定。 绑定必须以 .NET 编写,但可以在任何支持的语言中使用。 有关创建自定义绑定的详细信息,请参阅创建自定义输入和输出绑定