AWS API Gateway Websockets——connectionID 在哪里？

Question

我正在 $connect 路由上设置一个带有自定义授权方的 AWS API Gateway Websockets，如下所述：

https://docs.aws.amazon.com/apigateway/latest/developerguide/apigateway-websocket-api-route-keys-connect-disconnect.html

我的问题是——我如何获得 connectionID，即我可以用来稍后向连接的客户端广播的标识符？

Answer 1

要向集成请求添加内容，您需要使用请求模板。

1. 为您的路由关闭 HTTP 代理集成。 （否则您无法修改请求。）
2. 保存您的更改。 （在您这样做之前，“请求模板”部分不会出现。）
3. 设置您的模板选择表达式。这用于从传入的请求对象中查找值。 （如果要匹配所有传入请求，请输入 \$default。注意斜线。完整文档 here。）
4. 设置您的模板密钥。这与模板选择表达式选择的值进行比较。如果匹配，则使用模板。 （如果要匹配所有传入请求，请输入 $default。注意没有斜杠。）
5. 单击您的模板键以打开模板编辑器。您可以在此处输入模板，该模板将作为请求正文发送到您的集成端点。例如，如果您想将连接 ID 和传入的查询参数转发到集成端点，您可以使用以下内容：

{
    "myConnectionIdProperty": "$context.connectionId",
    "myQueryParams": $input.params()
}

模板表达式中可用的变量的文档可以在here找到。

（请注意，虽然$request 是模板选择表达式中的有效变量，但它不是模板本身的有效变量。在此处使用$input。）

Answer 2

感谢大家尝试记录 AWS API Gateway。

为了能够使用 VPC Link 将数据从 AWS Websocket API Gateway 发送到您的集成服务，请执行以下操作：

1. 取消选中使用代理集成

2. 保存

3. 如下图设置请求模板：

4. 这将允许在请求正文中获取 connectionId、查询、正文。

5. 保存

6. 点击右上角的添加集成响应

7. 设置集成响应，如下图所示：

8。希望它会奏效。如果没有，请通过测试找出答案，然后在此处为其他人提供答案。谢谢。

我建议忘记任何其他类型的集成，只使用 lambda。因为您将面临的下一个问题是在断开连接的集成中获取连接时传递的查询参数。

Answer 3

这里的问题是当使用 HTTP 作为集成类型时——即，当调用一个或多个 API GW 路由 ($connect/$disconnect/$invoke) 时会命中 http 端点。我们发现我们无法代理请求（这意味着我们丢失了原始标头，包括身份验证），但是如果我们需要连接 id，我们必须指定一个请求模板并使用类似的东西：

{"connectionId": "$context.connectionId", "body": "$input.body"}

Answer 4

该问题未指定使用哪种类型的后端。 AWS API Gateway 的 AWS 文档是针对 lambda 函数的——我找不到任何帮助来获取我的 http 后端的 connectionId。

尝试 Big Endian 的答案，我发现了一些问题 - 我的 cakephp 后端无法解码引用的 json 正文。我找到了解决方案，但是实现他的答案还需要许多其他步骤，所以它们是：

我在关闭 HTTP 代理的情况下创建了一个路由键，并设置了一个请求模板如下（也是非常稀疏的文档）：

• 路由选择表达式：$request.body.action

• 路由键：订阅
  这意味着所有带有 {"action": "subscribe"} 的请求都会经过这里

• 集成请求类型：HTTP

• HTTP 代理集成：关闭 - 到标头或身份验证通过
• HTTP 方法：POST

然后是困难的部分：设置请求模板。我希望所有“订阅”请求都使用这个模板，我发现这样做的唯一方法是将模板选择表达式设置为与路由选择表达式相同：$request.body.action，并将模板键设置为“订阅” ”。

它最终是对 API 应用此模板必须执行的相同内容的双重测试 - 如果有人有更好的方法，请发表评论。

最后一步是将其作为“订阅”的“生成模板”输入：

{"connectionId": "$context.connectionId", "body": $input.body}

请注意，在我的例子中，我的正文是 json 并且 $input.body 不在引号中 - 正文 json 被模板扩展。我想如果正文只是一个字符串，那么模板将是

{"connectionId": "$context.connectionId", "body": "$input.body"}

但是路由永远不会到达这里，因为路由需要 body 来包含 json 中的操作键。

Answer 5

要解决此问题，请转到您的 AWS 控制台 -> 打开您的 AWS CloudShell（控制面板右上角）

对于使用HTTP_PROXY的WebSocket服务器，需要修改@connect路由添加connectionId

1- 在shell中输入：

# List all integrations

aws apigatewayv2 get-integrations --api-id xxxxxxxxx

# Update all @connect integration

aws apigatewayv2 update-integration --integration-id zzzzzzzz --api-id xxxxxxxxx --request-parameters 'integration.request.header.connectionId'='context.connectionId'

2- 之后不要忘记部署，否则将无法正常工作

为什么 AWS 不为您提供 connectionId？因为他们希望你使用 Lambda。

Answer 6

非常感谢 Francois Stark，非常有帮助。

通过我自己的实验，我发现您可以避免使用 $default 路由和以下格式来匹配 $request.body.action 的特定值：

• 模板选择表达式：\$default
• 模板键：\$default
• 生成模板

{"connectionId": "$context.connectionId", "body": $input.body}

使用此配置，您的 HTTP 端点应该使用单个路由在“action”的所有值中获取 connectionID 作为正文数据。

另外，获取$connect和$disconnect路由中的connectionID，Request Template的格式是一样的，但是由于这些事件中没有body数据，所以可以省略body：

• 模板选择表达式：\$default
• 模板键：\$default
• 生成模板

{"connectionId": "$context.connectionId"}

使用此配置，您的 HTTP 端点应该在 $connect 和 $disconnect 事件中获取 connectionID 作为正文数据。

Answer 7

您可以从上下文变量中获取 connectionId。有关 WebSocket API 的可用变量，请参阅此： https://docs.aws.amazon.com/apigateway/latest/developerguide/apigateway-websocket-api-mapping-template-reference.html

在 Lambda 函数中，您可以通过 event.requestContext 访问上下文变量。

Answer 8

您可以从 event.requestContext 中获取 connectionId。

exports.handler = async (event) => {
const data = event['body'];
const connectionId = event['requestContext']['connectionId'];};