Scala Kinesis应用接入AWS X-Ray无追踪数据问题求助

1. X-Ray Daemon地址配置问题 #

本地运行时X-Ray Daemon默认监听127.0.0.1:2000，但部署到AWS环境（EC2、ECS、EKS等）时，需根据Daemon的部署方式调整地址配置：

• 若Daemon与应用在同一EC2实例：默认127.0.0.1可正常使用，但需确认Daemon进程处于运行状态。
• 若Daemon为独立部署（如单独EC2实例）或Sidecar模式：需在应用中指定Daemon的访问地址，可通过两种方式实现：
  • 设置环境变量AWS_XRAY_DAEMON_ADDRESS为daemon-host-ip:2000
  • 代码中显式配置：

    import com.amazonaws.xray.AWSXRay
    import com.amazonaws.xray.config.DaemonConfiguration
    
    val daemonConfig = new DaemonConfiguration()
    daemonConfig.setDaemonAddress("your-daemon-ip:2000")
    AWSXRay.setGlobalDaemonConfig(daemonConfig)
    

2. Kinesis的X-Ray支持情况 #

Kinesis属于X-Ray支持的AWS服务范畴，可通过两种方式实现追踪：

• 若使用AWS SDK调用Kinesis：需集成X-Ray拦截器，以SDK v2为例：

  import software.amazon.awssdk.services.kinesis.KinesisClient
  import software.amazon.awssdk.xray.interceptors.TracingInterceptor
  
  val kinesisClient = KinesisClient.builder()
    .addInterceptor(TracingInterceptor.create())
    .build()
  

• 若使用手动埋点（如你代码中的beginSegment/beginSubsegment）：可将Kinesis操作逻辑包裹在自定义子段中，这种方式不受服务原生支持限制，只要埋点逻辑正确即可生成追踪数据。

3. 额外排查方向 #

• 确认X-Ray Daemon运行状态：查看Daemon日志，验证它是否在接收并上报追踪数据到X-Ray服务。
• 检查采样规则：X-Ray默认采样率为1%，可能你的请求未被采样。可通过代码强制设置全采样：

  import com.amazonaws.xray.strategy.sampling.LocalizedSamplingStrategy
  import java.io.File
  
  val samplingStrategy = new LocalizedSamplingStrategy(new File("sampling-rules.json"))
  AWSXRay.setGlobalSamplingStrategy(samplingStrategy)
  

  对应的sampling-rules.json内容：

  {
    "version": 2,
    "default": {
      "fixed_target": 10,
      "rate": 1.0
    }
  }
  

• 再次验证IAM权限：确保角色包含xray:PutTraceSegments和xray:PutTelemetryRecords权限（全权限角色默认包含，但可通过IAM控制台确认）。

内容的提问来源于stack exchange，提问作者Limey