java - AWS XRay - 请求期间无法开始名为 'AWSSecurityTokenService' : segment cannot be found, 的子分段

标签 java spring amazon-web-services amazon-dynamodb aws-xray

我正在尝试在新的 Spring Boot 应用程序中设置 AWS XRay。

我想在投入生产之前在本地进行测试。该应用程序在本地与 dynamoDB 客户端和 STS 一起运行,以承担调用 dynamo 的角色。

该服务启动正常,加载所有 bean,但是当我调用该服务时,它失败了

Failed to begin subsegment named 'AWSSecurityTokenService': segment cannot be found

当它尝试调用 dynamoDB 来保存项目时。我认为如果您添加了 aws-xray-recorder-sdk-aws-sdy 依赖项,那么像 AWSSecurityTokenService 这样的包会在请求期间自动获取上下文子段?我错过了什么?

我已将以下内容添加到 pom.xml:

    <!-- AWS XRay -->
      <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>com.amazonaws</groupId>
        <artifactId>aws-xray-recorder-sdk-bom</artifactId>
        <version>1.3.1</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>

    <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-xray-recorder-sdk-core</artifactId>
    </dependency>
    <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-xray-recorder-sdk-aws-sdk</artifactId>
    </dependency>
    <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-xray-recorder-sdk-aws-sdk-instrumentor</artifactId>
      <version>2.4.0</version>
    </dependency>
    <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-xray-recorder-sdk-aws-sdk-v2</artifactId>
      <version>2.4.0</version>
    </dependency>
    <dependency>
      <groupId>com.amazonaws</groupId>
      <artifactId>aws-xray-recorder-sdk-aws-sdk-v2-instrumentor</artifactId>
      <version>2.4.0</version>
    </dependency>

以及以下方面:

import java.util.HashMap;
import java.util.Map;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Component;

import com.amazonaws.xray.AWSXRay;
import com.amazonaws.xray.entities.Subsegment;

@Aspect
@Component
@Profile("!test")
public class XRayInspector {

    private static final Logger LOG = LoggerFactory.getLogger(XRayInspector.class);

    @Around("!execution(* com.things.service.config..*(..)) && " +
            "execution(* com.things.service.controller..*(..)) && " +
            "execution(* com.things.service.factory..*(..)) && " +
            "execution(* com.things.service.exceptions..*(..)) && " +
            "execution(* com.things.service.security..*(..)) && " +
            "execution(* com.things.service.model..*(..)) && " +
            "execution(* com.things.service.service..*(..))")
    public Object logExecutionTime(final ProceedingJoinPoint joinPoint) throws Throwable {
        return this.processXRayTrace(joinPoint);
    }

    protected Object processXRayTrace(final ProceedingJoinPoint pjp) throws Throwable {
        try {
            final Subsegment subsegment = AWSXRay.beginSubsegment(pjp.getSignature().getName());
            subsegment.setMetadata(generateMetadata(pjp, subsegment));
            return conditionalProceed(pjp);
        } catch (final Exception e) {
            AWSXRay.getCurrentSegment().addException(e);
            throw e;
        } finally {
            LOG.trace("Ending Subsegment");
            AWSXRay.endSubsegment();
        }
    }

    public static Object conditionalProceed(final ProceedingJoinPoint pjp) throws Throwable {
        if (pjp.getArgs().length == 0) {
            return pjp.proceed();
        } else {
            return pjp.proceed(pjp.getArgs());
        }
    }

    public static Map<String, Map<String, Object>> generateMetadata(final ProceedingJoinPoint pjp, final Subsegment subsegment) {
        final Map<String, Map<String, Object>> metadata = new HashMap<>();
        final Map<String, Object> classInfo = new HashMap<>();
        classInfo.put("Class", pjp.getTarget().getClass().getSimpleName());
        metadata.put("ClassInfo", classInfo);
        return metadata;
    }

}

最佳答案

有初始化代码吗?如果在请求实际进入启用 X-Ray 的服务之前进行 STS 调用(或在请求的带外),这将导致丢失上下文异常。我们建议忽略不属于请求路径的任何调用(使用未跟踪的 AWS 客户端)或将 AWS_XRAY_CONTEXT_MISSING 环境变量设置为 LOG_ERROR:

https://docs.aws.amazon.com/xray/latest/devguide/xray-sdk-java-configuration.html#xray-sdk-java-configuration-envvars

关于java - AWS XRay - 请求期间无法开始名为 'AWSSecurityTokenService' : segment cannot be found, 的子分段,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60809761/

相关文章:

spring - 范围 'session' 对当前线程无效;非法状态异常 : No thread-bound request found

java - 使用 spring ioc 可交换数据层

java - 从其余 Controller 方法请求 String [] + String 作为 Json

node.js - 如何处理集群中基于时间的事件?

javascript - MTurk : Posting experimental conditions simultaneously, 但只允许每个 worker 看到其中一个条件

java - wsimport 在将 wsdl 解析为 java 时抛出与包相关的错误

java - 如何将 Java8 流的元素添加到现有列表中

amazon-web-services - AWS 云信息 : How to fix "Api Event must reference an Api in the same template" error?

java - 在 OSGI 包中重用组件树?

java - 如何使用InputStream "efficiently"逐行读取文本文件?