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函数。这解决了我的问题。