0

我试图弄清楚在发出 HTTP 请求时是否有办法在所有 winston 记录器调用中使用唯一（每个请求）会话 ID。

关于问题的详细说明：

假设每分钟有数百个请求访问一个网站，并且每个请求都通过不同的函数来注销各种消息。

我的目标是使用winston记录器记录消息，包括每个请求的唯一会话 ID，直到发送响应。

app.use(session(...))我使用express-session库为请求生成一个唯一的会话 ID 。

使用morgan，HTTP 日志会打印一个唯一的会话 ID，如下所示：

logger = winston.createLogger(...);

const myStream = {
  write: (text: string) => {
    logger.info(text);
  }
}

morgan.token('sessionid', function (req, res) { return req['sessionID'] });
app.use(morgan(':remote-addr - :remote-user [:date[clf]] ":method :url HTTP/:http-version" :status :res[content-length] ":referrer" ":user-agent"  ["SESSION_ID :sessionid"]', { stream: myStream }));

但是，我还想在代码中其他地方的其他 logger.* 函数中使用相同的会话 ID。我能够做到这一点，但是随着同时请求的数量（使用 k6 负载测试）的增加，会话 ID 会被另一个请求的新会话 ID 覆盖。

我在 winston 传输中使用请求中的会话 ID 的代码是：

public static initializeLogger(appInstance: express.Application) {

        if (!appInstance) throw new Error(`Cannot initialize logger. Invalid express.Application instance passed. Logging may not be available`);
        
        appInstance.use((req, res, next) => {
            //this.m_sessionID = req["sessionID"];
            this.m_logger.clear();
            this.m_logger = winston.createLogger({
                level: LOG_LEVEL,
                levels: winston.config.syslog.levels,
                format: winston.format.json(),
                transports: [
                    new winston.transports.Console({ format: winston.format.simple() }),
                    new winston.transports.File({ filename: 'error.log', level: 'error' }),
                    new winston.transports.File({ filename: 'debug.log', level: 'debug' }),
                    new WinstonCloudWatch({
                        logGroupName: CLOUDWATCH_LOG_GROUP_NAME,
                        logStreamName: function () {
                            let date = new Date().toISOString().split('T')[0];
                            return 'k-server-logs-' + date;
                        },
                        awsRegion: AWS_REGION,
                        awsAccessKeyId: process.env.AWS_ACCESS_KEY_ID,
                        awsSecretKey: process.env.AWS_SECRET_ACCESS_KEY,
                        retentionInDays: process.env.CLOUDWATCH_LOG_RETENTION_DAYS ? Number(process.env.CLOUDWATCH_LOG_RETENTION_DAYS) : 30,
                        messageFormatter: (log) => {
                            return `${JSON.stringify({
                                message: log.message,
                                sessionID: req["sessionID"],
                                level: log.level
                            })}`
                        }
                    })
                ],
            });
            next();
        });
    }

我希望将 winston 记录器放入app.use(...)中间件中，以便为 winston 记录器设置 cloudwatch 传输，并在每个请求进入时使用 req.sessionID。

但是，此设置不起作用。如果我同时发送 10 个请求，则此代码会中断，并且 sessionID 会错误地标记在 logger.* 消息上和/或在多条消息中重复。

我查看了其他实现，例如https://solidgeargroup.com/en/express-logging-global-unique-request-identificator-nodejs/，但无法使其正常工作。

希望得到一些建议-我确定我的设置已关闭。

先感谢您。

4

1 回答 1

0

来自https://solidgeargroup.com/en/express-logging-global-unique-request-identificator-nodejs/的关键提示

使用 express-http-context，它有一个 set 和 get 函数，可以确保唯一的 session ID 在你的代码中可用。

import httpContext from 'express-http-context';
...
...
logger.add(new WinstonCloudWatch({
                level:LOG_LEVEL,
                logGroupName: CLOUDWATCH_LOG_GROUP_NAME,
                logStreamName: function () {
                    let date = new Date().toISOString().split('T')[0];
                    return `${process.env.CLOUDWATCH_LOG_FILE_NAMEPREFIX}-logs-${date}`;
                },
                awsRegion: AWS_REGION,
                awsAccessKeyId: process.env.AWS_ACCESS_KEY_ID,
                awsSecretKey: process.env.AWS_SECRET_ACCESS_KEY,
                retentionInDays: process.env.CLOUDWATCH_LOG_RETENTION_DAYS ? Number(process.env.CLOUDWATCH_LOG_RETENTION_DAYS) : 30,
                messageFormatter: (log) => {
                    return `${JSON.stringify({
                        message: log.message,
                        **sessionID: httpContext.get('reqId')**,
                        level: log.level
                    })}`
                }
}));
于 2020-11-25T20:06:12.080 回答