无服务器 WebSockets - 找不到与 http 方法 POST 的路由 @connections/* 匹配的方法

Question

我使用无服务器框架来托管我的 WebSocket，它具有典型的 $connect、$disconnect、$default 等方法来更新我的连接数据库：

case '$connect':
  await dynamoDb.put({
    TableName: process.env.CONNECTIONS_TABLE,
    Item: {
      connectionId,
      // Expire the connection an hour later. This is optional, but recommended.
      // You will have to decide how often to time out and/or refresh the ttl.
      ttl: parseInt((Date.now() / 1000) + 3600)
    }
  }).promise();

我的 WebSocket 设置是：

WebSocket URL: wss://1111111111.execute-api.ap-southeast-2.amazonaws.com/dev/
Connection URL: https://1111111111.execute-api.ap-southeast-2.amazonaws.com/dev/@connections

我的 HTTP 设置是：

Invoke API at: https://222222222.execute-api.ap-southeast-2.amazonaws.com/dev/

我有一个广播函数，我用它来向连接发送数据，我用它来调用：

sls invoke --function broadcast --data '{ \"body\": \"Hello from server\" }'

源向每个连接发送一条消息，如请求参数中所提供：

async function sendMessage(connectionId, body) {
  try {
    await apig.postToConnection({
      ConnectionId: connectionId,
      Data: body
    }).promise();
  } catch (err) {
    // Ignore if connection no longer exists
    if(err.statusCode !== 400 && err.statusCode !== 410) {
      throw err;
    }
  }
}

async function getAllConnections(ExclusiveStartKey) {
  const { Items, LastEvaluatedKey } = await dynamoDb.scan({
    TableName: process.env.CONNECTIONS_TABLE,
    AttributesToGet: [ 'connectionId' ],
    ExclusiveStartKey
  }).promise();

  const connections = Items.map(({ connectionId }) => connectionId);
  if(LastEvaluatedKey) {
    connections.push(...await getAllConnections(LastEvaluatedKey));
  }
  return connections;
}

module.exports.handler = async function(event, context) {
  const { body } = event;
  const connections = await getAllConnections();

  await Promise.all(
    connections.map(connectionId => sendMessage(connectionId, body))
  );
}

可以建立连接（我可以连接到 WebSocket），但是当我尝试调用此函数时，我收到错误：

未找到与 http 方法 POST 的路由 @connections/ZE4SDfSJSwMCJ4g%3D 匹配的方法。

ZE4SDfSJSwMCJ4g

是我的connectionId，它存在于我的数据库中。我不确定此路由问题是否与我的 HTTP API 和 WebSocket API 指向不同的 API 网关 URL 有关？

我感谢您的帮助！

Answer 1

确保您的API网关管理配置中的端点与您的ws端点相同。

const agma = new AWS.ApiGatewayManagementApi({
  apiVersion: AGMA_VERSION,
  endpoint: WS_ENDPOINT // 1111111111.execute-api.ap-southeast-2.amazonaws.com/dev
})

Answer 2

我也遇到了网络套接字和谷歌云功能的问题。我认为这是因为 Web 套接字服务器处于睡眠状态并且没有主动监听，因为它是无服务器的。

函数被配置为在http请求（端口80/443）上唤醒并返回睡眠状态，因此需要对它们进行特殊配置以在Web套接字端口上的请求上唤醒。

这似乎可以使用无服务器 websockets 插件https://github.com/serverless/serverless-websockets-plugin有一篇如何文章https://www.serverless.com/blog/api-gateway- websockets-示例

Answer 3

当我开始在 AWS 上使用自定义域时，我遇到了同样的错误。自定义域不需要最后添加阶段。从网址中删除舞台就可以正常工作了。

自定义域，我使用的是

https://mywebsite.com

，当我们附加舞台时，它就像

https://mywebsite.com/dev

。然后我得到了上面的错误。移除舞台解决了问题。