从 AWS Api 与 HTTP 集成的网关中的 websocket 中提取 websocket 连接 ID 和其他详细信息

Question

我有一个 http 端点 https://websocketsample.free.beeceptor.com 以及 AWS 中用于 Websockets 的 API 网关，带有 $connect、$disconnect 和 $default 的路由，所有这些都与 HTTP 集成集成到 POST https://websocketsample.free.beeceptor.com 以便我可以捕获 http 请求。

当我用 wscat 测试它时

wscat -c wss://e96ypxXXXX.execute-api.eu-west-3.amazonaws.com/production

我可以看到在 HTTP 服务器（在我的例子中是 beeceptor）接收到的 HTTP 请求。问题是 $connect 和 $disconnect 在 POST 请求中没有任何负载，只有 http headers。示例：

当我 $connect 到 websocket 时，我得到

Request body: empty
Headers:
{
  "content-length": "0",
  "sec-websocket-extensions": "permessage-deflate; client_max_window_bits",
  "sec-websocket-key": "pTR36OHKUSk8cqBix8vJXA==",
  "sec-websocket-version": "13",
  "x-amzn-trace-id": "Root=1-605322fb-1e2b058363326df80a61df18",
  "x-forwarded-for": "185.153.165.121",
  "x-forwarded-port": "443",
  "x-forwarded-proto": "https",
  "user-agent": "AmazonAPIGateway_e96ypxXXXX",
  "x-amzn-apigateway-api-id": "e96ypxXXXX"
}

当我向 websocket 发送任何消息时，例如 {"action":"action1"} 我得到

Request body: {"action":"action1"}
Headers:
{
  "content-length": "20",
  "user-agent": "AmazonAPIGateway_e96ypxXXXX",
  "x-amzn-apigateway-api-id": "e96ypxXXXX",
  "content-type": "application/json; charset=UTF-8"
}

当我 $disconnect 网络套接字时，我得到

Request body: empty
Headers:
{
  "content-length": "0",
  "x-api-key": "",
  "x-forwarded-for": "",
  "x-restapi": "",
  "user-agent": "AmazonAPIGateway_e96ypxXXXX",
  "x-amzn-apigateway-api-id": "e96ypxXXXX"
}

如何获取连接 ID，以便我可以独立跟踪每个 websocket session？ 当我使用 lambda 对此进行测试时，请求有一个 requestContext，我可以在其中提取 connectionId 并使用 DynamoDb 来管理连接。 我不想使用 AWS Lambda，我已经有一个可以处理这个问题的 http back-end 服务。但是HTTP集成似乎并没有提供太多信息。

更新1：这篇文章或许可以解释一些原因https://docs.aws.amazon.com/apigateway/latest/developerguide/websocket-api-data-mapping.html 显然：

“AWS 管理控制台不支持 WebSocket APIs 的数据映射。您必须使用 AWS CLI、AWS CloudFormation 或 SDK 来配置数据映射。”

所以我可能需要在控制台外配置数据映射，并希望构建一个有意义的负载

更新 2：我已经按照 https://docs.aws.amazon.com/apigateway/latest/developerguide/websocket-api-data-mapping.html#websocket-mapping-request-parameters 添加了请求参数，但没有成功

$ aws --profile diegosasw apigatewayv2 update-integration --integration-id 3lppdXX --api-id oe9jal8gXX --request-parameters 'integration.request.header.connectionId'='context.connectionId'
{
    "ConnectionType": "INTERNET",
    "IntegrationId": "3lppdXX",
    "IntegrationMethod": "POST",
    "IntegrationType": "HTTP_PROXY",
    "IntegrationUri": "https://websocketsample.free.beeceptor.com/connections",
    "PassthroughBehavior": "WHEN_NO_MATCH",
    "PayloadFormatVersion": "1.0",
    "RequestParameters": {
        "integration.request.header.connectionId": "context.connectionId"
    },
    "TimeoutInMillis": 29000
}

连接请求仍然没有转发到具有 http headers 或任何地方的 connectionId 的 beeceptor，我不知道如何实现。

另外.. 我在创建 http 端点时在 API 网关 API Websocket 中发现了一个问题：

不是最直观的文档或用法。

解决方案：根据标记的答案，解决方案与 re-deploying 和 API 一样简单。请求参数将被正确转发。

"Items": [
        {
            "ConnectionType": "INTERNET",
            "IntegrationId": "okmv0au",
            "IntegrationMethod": "POST",
            "IntegrationType": "HTTP_PROXY",
            "IntegrationUri": "https://awswebsocket.free.beeceptor.com",
            "PassthroughBehavior": "WHEN_NO_MATCH",
            "PayloadFormatVersion": "1.0",
            "RequestParameters": {
                "integration.request.header.domainName": "context.domainName",
                "integration.request.header.stage": "context.stage",
                "integration.request.header.connectionId": "context.connectionId",
                "integration.request.header.messageId": "context.messageId"
            },
            "TimeoutInMillis": 29000
        }
    ]

Answer 1

您很可能忘记部署 API（路线 -> 操作 -> 部署 API）。 WebSocket APIs 仍然使用没有自动部署的旧控制台。

一试就成功

        {
            "ConnectionType": "INTERNET",
            "ContentHandlingStrategy": "CONVERT_TO_TEXT",
            "IntegrationId": "iasyqzb",
            "IntegrationMethod": "ANY",
            "IntegrationType": "HTTP_PROXY",
            "IntegrationUri": "[REDACTED]",
            "PassthroughBehavior": "WHEN_NO_MATCH",
            "PayloadFormatVersion": "1.0",
            "RequestParameters": {
                "integration.request.header.connectionId": "context.connectionId"
            },
            "TimeoutInMillis": 29000
        },

Headers:

connectionid: dL53oem8IAMCK9g=
host: [REDACTED]
sec-websocket-key: dJleaOF55APY+0K6bPJWmg==
sec-websocket-version: 13
user-agent: AmazonAPIGateway_fhyhvnschc
x-amzn-apigateway-api-id: fhyhvnschc
x-amzn-trace-id: Self=1-6067d697-7dc1eea10d51468c3adbbc80;Root=1-6067d697-048e3deb132e05d50553a29e
x-forwarded-for: [REDACTED]

从 AWS Api 与 HTTP 集成的网关中的 websocket 中提取 websocket 连接 ID 和其他详细信息

Extract websocket connection Id and other details from websocket in AWS Api Gateway with HTTP integration

http

websocket

aws-api-gateway