如何使用AWS X-Ray跟踪lambda调用lambda？

Question

我有一个由API网关事件触发的AWS Lambda函数。API网关配置为使用X射线。

由于Lambda跟踪配置默认为PassTrough，因此它也会显示在X射线中(服务映射等)。

被调用的lambda使用node.js aws-sdk来调用另一个Lambda。如果我理解正确的话，为了在X-Ray中显示这个Lambda，必须将跟踪ID传递给下一次调用。在API of the SDK中，我找不到解决此问题的选项。

const result = await lambda
        .invoke(lambdaParamsCreateUser)
        .promise()

我如何才能做到这一点？我如何跟踪原始请求的调用？

根据@Balu Vyamajala的提示，我将AWS-SDK导入更改为：

import AWS from "aws-sdk";

import AwsXRay from "aws-xray-sdk-core";
const aws = AwsXRay.captureAWS(AWS);
export default aws;

我在开具第二个函数的发票时使用它，如下所示：

import AWS from "aws";
const Lambda = AWS.Lambda;
// ...
const lambda = new Lambda({ region: "eu-central-1" });
const lambdaPromise = lambda
        .invoke({
            FunctionName: AUTH_CREATE_USER_FUNC,
            InvocationType: "RequestResponse",
            Qualifier: AUTH_CREATE_USER_FUNC_VERSION,
            Payload: JSON.stringify({
                eMail: eMail,
                device: device,
                customerId: customerId,
            }),
            LogType: "Tail",
        })
        .promise()

但在X-Ray中没有调用链:-(

https://imgur.com/wDMlNzb

我做错了吗？

Answer 1

如果我们为两个Lambda函数都启用了X-Ray，trace-id就会自动传递，并且对于两个Lambda都是一样的。

在代码中，我们可以简单地通过包装aws-sdk来启用X-Ray

JavaScript：

const AWSXRay = require("aws-xray-sdk-core");
const AWS = AWSXRay.captureAWS(require("aws-sdk"));    

打字：

import AWSXRay from 'aws-xray-sdk';
import aws from 'aws-sdk';
const AWS = AWSXRay.captureAWS(aws)

这里有一个样本测试来确认。

balu-测试>>样本-测试

Lambda 1 (balu-test)：

const AWSXRay = require("aws-xray-sdk-core");
const AWS = AWSXRay.captureAWS(require("aws-sdk"));    
const lambda = new AWS.Lambda();

exports.handler = async function (event, context) {
  var params = {
    FunctionName: "sample-test",
    InvocationType: "RequestResponse",
    Payload: '{ "name" : "foo" }',
  };
  
  const response = await lambda.invoke(params).promise();
  console.log('response',response);

  return "sucess";
};

Lambda 2(样本测试)：

const AWSXRay = require("aws-xray-sdk-core");
const AWS = AWSXRay.captureAWS(require("aws-sdk"));    
let region = "us-east-1"
let secretName = "SomeSecret"
let secret
let decodedBinarySecret    
var client = new AWS.SecretsManager({
  region: region,
});

exports.handler = (event, context, callback) => {
  client.getSecretValue({ SecretId: secretName }, function (err, data) {
    if (err) {
      callback(err);
    } else {
      if ("SecretString" in data) {
        secret = data.SecretString;
      } else {
        let buff = new Buffer(data.SecretBinary, "base64");
        decodedBinarySecret = buff.toString("ascii");
      }
      callback(null, secret);
    }
  });
};

对于两个Lambda调用，TraceId是相同的，并且X射线指向相同的图形。当从Api-Gateway调用第一个api时，也会发生同样的事情。第一次跟踪-id被生成并作为http报头被传递到下游进程。

​

​

​

​