1 回答
TA贡献1828条经验 获得超6个赞
看起来他们使用 Node.js 域(https://nodejs.org/api/domain.html)为每个请求创建一个单独的“上下文”。
从 Sentry 文档中,您需要使用 requestHandler 才能正常工作。
例如对于快递(https://docs.sentry.io/platforms/node/express/):
const express = require('express');
const app = express();
const Sentry = require('@sentry/node');
Sentry.init({ dsn: 'https://963bad1904fe48b18c1866f10e69eff8@sentry.io/1240240' });
// The request handler must be the first middleware on the app
app.use(Sentry.Handlers.requestHandler());
// All controllers should live here
app.get('/', function rootHandler(req, res) {
res.end('Hello world!');
});
处理程序看起来像这样:
(来自:@sentry/node/dist/handlers.js)
function requestHandler(options) {
return function sentryRequestMiddleware(req, res, next) {
if (options && options.flushTimeout && options.flushTimeout > 0) {
// tslint:disable-next-line: no-unbound-method
var _end_1 = res.end;
res.end = function (chunk, encoding, cb) {
var _this = this;
sdk_1.flush(options.flushTimeout)
.then(function () {
_end_1.call(_this, chunk, encoding, cb);
})
.then(null, function (e) {
utils_1.logger.error(e);
});
};
}
var local = domain.create();
local.add(req);
local.add(res);
local.on('error', next);
local.run(function () {
core_1.getCurrentHub().configureScope(function (scope) {
return scope.addEventProcessor(function (event) { return parseRequest(event, req, options); });
});
next();
});
};
}
exports.requestHandler = requestHandler;
因此,您可以看到根据新请求创建的新域。
我主要是通过发现这个问题来找到这个信息的:https : //github.com/getsentry/sentry-javascript/issues/1939
如果您想将“上下文”添加到 Node 后端的其他异步部分(例如,如果您有工作人员/线程/某些工作不是从 HTTP 请求启动的……),上面的问题中有一些示例说明了如何实现完成(通过手动创建集线器/域..)。
如果您有兴趣,现在也可以使用 async_hooks 来保持 Node.js 中具有各种异步函数/回调/setTimeouts 的上下文的某种意义:https ://nodejs.org/api/async_hooks.html
这是一个很好的介绍:
https://itnext.io/request-id-tracing-in-node-js-applications-c517c7dab62d?
以及一些实现此功能的库:
https://github.com/Jeff-Lewis/cls-hooked
https://github.com/vicanso/async-local-storage
例如,这样的事情应该工作:
const ALS = require("async-local-storage");
function withScope(fn, requestId) {
ALS.scope();
ALS.set("requestId", requestId, false);
return await fn();
}
async function work() {
try {
await part1();
await part2();
} catch(e) {
Sentry.withScope((scope) => {
scope.setTag("requestId", ALS.get("requestId"));
Sentry.captureException(new Error("..."))
})
}
}
withScope(work, "1234-5678");
不过,您必须自己跟踪面包屑,例如添加面包屑:
ALS.set("breadcrumbs", [...ALS.get("breadcrumbs"), new_breadcrumb]);
您需要在 Sentry 的 beforeSend() 回调中手动设置这些:
beforeSend: function(data) {
data.breadcrumbs = ALS.get("breadcrumbs");
return data;
}
添加回答
举报