登录
首页 >  Golang >  Go问答

aws xray 和 golang http 调用

来源:stackoverflow

时间:2024-03-16 16:27:30 490浏览 收藏

在使用 AWS X-Ray 和 Go 语言进行 HTTP 调用时,您需要检测您的应用程序以在 Lambda 函数中创建子段。在您提供的代码片段中,缺少这一步,导致 X-Ray 无法收集数据。请按照 Lambda 文档中的说明进行检测,以便 AWS X-Ray Go SDK 可以创建子段并将其发送到 X-Ray 守护程序。

问题内容

我正在尝试在我的 go 应用程序上使用 awx xray 对服务进行 http 调用。我只是按照此操作,不确定是否错过了某些内容,https://docs.aws.amazon.com/xray/latest/devguide/xray-sdk-go-httpclients.html

我像这样进行 http 调用:

payloadstr, _ := json.marshal(dxpayload)

fmt.println("size: ", int(unsafe.sizeof(bytes.newbuffer(payloadstr))))

clambda = &http.client{}

//-------added xray here-------//
xray.client(clambda)

reqlambda, errreq := http.newrequest("post", lambdaurl, bytes.newbuffer(payloadstr))
if errreq != nil {
    log.fatal("request error: ", errreq)
    return
}

reqlambda.header.add("accept", "application/json;v=1")
reqlambda.header.add("cach-control", "no-cache")
reqlambda.header.add("content-type", "application/json")
reqlambda.header.add("authorization", "bearer " + devextoken.accesstoken)

resplambda, errresp := clambda.do(reqlambda)
if errresp != nil {
    log.fatal("status response error ", errresp)
    return
} else {

}

在我的 main.go 文件中,我在 func init() 中有这个

func init() {

    pconfig = createpconfig()

    //aws xray config
    ss, err := sampling.newlocalizedstrategyfromfilepath("xray.json")

    if err != nil {
        panic(err)
    }
    xray.configure(xray.config{
        samplingstrategy: ss,
    })
}

我的 xray.json 配置如下所示:

{
  "version": 1,
  "rules": [
    {
      "description": "ehb",
      "service_name": "ehb-kafka-push",
      "http_method": "*",
      "url_path": "/private/api/calllambda/*",
      "fixed_target": 0,
      "rate": 0.85
    }
  ],
  "default": {
    "fixed_target": 1,
    "rate": 0.1
  }
}

现在,当我启动我的应用程序时...我的 api 调用正在通过,但我在 aws xray 和本地 xray 守护程序上看不到任何内容,我只在日志中看到此内容:

2018-08-26T18:45:04-07:00 [Info] Initializing AWS X-Ray daemon 2.1.3
2018-08-26T18:45:04-07:00 [Debug] Listening on UDP 127.0.0.1:2000
2018-08-26T18:45:04-07:00 [Info] Using buffer memory limit of 163 MB
2018-08-26T18:45:04-07:00 [Info] 2608 segment buffers allocated
2018-08-26T18:45:04-07:00 [Debug] Fetch region us-east-1 from commandline argument
2018-08-26T18:45:04-07:00 [Info] Using region: us-east-1
2018-08-26T18:45:04-07:00 [Debug] ARN of the AWS resource running the daemon: 
2018-08-26T18:45:04-07:00 [Debug] No Metadata set for telemetry records
2018-08-26T18:45:04-07:00 [Debug] Using Endpoint: https://xray.us-east-1.amazonaws.com
2018-08-26T18:45:04-07:00 [Debug] Telemetry initiated
2018-08-26T18:45:04-07:00 [Debug] Using Endpoint: https://xray.us-east-1.amazonaws.com
2018-08-26T18:45:04-07:00 [Debug] Batch size: 50
2018-08-26T18:46:04-07:00 [Debug] Skipped telemetry data as no segments found
2018-08-26T18:47:04-07:00 [Debug] Skipped telemetry data as no segments found
2018-08-26T18:48:04-07:00 [Debug] Skipped telemetry data as no segments found

我在这里缺少什么?除了 x 射线部分之外,一切似乎都正常,为什么我没有收到任何数据或错误?


解决方案


在 Lambda 场景中,Lambda 负责创建分段,而 AWS X-Ray Golang SDK 仅创建子分段然后发出它们。根据您的代码片段,您没有找到使用 X-Ray Go SDK API 检测应用程序以在 Lambda 函数内生成子段的代码。我在此处附加了一个链接,您可以在其中找到如何检测您的应用程序:lambdadocs

本篇关于《aws xray 和 golang http 调用》的介绍就到此结束啦,但是学无止境,想要了解学习更多关于Golang的相关知识,请关注golang学习网公众号!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>