如何用node优雅地打印全链路日志

目录

• 前言
• 一、原理和实践
• 二、性能开销
• 总结

asyncHook = async_hook.createHook({
  // 监听异步资源的创建
  init(asyncId,type,triggerAsyncId,resource){},
  // 异步资源回调函数开始执行之前
  before(asyncId){},
  // 异步资源回调函数开始执行后
  after(asyncId){},
  // 监听异步资源的销毁
  destroy(asyncId){}
})

const createNamespace = require("cls-hooked").createNamespace 
const session = createNamespace("requestId-store") 
module.exports = session

const session = require("./session") 
module.exports = { 
info: (message) => 
{ 
const requestId = session.get("requestId")
console.log(`requestId:${requestId}`, message) 
}, 
error: (message) => 
{ 
const requestId = session.get("requestId") 
console.error(`requestId:${requestId}`, message) 
} 
}

const logger = require("./logger") 
new Sequelize( 
logging: function (sql, costtime) { 
logger.error( `sql exe : ${sql} | costtime ${costtime} ms` ); 
} )

const session = require("./session") 
const logger = require("./logger") 
async function accessHandler(ctx, next) 
{ 
const requestId = ctx.header["x-request-id"] || uuid()
const params = ctx.request.body ? JSON.stringify(ctx.request.body) : JSON.stringify(ctx.request.query)
// 设置requestId session.run(() => { session.set("requestId", requestId)
logger.info(`url:${ctx.request.path}；params:${params}`) next()
// 设置返回响应头
ctx.res.setHeader("X-Request-Id",requestId)
}) }

访问日志：
requestId:79f422a6-6151-4bfd-93ca-3c6f892fb9ac url:/home；params:{"a":"1"}

Sql日志：
requestId:79f422a6-6151-4bfd-93ca-3c6f892fb9ac sql exe :
Executed (default): SELECT `id` FROM t_user