Правильный способ создания и завершения интервалов трассировки в express / nodejs

Я экспериментирую с библиотекой Opentelemetry.js nodejs / express и пытался переписать рассматривает приложение bookinfo Образец с Istio.

Я следил за конфигурациями трассировщика, указанными в пример:

И мой обработчик запросов как:

router.get('/:productIdStr', function(req, res, next) {
    starsReviewer1 = -1
    starsReviewer2 = -1
      var productId = parseInt(req.params.productIdStr)
      tracer = req.app.locals.tracer
    
      api.context.with(api.propagation.extract(api.ROOT_CONTEXT, req.headers),async () => {
        //---
       var returnedData=""
       span = {}
        Promise.all(
          [ function(){
            span = req.app.locals.tracer.startSpan('calculate-reviews', {
              kind: 1, // server
              attributes: { star_colour: starColor },    
            });
            let promise;
            api.context.with(api.setSpan(api.context.active(), span),async () => {
              additionalHeaders = {'Content-Type':'application/json'}
              function addHeader(value, index, array) {
                if (typeof req.headers[value] !== 'undefined' && req.headers[value] !== null){
                  additionalHeaders[value] = req.headers[value]} 
              }
              headersToPropogate.forEach(addHeader)
              api.propagation.inject(api.context.active(),additionalHeaders)
              requstPath='http://'+ratingsService +":"+ratingsServicePort + "/ratings/" + productId
              //GetRatings
              // Make HTTP Call to the ratings service here.
              promise = axios.get(
                requstPath,
               {headers:additionalHeaders}
              )
              .then((res) => {
                log_info(span,"Get Ratings give value")
                span.addEvent('Data available from ratings ');
                returnedData=res.data
              })
              .catch((error) => {
                log_info(span,"Get Ratings did not give value, Using default Values")
                span.addEvent('Data not available from ratings ');
                console.error(error)
              })
              .finally(() => {
                span.end();
              });
    
            })
            return promise;
          }()]
        )
        .then(() => {
          if (returnedData !== ""){
            
            res.writeHead(200, {'Content-type': 'application/json'})
            res.end(JSON.stringify(getJsonResponse(productId,returnedData.ratings.Reviewer1, returnedData.ratings.Reviewer1)))
          }
          else{
            res.writeHead(200, {'Content-type': 'application/json'})
            res.end(JSON.stringify(getJsonResponse(productId,starsReviewer1, starsReviewer1)))
          }
        })
        .catch((error) => {
          res.writeHead(200, {'Content-type': 'application/json'})
          res.end(JSON.stringify(getJsonResponse(productId,starsReviewer1, starsReviewer1)))
        })
        .finally(()=>{
          span.end()
        })
        
        })
      //---
    });

Проблема, с которой я сталкиваюсь, заключается в том, что когда я смотрю на сгенерированные следы, это кажется неправильным:  введите описание изображения здесь

Проблемы следующие:

  • диапазон вычислений-обзоров не закрывается
  • Как мне удалить HTTP GET, который, кажется, добавляется автоматически. Я попытался изменить эту настройку трассировщика, но это не сработало. Скорее создается новый node-express-reviews-service диапазон в дополнение к HTTP GET:
registerInstrumentations({
    tracerProvider: provider,
    instrumentations: [
      // Express instrumentation expects HTTP layer to be instrumented
      new HttpInstrumentation({
        requestHook: (span, request) => {
          span.updateName("node-express-reviews-service")
        }
    }),
      new ExpressInstrumentation(),
    ],
  });
  • Диапазон для HTTP-вызова rating.default начинается и заканчивается перед вызовом calculate-reviews. В идеале интервал для ratings.default должен начинаться после calculate-review и заканчиваться раньше. Но на изображении calcualte-reviews промежуток начинается и заканчивается после ratings.default. Что я делаю не так и как правильно?
  • Что такое ошибка корректировки перекоса часов отключена; не применяя вычисленную дельту -53,6005 мс, полученную при проверке вычислений  введите описание изображения здесь

person Vipin Menon    schedule 26.05.2021    source источник
comment
Господи, этот код нуждается в глубоком рефакторинге. Как это вообще можно прочитать? Есть Promises с .then(), смешанным с async без await (так что это бесполезно) внутри функций внутри обратных вызовов внутри самовызывающейся функции внутри массива внутри Promise. Все внутри обработчика маршрута O_o Также вы return promise до его определения (вы определяете его внутри асинхронного обратный вызов, поэтому он будет определен после его возврата)   -  person Jeremy Thille    schedule 26.05.2021
comment
Что такое api.context.with? Требуется функция обратного вызова без аргумента? Значит, он ничего не возвращает? Но по-прежнему принимает функцию обратного вызова? Я не понимаю. Также Promise.all имеет массив только из одного обещания, поэтому в Promise.all нет необходимости, достаточно одного простого обещания.   -  person Jeremy Thille    schedule 26.05.2021
comment
Я пытаюсь провести рефакторинг и разобраться в этом коде, но так много неправильных и непонятных вещей. api.context.with ничего не возвращает, но по-прежнему выполняет функцию обратного вызова? Почему? headersToPropogate не определено. Многие переменные объявлены без const, что делает их глобальными (например, starsReviewer1, starsReviewer2 и requstPath). ratingsService и ratingsServicePort не определены. starsReviewer2 не используется и т. Д.   -  person Jeremy Thille    schedule 26.05.2021


Ответы (1)


Я попытался реорганизовать код, чтобы сделать его более читаемым и понятным, надеюсь, это будет хорошей отправной точкой для выяснения того, что не так. Но на самом деле я не понимаю, что это должно делать, поэтому я не могу это отладить.

router.get('/:productIdStr', async (req, res) => {

    const starsReviewer1 = -1;
    const starsReviewer2 = -1;
    const productId = parseInt(req.params.productIdStr);
    const tracer = req.app.locals.tracer;

    await new Promise(resolve => api.context.with(api.propagation.extract(api.ROOT_CONTEXT, req.headers), resolve)); // Not sure what this does? It doesn't return anything?

    const span = req.app.locals.tracer.startSpan('calculate-reviews', {
        kind: 1, // server
        attributes: { star_colour: starColor },
    });

    await new Promise(resolve => api.context.with(api.setSpan(api.context.active(), span), resolve)); // Still not sure what this does, as it still doesn't return anything

    const additionalHeaders = { 'Content-Type': 'application/json' };

    headersToPropogate.forEach(value => { // headersToPropogate is undefined?
        if (typeof req.headers[value] !== 'undefined' && req.headers[value] !== null) {
            additionalHeaders[value] = req.headers[value]
        }
    });

    api.propagation.inject(api.context.active(), additionalHeaders); // No idea what this does, it doesn't seem to be asynchronous

    const requstPath = 'http://' + ratingsService + ":" + ratingsServicePort + "/ratings/" + productId;
    
    const returnedData = await axios.get(
        requstPath,
        { headers: additionalHeaders }
    ).data;

    if (returnedData !== "") {
        res.writeHead(200, { 'Content-type': 'application/json' })
        res.end(JSON.stringify(getJsonResponse(productId, returnedData.ratings.Reviewer1, returnedData.ratings.Reviewer1)))
    }
    else {
        res.writeHead(200, { 'Content-type': 'application/json' })
        res.end(JSON.stringify(getJsonResponse(productId, starsReviewer1, starsReviewer1)))
    }

    span.end(); // No idea what this is either
});
person Jeremy Thille    schedule 26.05.2021
comment
Привет, Джереми, спасибо за полезную информацию. Вы правы, код действительно требует значительного рефакторинга ... (И я учусь правильно использовать промисы). - person Vipin Menon; 26.05.2021