如何通过elastic-apm-node将Node.js应用的console.log推送至Elasticsearch

可以直接借助elastic-apm-node实现需求，无需依赖Filebeat，下面提供两种适配不同场景的方案：

方案1：劫持console.log，转发到APM #

直接重写console.log方法，保留原有控制台输出的同时，将日志内容通过APM发送到Elastic。这种方式兼容你现有代码里的console.log调用，无需大量修改业务逻辑。

示例代码：

const apm = require('elastic-apm-node').start({
  serviceName: 'your-service-name',
  serverUrl: 'http://your-apm-server:8200'
});

// 保存原始console.log方法
const originalConsoleLog = console.log;

// 重写console.log
console.log = (...args) => {
  // 保留原本的控制台输出
  originalConsoleLog(...args);

  // 将日志内容转为字符串，发送到APM
  const logContent = args.join(' ');
  apm.captureMessage(logContent, {
    level: 'info',
    logger: 'function-trace-log',
    labels: { source: 'function-call' }
  });
};

// 你的业务函数
function A() {
  console.log("Function A called , send to Elastic");
  doSomething();
}

function doSomething() {
  console.log("Function doSomething called, send to Elastic");
}

说明：

• captureMessage是APM提供的发送自定义日志信息的方法，会在Elastic APM的「Logs」或「Messages」面板中展示。
• 通过labels可以给日志打标签，方便后续在Kibana中过滤查询。

方案2：用自定义Span追踪函数调用（更符合APM链路模型） #

如果核心需求是追踪函数调用链路而非单纯发送日志，推荐使用APM的自定义Span实现。这种方式能在APM UI中清晰看到函数的调用关系、执行时长，比单纯日志更具分析价值。

示例代码：

const apm = require('elastic-apm-node').start({
  serviceName: 'your-service-name',
  serverUrl: 'http://your-apm-server:8200'
});

// 封装一个函数追踪装饰器
function traceFunction(targetFunc) {
  return function(...args) {
    // 创建自定义Span，标记函数调用
    const span = apm.startSpan(`function: ${targetFunc.name}`, 'function-execution');
    
    // 可选：保留原有控制台日志输出
    console.log(`Function ${targetFunc.name} called, send to Elastic`);

    try {
      // 执行原函数
      const result = targetFunc.apply(this, args);
      
      // 处理异步函数：返回Promise时，等待结束后关闭Span
      if (result instanceof Promise) {
        return result
          .finally(() => span?.end())
          .catch(err => {
            apm.captureError(err);
            throw err;
          });
      } else {
        span?.end();
        return result;
      }
    } catch (err) {
      apm.captureError(err);
      span?.end();
      throw err;
    }
  };
}

// 用装饰器包装需要追踪的函数
const A = traceFunction(function A() {
  doSomething();
});

const doSomething = traceFunction(function doSomething() {
  // 你的业务逻辑
});

说明：

• 自定义Span会被纳入APM的链路追踪中，在「Transactions」面板可以查看每个函数的执行细节。
• 支持同步和异步函数，自动处理Promise场景。
• 相比日志，能提供更丰富的性能数据（如函数执行耗时）。

注意事项 #

• 避免循环调用：不要在APM回调方法（如captureMessage）里再次调用console.log，否则会触发无限循环。
• 性能优化：若应用有大量高频函数调用，建议调整APM的采样率（配置transactionSampleRate），避免过多数据影响性能。
• 配置验证：确保APM的serviceName和serverUrl配置正确，应用能正常连接到APM Server。

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