可扩展的AWS API网关Websocket广播？

Question

在我们的可扩展AWS无服务器应用程序（DynamoDB，Lambda，API网关Websockets）中，我们希望将消息从lambda传播到许多连接的浏览器会话。

我们有许多主题，并且为了限制系统的负载，我们要限制每个浏览器会话以订阅Max。两个主题。

此是否通过循环浏览连接ID并为每个连接进行等待后连接，因为每个后连接都需要40 ms（平均）：

const AWS = require('aws-sdk');
const ddb = new AWS.DynamoDB.DocumentClient();

exports.handler = async function (event, context) {
  let connections;
  try {
    connections = await ddb.scan({ TableName: process.env.table }).promise();
  } catch (err) {
    return {
      statusCode: 500,
    };
  }
  const callbackAPI = new AWS.ApiGatewayManagementApi({
    apiVersion: '2018-11-29',
    endpoint:
      event.requestContext.domainName + '/' + event.requestContext.stage,
  });

  const message = JSON.parse(event.body).message;

  const sendMessages = connections.Items.map(async ({ connectionId }) => {
    if (connectionId !== event.requestContext.connectionId) {
      try {
        await callbackAPI
          .postToConnection({ ConnectionId: connectionId, Data: message })
          .promise();
      } catch (e) {
        console.log(e);
      }
    }
  });

  try {
    await Promise.all(sendMessages);
  } catch (e) {
    console.log(e);
    return {
      statusCode: 500,
    };
  }

  return { statusCode: 200 };
};

我们如何使此广播可扩展？