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