异步调用触发aws lambda两次

Question

我有一个聊天应用程序，当我在输入消息后单击按钮时，消息会发布到我的DynamoDB表中。该应用程序应该发布一次消息，但不知何故发布了两次。

管道如下：

客户端单击“发送”按钮--

在SO的帮助下，我已经将问题隔离到我的Google Cloud函数异步调用Lambda，该函数将Lambda排队两次。

使用async，请求在实际执行之前排队。所以，如果您调用它一次，AWS将检查是否已经有一个正在执行，如果没有，它将添加另一个。

理想情况下，我希望同步调用Lambda，但根据这篇Github帖子，我会收到两次账单（？）。他提到增加了我函数的超时时间，但它已经设置为60秒了——我的lambda有足够的时间发回响应。有没有其他机制让我的lambda排队两次？

供您参考，我的谷歌云功能如下：

let AWS = require('aws-sdk');

AWS.config.update({
  accessKeyId: ''
  secretAccessKey: ''
  region: ''
})

let lambda = new AWS.Lambda();

exports.helloWorld = async (req,res) =>{
  let payload = {
    pathParameters: req.query.p,
    httpMethod: req.method,
    body: req.method == "POST" ? req.body.message || req.body.user : null,
    cognitoUsername: req.query.u
  }

  let params = {
    FunctionName: '',
    InvocationType: 'RequestResponse',
    Payload: JSON.stringify(payload)
  }

  res.status(200).send( await lambda.invoke(params, function(err,data){
    if (err){throw err}
    else {return data.Payload}
  }).promise())
}

解决方案：

基于@jarmod的解决方案，我的云功能如下所示。相关部分在最后。

let AWS = require('aws-sdk');

AWS.config.update({
  accessKeyId: ''
  secretAccessKey: ''
  region: ''
})

let lambda = new AWS.Lambda();

exports.helloWorld = async (req,res) =>{
  let payload = {
    pathParameters: req.query.p,
    httpMethod: req.method,
    body: req.method == "POST" ? req.body.message || req.body.user : null,
    cognitoUsername: req.query.u
  }

  let params = {
    FunctionName: '',
    InvocationType: 'RequestResponse',
    Payload: JSON.stringify(payload)
  }

  // code changed only here
  res.status(200).send( await lambda.invoke(params).promise())
}

编辑：

@Ngenator提醒我，我的Google云功能可能会被触发两次。作为参考，这是我的API yaml配置：

swagger: '2.0'
info:
  title: Cloud Endpoints + GCF
  version: 1.0.0
host: service.run.app
x-google-endpoints:
  - name: "service.run.app"
    allowCors: "true"
schemes:
  - https
produces:
  - application/json
paths:
  /function-2:
    get:
      operationId: get 
      parameters:
        - name: p
          in: query
          required: true
          type: string
        - name: u
          in: query
          required: false
          type: string
      x-google-backend:
        address: https://to.my/function-2
      responses:
        '200':
          description: A successful response
          schema:
            type: string
    post:
      operationId: post 
      consumes:
        - application/json
      parameters:
        - name: p
          in: query
          required: true
          type: string
        - name: u
          in: query
          required: false
          type: string
        - in: body
          name: body
          schema:
            type: object
            properties:
              message:
                type: string
              user:
                type: array
                items:
                  type: string
      x-google-backend:
        address: https://to.my/function-2
      responses:
        '200':
          description: A successful response
          schema:
            type: string

Answer 1

您对lambda.invoke的调用不正确。它包括回调和等待promise。您应该使用其中一个，最好是后者：

const rc = await lambda.invoke(params).promise();