调用post_to_connection时Lambda超时

Question

我正在使用WebSocket ApiGateway和AWS Lambda集成。当我尝试使用post_to_connection方法boto3.client('apigatewaymanagementapi')向客户机发送数据时，Lambda函数总是超时而不会出现任何错误消息。只有超时消息才会登录到CloudWatch中：

import json
import boto3
import time
import urllib

api_client = boto3.client('apigatewaymanagementapi')

def lambda_handler(event, context):

    connectionId = event['requestContext']['connectionId']

    api_client.post_to_connection(ConnectionId=connectionId, Data=json.dumps({'test': '1'}))

    return {
        'statusCode': 200,
        'body': json.dumps('Hello from Lambda!')
        }

我做错了什么？

Answer 1

我发现这篇文章要求更清晰的boto3文档。事实证明，如果实例化apigatewaymanagementapi客户机，必须传递endpoint_url参数，但是如果不这样做，函数不会抛出任何错误。无论如何，api_client应该这样创建：

api_client = boto3.client('apigatewaymanagementapi',
endpoint_url='https://{api-id}.execute-api.{your-aws-region}.amazonaws.com/{stage}')

注意：不要将末尾带有'@connections'的url字符串传递给endpoint_url