Azure Functions 触发器和绑定概念

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# 独立辅助角色模型指南。

HTTP 触发器 (HttpTrigger) 是在名为 HttpExample 的函数的 Run 方法上定义的，该函数会写入由在 msg 参数上的 Queue 和 StorageAccount 属性定义的存储队列：

        [FunctionName("HttpExample")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req, 
            [Queue("outqueue"),StorageAccount("AzureWebJobsStorage")] ICollector<string> msg, 
            ILogger log)
        {

有关详细信息，请参阅 C# 进程内模型指南。

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

在 Functions 版本 3 的 Node.js 中，可以在代码所在的同一文件夹中的特定于函数的 function.json 文件中配置触发器和绑定。 有关详细信息，请参阅 Node.js 开发人员指南。

导出 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.' };
    },
});

此示例 function.json 文件定义 HTTP 触发器函数，该函数会返回 HTTP 响应并写入存储队列。

{
  "bindings": [
    {
      "type": "httpTrigger",
      "direction": "in",
      "authLevel": "function",
      "name": "input"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "myQueueItem",
      "queueName": "outqueue",
      "connection": "MyStorageConnectionAppSetting"
    }
  ]
}

导出 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 文件定义 HTTP 触发器函数，该函数会返回 HTTP 响应并写入存储队列。

{
  "bindings": [
    {
      "type": "httpTrigger",
      "direction": "in",
      "authLevel": "function",
      "name": "input"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "myQueueItem",
      "queueName": "outqueue",
      "connection": "MyStorageConnectionAppSetting"
    }
  ]
}

在 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.')

在 Python for Functions 版本 1 中，此示例 function.json 文件会定义一个 HTTP 触发器函数，该函数会返回 HTTP 响应并写入存储队列。

    {
      "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"
    }
  ]
}