Azure Function App 对 Webhook 的初始响应

Posted 2023-02-19

【中文标题】Azure Function App 对 Webhook 的初始响应

【英文标题】：Initial Response to Webhook from Azure Function App

【发布时间】：2020-04-12 14:37:52

【问题描述】：

我的函数应用中有一个 HTTP 触发函数 - 它由 Azure 逻辑应用中的 webhook 连接器调用。 Webhook 在逻辑应用程序中的工作方式是它们需要像"status:200" 这样的初始响应，它使逻辑应用程序进入睡眠状态，然后当“工作”完成时，callbackURL 被调用，然后逻辑应用程序恢复工作。我的问题是响应我的函数应用程序的初始响应。

如果您在 2 分钟内没有以 status:2** 响应 webhook，则 webhook 会“重试”，这会启动函数应用的新实例，这显然是有问题的。

所以我的代码看起来像这样

try 
 
     await function1() // this function runs more than 2 minutes

catch(err)

     context.log(err)

finally

     await function2() // this function returns to LogicApp via callbackurl

我尝试在 try 块中添加 context.res = status:200 并尝试创建一个内部包含 context.res = status:200 的单个函数，但是这些都不起作用。

如果我的函数运行时间不到 2 分钟，那么显然 webhook 不会重试，但是当它运行超过 2 分钟时它会失败。

我尝试基于本文中的“Webhook”设计进行构建

Calling Long Running Functions Azure

这些是我尝试过的组合：

try 
    context.bindings.res = status:202
    await function1()


try 
    context.res = status:202
    await function1()


try 
    await initialResponse(context)// function that has context.res=status:202 inside
    function1()


try 
    context.res = status:202
    context.done()
    await function1()
 // I added @UncleDave 's suggestion as well

try 
    await initialResponse(context)
    function1()

async function initialResponse(context)

    context.res = status:202
    context.done()
 // this attempt also just ended the function

【参考方案1】：

考虑创建第二个函数来处理长时间运行的操作，并更改当前函数以将请求放入队列并立即返回。

您的网络挂钩命中的 HTTP 触发器：

function.json

  "bindings": [
    
      "authLevel": "anonymous", // Don't do this - demonstration only.
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": [
        "post"
      ]
    ,
    
      "type": "http",
      "direction": "out",
      "name": "res"
    ,
    
      "type": "queue",
      "direction": "out",
      "name": "queue",
      "queueName": "process",
      "connection": "AzureWebJobsStorage"
    
  ]

index.js

module.exports = function (context, req) 
  context.log('Started processing a request.', req);

  context.done(null, 
    res:  status: 202 ,
    queue:  callbackUrl: req.body.callbackUrl, data: req.body.data 
  );
;

执行处理的队列触发器：

function.json

  "bindings": [
    
      "name": "item",
      "type": "queueTrigger",
      "direction": "in",
      "queueName": "process",
      "connection": "AzureWebJobsStorage"
    
  ]

index.js

module.exports = async function (context, item) 
    context.log('javascript queue trigger function started to process work item.', item);

    const data = await process(item.data);

    const request = require('request');

    await request.post(item.callbackUrl,  body: data, json: true );
;

function process(data) 
    // Some long running operation.
    return new Promise(resolve => 
        setTimeout(() => resolve( a: 'b', c: 'd' ), 5000);
    );

请注意，我在这里使用request，这是一个外部依赖项，您必须将其添加到您的package.json，但Node 内置的HTTP 客户端也可以正常工作。