AWS Websocket API

Question

我正在使用 API 网关 Websocket。

当我从 Lambda 函数向客户端发送消息时，它有时不发送消息，有时会发送 2-3 条消息。

const AWS = require("aws-sdk")

const api = new AWS.ApiGatewayManagementApi({
    endpoint : process.env.API_ENDPOINT
})

exports.handler = async (event) => {
    console.log(event)
    const body = JSON.parse(event.body)
    const connectionId = event.requestContext.connectionId

    sendMessage(connectionId, "My Message")

    return {}
};

const sendMessage = (connectionId, response) => {
    const data = { message : response }

    const params = {
         ConnectionId : connectionId,
         Data : Buffer.from(JSON.stringify(data))
    }

    return api.postToConnection(params).promise()
}

Answer 1

实际上我必须等待 sendMessage 函数。这解决了我的问题。