Как использовать AWS X-Ray в NodeJs? - PullRequest
Новая
       32

Как использовать AWS X-Ray в NodeJs?

0 голосов
/ 15 ноября 2018

Я пытаюсь использовать aws-xray-sdk для получения следов моего приложения,
Я написал три API,
1. Выполнение вызова службы AWS S3 ( / traceS3)
2. Выполнение HTTP-вызова к внешней конечной точке, т.е.google.com ( / traceHttp )
3. Выполнение вызова БД для локально установленной БД MySql ( / traceMysql )

Также установлен AWS X-Ray Daemon локально
И сделал конфигурации AWS, используя aws-cli, а затем запустил демон, используя следующую команду (я использую Ubuntu) - 

/usr/bin/xray -o -n ap-southeast-2

Я имею в виду следующие ресурсы -
1. разрывы трассировки рентгеновских лучей aws для исходящих запросов в Node.js
2. https://docs.aws.amazon.com/xray/latest/devguide/xray-sdk-nodejs-httpclients.html

Демон успешно работает, но не отправляет данные для всех API,
Он только отправляет данные для /traceS3 и /traceMysql API.

Ниже приводитсятекущий код - 

var AWSXRay = require('aws-xray-sdk');
var AWS = AWSXRay.captureAWS(require('aws-sdk'));
var mysql = AWSXRay.captureMySQL(require('mysql'));

var express = require('express');
var app = express();

var http = AWSXRay.captureHTTPs(require('http'));
app.use(AWSXRay.express.openSegment('X-Ray-Node-Example'));

AWS.config.update({region: 'ap-southeast-2'});
s3 = new AWS.S3({apiVersion: '2006-03-01'});

var con = mysql.createConnection({
    host: "localhost",
    user: "root",
    password: "root",
    database: "nodejs",
    port: 3306
});

con.connect(function (err) {
    if (err) throw err

});

app.get('/traceS3', function(req,res){

    // Call S3 to list current buckets
    s3.listBuckets(function(err, data) {
        if (err) {
            console.log("Error", err);
            res.send(err);
        } else {
            res.send(data.Buckets);
        }
    });
});

app.get('/traceHttp', function (req, res) {
    console.log("traceHttp called!\n"+req);

    http.get("http://jsonplaceholder.typicode.com/todos/1", (resp) => {
        console.log(resp);
        res.send("googlefetched")
    });
});

app.get('/traceMysql', function (req, res) {
    console.log("traceMysql called!\n"+req);

    var start = Date.now();

    var query = con.query('SELECT * FROM customer', function (err, rows, fields) {
        if (err) {
            console.log("Error Selecting : %s ", err);
        }
        else {
            var resp = [];
            function Person(id, name) {
                this.id = id;
                this.name = name;
            }

            for (var i = 0; i < rows.length; i++) {
                var id = rows[i].id;
                var name = rows[i].name;
                resp.push(new Person(id, name));
            }
            var end = Date.now();
            res.send(JSON.stringify({ "status": 200, "error": null, "response": resp, "requestTime": end - start }));
        }
    });
});

app.use(AWSXRay.express.closeSegment());
var server = app.listen(8085, function () {
    var host = server.address().address
    var port = server.address().port
    console.log("Example app listening at http://%s:%s", host, port)
});

Может кто-нибудь помочь исправить код?

1 Ответ

0 голосов
/ 27 мая 2019

Симптомы похожи на признаки ошибки, которая, как сообщается, была исправлена ​​в v1.2.0

HTTP Patcher пропускает отклик и блокирует сегменты, если никакой другой прослушиватель ответа не предоставлен

...