AWS Lambda 上的 Slack 斜杠命令延迟响应

Question

我正在尝试为 Slack 进行集成，以查询服务器并将一些结果返回给用户。搜索有时需要比 Slack 允许响应的窗口更长的时间，所以我需要立即返回状态 200。

如何使用 lambda 函数做到这一点？我尝试使用回调函数，然后将数据发送到另一个 lambda 服务，但原始函数等待它返回，这意味着我仍然被正在查询的服务器阻止。

这就是我正在使用的东西

var rp = require('request-promise');

exports.handler = (event, context, callback) =>{
  //I wanted this to send back my STATUS 200 so the command wouldn't time out
  callback(null, "Working...");
	
  //I want this post to happen asynchronously so that slack gets the callback response while the search is happening
  //but this still waits until the post comes back before resolving the callback
  var options = {
    method: 'POST',
    uri: "https://url-to-other.service",
    body:{
    	"team": event.team,
    	 "label": event.label,
    	 "url": event.aresponse_url
    },
    json:true
  };
  rp(options);
};

当我运行这个时，回调文本显示在另一个函数的结果之后，这意味着这个服务在返回状态之前正在等待另一个停止运行。

Answer 1

这在单个 lambda 函数中不起作用，因为一旦您调用 callback()，lambda 容器就会死掉。你可以做的是让这个 lambda 函数 invoke another lambda function before 调用 callback() 这反过来将 POST 到你的松弛通道 url。

这是一个如何工作的示例（它不是 100%，但应该让您很好地了解它是如何工作的。）

函数1：（接收slack事件，调用第二个函数，立即返回200

let AWS = require('aws-sdk')
exports.handler = (event, context, callback) => {
    let lambda = new AWS.Lambda()
    let params = {
        FunctionName: 'YOUR_SECOND_FUNCTION_NAME',
        InvocationType: 'Event', // Ensures asynchronous execution
        Payload: JSON.stringify({
            team: event.team,
            label: event.label,
            url: event.aresponse_url
        })
    }
    return lambda.invoke(params).promise() // Returns 200 immediately after invoking the second lambda, not waiting for the result
    .then(() => callback(null, 'Working...'))
}

函数 2：（接收第一个 lambda 事件，等待搜索完成，POST 到 slack 通道）

let rp = require('request-promise')

exports.handler = (event, context, callback) => {
    let searchOptions = {
        method: 'POST',
        uri: 'https://url-to-other.service',
        body: {
            'team': event.team,
            'label': event.label,
            'url': event.aresponse_url
        },
        json:true
    }
    return rp(searchOptions)
    .then(result => {
        let slackOptions = {
            method: 'POST',
            uri: 'YOUR_SLACK_CHANNEL_URL',
            body: {
                text: JSON.stringify(result) // I stringified the search result for you for ease's sake, not sure what you need here
            },
            json: true
        }
        return rp(slackOptions)
    })
    .then(() => { callback(null, 'good measure') })
}