• 处理 Java AWS Lambda 的关闭（aws cognito java）
• @aws-sdk/client-lambda] - 调用 Lambda - Unit8Array 中的有效负载响应 - 转换为字符串
• AWS API 网关 + SQS + Lambda + 将响应从 Lambda 返回到 API
• AWS CDK - 自定义 aws-lambda-nodejs 和 aws-lambda-python 使用的 Dockerfile
• AWS Kinesis Lambda DynamoDB我正在尝试使用以下代码通过 Lambda 函数从 Kinesis 摄取数据 DynamoDB

处理 Java AWS Lambda 的关闭（aws cognito java）

如何解决处理 Java AWS Lambda 的关闭

有没有办法挂钩 Lambda 的关闭？我正在打开一个数据库连接并想让它保持打开状态，但我想确保它在 Lambda 终止时关闭。

解决方法

@aws-sdk/client-lambda] - 调用 Lambda - Unit8Array 中的有效负载响应 - 转换为字符串

如何解决@aws-sdk/client-lambda] - 调用 Lambda - Unit8Array 中的有效负载响应 - 转换为字符串

我正在使用 @aws-sdk/client-lambda npm 包来调用 lambda。我有两个 Lambda。 Lambda A 和 Lambda B。Lambda A 正在尝试调用 Lambda B。

Lambda A 通过运行以下代码调用 Lambda B：

const { LambdaClient,InvokeCommand } = require(''@aws-sdk/client-lambda'');
module.exports = {
  getGitHubToken: async () => {
    const client = new LambdaClient({ region: process.env.REGION });
    const params = {
      FunctionName: process.env.GITHUB_TOKEN_FUNCTION,LogType: ''Tail'',Payload: '''',};
    const command = new InvokeCommand(params);
    try {
      const { Payload } = await client.send(command);
      console.log(Payload);
      return Payload;
    } catch (error) {
      console.error(error.message);
      throw error;
    }
  },};

来自 Lambda B 的预期响应应如下所示：

{
  statusCode: 200,body: JSON.stringify({
    token: ''123'',}),};

但是，Payload 看起来是从 console.log(Payload); 行返回的：

我查看了 AWS SDK Website，它看起来像 Payload 返回一个 Uint8Array。我猜这是因为它来自一个承诺？

我曾尝试执行 Payload.toString()，但是它返回的只是 Unit8Array 中的值的字符串。例如：

2021-04-13T14:32:04.874Z worker:success Payload: 123,34,115,116,97,117,67,111,100,101,58,50,48,44,98,121,123,92,107,110,103,104,95,114,51,65,109,99,122,86,85,74,66,52,90,68,57,118,119,71,75,79,69,72,125,125

我的问题：

如何将 Unit8Array 中的数据解析为我期望从 Lambda 响应中获得的数据？哪个是 JSON 对象？

我已通过转到 CloudWatch 确认请求的 Lambda（在本例中为 Lambda B）正确返回数据。谢谢。

解决方法

const asciiDecoder = new TextDecoder(''ascii'');

const data = asciiDecoder.decode(Payload);

AWS API 网关 + SQS + Lambda + 将响应从 Lambda 返回到 API

如何解决AWS API 网关 + SQS + Lambda + 将响应从 Lambda 返回到 API

我想使用 API Gateway 向 SQS 发送消息，然后需要触发 Lambda。在 Lambda 中完成计算后，我需要将结果传回 API Gateway。换句话说，是这样的：

Get request --> Gateway API --> SQS --> Lambda --> (back to the same SQS?) -->  Gateway API

我已经设置了所有必要的权限，这意味着我可以调用网关 API 并向 SQS 发送消息，然后 SQS 将其发送给 Lambda（我可以在 Cloudwatch 中看到 Lambda 收到了消息）。但是，我无法将 Lambda 响应返回给网关 API...

有人对此有一些建议/教程/博客文章吗？我观看了各种 YouTube 视频并搜索了 SO 上的帖子，但没有找到解决我的问题的方法。

解决方法

AWS CDK - 自定义 aws-lambda-nodejs 和 aws-lambda-python 使用的 Dockerfile

如何解决AWS CDK - 自定义 aws-lambda-nodejs 和 aws-lambda-python 使用的 Dockerfile

是否可以将包 Dockerfile 使用的 aws-lambda-nodejs/aws-lambda-python 更改为包依赖项？

我目前的问题是我们在 CI/CD 服务器上使用 aws-lambda-python，其中 RUN pip install --upgrade pip 由于服务器上的配置错误而失败。我们对服务器几乎没有控制，所以想单独构建我们自己的镜像来规避这个问题。

AWS Kinesis Lambda DynamoDB我正在尝试使用以下代码通过 Lambda 函数从 Kinesis 摄取数据 DynamoDB

    import boto3
    import datetime
    import base64
    import json
    
    def lambda_handler(event,context):
        try:
            dynamo_db = boto3.resource(''dynamodb'')
            table = dynamo_db.Table(''table'')
            for record in event["Records"]:
                encoded = record["kinesis"]["data"]
                decoded = json.loads(base64.b64decode(encoded).decode("utf-8"))
                for i in decoded:
                    record = i["demo-stream"]
                    for j in record:
                        data = {
                            ''timestamp'': ["timestamp"],''name'': ["name"],''age'': ["age"]
                        }
                        # table.put_item(Item=data)  
                        with table.batch_writer() as batch_writer:
                            batch_writer.put_item(Item=data)
        except Exception as e: 
            print(str(e))