AWS Lambda中Node.js Worker Threads控制台日志不一致问题

代码与配置 #

hello-world.js #

const { Worker } = require('node:worker_threads')

export const hello = async (event, context) => {
  console.log('Hello World')
  const w = new Worker('./build/other-file.js')
  return new Promise(resolve => {
    w.on('exit', () => {
      console.log('Goodbye')
      resolve()
    })
  })
}

other-file.js #

console.log('Blah Blah')

serverless.yml配置 #

functions:
  helloWorld:
    handler: build/hello-world.hello
    maximumRetryAttempts: 0

日志输出情况 #

Serverless本地调用日志 #

15:40:59 $ sls invoke local --function helloWorld
Using serverless-localstack
Hello World
Blah Blah
Goodbye

AWS云端调用日志 #

15:44:00 $ aws lambda invoke --function-name sheetbuilder-dev-helloWorld out --log-type Tail --query 'LogResult' --output text | base64 -d
START RequestId: ebf33295-c59e-4182-a5b0-d436210f5e6f Version: $LATEST
2022-09-05T14:51:48.833Z    ebf33295-c59e-4182-a5b0-d436210f5e6f    INFO    Hello World
Blah Blah
2022-09-05T14:51:48.973Z    ebf33295-c59e-4182-a5b0-d436210f5e6f    INFO    Goodbye
END RequestId: ebf33295-c59e-4182-a5b0-d436210f5e6f
REPORT RequestId: ebf33295-c59e-4182-a5b0-d436210f5e6f  Duration: 154.59 ms Billed Duration: 155 ms Memory Size: 1024 MB    Max Memory Used: 73 MB  Init Duration: 192.28 ms    
15:51:49 $ 

技术问题 #

1. 为何主线程与Worker线程的日志输出存在格式差异？
2. 是否可以轻松实现Worker线程日志与主线程格式一致（至少包含时间戳和执行ID）？
3. 是否可以让Serverless本地执行的日志输出也保持格式一致？

问题解答 #

1. 日志格式差异原因 #

Lambda运行时只会对主线程的console输出做格式化处理，自动添加时间戳和Request ID前缀。Worker线程是独立的子进程，脱离了Lambda运行时的日志拦截逻辑，所以它的输出是原始内容，不会被额外加工。

2. 让Worker日志格式与主线程一致的方法 #

可以实现，有两种简单方案：

• 传递上下文到Worker：创建Worker时通过workerData把主线程的context.requestId传过去，在Worker里自定义日志函数，手动拼接时间戳和Request ID后再输出。
  示例修改：
  主线程：

  const w = new Worker('./build/other-file.js', { workerData: { requestId: context.requestId } })
  

  Worker线程（other-file.js）：

  const { workerData } = require('node:worker_threads')
  const formatLog = (msg) => {
    const timestamp = new Date().toISOString()
    return `${timestamp}\t${workerData.requestId}\tINFO\t${msg}`
  }
  console.log(formatLog('Blah Blah'))
  

• 主线程统一输出：Worker里不用console.log，而是通过postMessage把日志内容发给主线程，由主线程负责打印，自然带上Lambda的标准格式。

3. Serverless本地执行日志统一格式 #

可以实现：

• 统一主线程和Worker的日志函数，不管本地还是云端，都输出带时间戳和模拟Request ID的格式；
• 借助Serverless插件（比如serverless-plugin-logging），配置本地环境的日志模板，让本地调用时自动生成和云端一致的日志前缀。

内容的提问来源于stack exchange，提问作者Richard Wheeldon