PMX文库

PMX是一个轻量级库，允许与仪表板进行高级交互。

• 公开指标可以实时或通过历史记录显示
• 公开操作可从仪表板远程触发
• 发出异常 比如异常或关键问题
• 发送事件以通知任何事项

安装

使用yarn:

yarn add @pm2/io

使用npm:

npm install @pm2/io --save

PMX初始化

加载并初始化应用顶层的io.

const io = require('@pm2/io').init({
  errors: true,
  transactions: false
  profiling: true,
});

模块可能存在的问题：

为了检索http延迟，io 包装了http模块。 如果您需要任何模块以修改http模块，此包装可以被移除

• request-promise：该模块清除节点缓存并需要一个新的干净版本的http模块。 为了解决这个问题，在请求request-promise以获得正确包装的 http模块后再次请求http。
  可用的选项是：

应用级网络流量监视/显示使用的端口

初始化PMX时，您可以通过添加选项network：true来监控特定应用的网络使用情况。如果您启动io时启用了标志ports：true，它将显示您的应用正在侦听哪些端口。

您可以在位于Keymetrics仪表板页面的Custom Metrics部分中找到这些指标。

示例：

io.init({
  [...]
  network : true, // Allows application level network monitoring
  ports   : true  // Displays ports used by the application
});

HTTP延迟分析

通过此功能，您可以在遵从REST的同时监控路由，延迟和代码。

io.http(); // You must do this BEFORE any require('http')

您也可以通过传递正则表达式列表来忽略一些路由。

io.http({
  http          : true, // (Default: true)
  ignore_routes : [/socket\.io/, /notFound/] // Ignore http routes with this pattern (Default: [])
});

这可以选择性通过io.init（）来完成。

io.init({
  http          : true, // (Default: true)
  ignore_routes : [/socket\.io/, /notFound/] // Ignore http routes with this pattern (Default: [])
});

自定义指标

然后，您可以编制自己的指标来跟踪重要的相关信息。 有4种不同的探头可供选择：

• 简单的指标：可立即读取的值
  • 例如，监视变量值
• 计数器：增加或减少的事项
  • 例如，正在处理的下载，用户连接
• 仪表：以事件/间隔来衡量的事物
  • 例如，每分钟请求一次http服务器
• 直方图：保留一个统计相关值的库，偏向最后5分钟以探索其分布
  • 例如，监视查询执行到数据库的平均值

指标：简单的价值报告

这允许暴露可以立即读取的值。

const probe = io.probe()
// Here the value function will be called each second to get the value
const metric = probe.metric({
  name: 'Realtime user',
  value: function() {
    return Object.keys(users).length;
  }
})
// Here we are going to call valvar.set() to set the new value
const valvar = probe.metric({
  name: 'Realtime Value'
})
valvar.set(23)

计数器：顺序值更改

增加或减少的事项。

const probe = io.probe()
// The counter will start at 0
const counter = probe.counter({
  name: 'Current req processed'
});
http.createServer((req, res) => {
  // Increment the counter, counter will eq 1
  counter.inc()
  req.on('end', () => {
    // Decrement the counter, counter will eq 0
    counter.dec()
  })
})

仪表：平均计算值

以事件/间隔来衡量的事物。

const probe = io.probe()
const meter = probe.meter({
  name: 'req/sec',
  samples: 1,
  timeframe: 60
})
http.createServer((req, res) => {
  meter.mark()
  res.end({ success: true })
})

选项

Sample 选项是费率单位。 默认为 1 秒。timeframe 选项是分析事件的时间范围。 默认为 60秒.

直方图

存储统计相关值的储存库，偏向最近5分钟以探索其分布。

const probe = io.probe()
const histogram = probe.histogram({
  name: 'latency',
  measurement: 'mean'
})
let latency = 0
setInterval(function() {
  latency = Math.round(Math.random() * 100)
  histogram.update(latency)
}, 100)

常用自定义度量选项

• name：探针名称，它将显示在 Keymetrics 仪表板上。
• agg_type：这个参数是可选的，它可以是sum，max，min，avg（默认）或none。 它将影响探测数据在 Keymetrics 后端聚合的方式。 如果这不相关（如：常量或字符串值），则使用none。
• alert : 用于 Meter 和 Counter 探测器。 该参数是可选的。它会创建一个警告对象（见下文）。

自定义度量的警报系统

此警报系统可以监控Probe值，并在达到特定值时启动一个异常。

Example for a cpu_usage var: 一个cpu_usage变种的例子：

const metric = probe.metric({
  name: 'CPU usage',
  value: () => {
    return cpu_usage;
  },
  alert: {
    mode: 'threshold',
    value: 95,
    // optional
    msg: 'Detected over 95% CPU usage',
    //optional
    action: () => {
      console.error('Detected over 95% CPU usage');
    },
    //optional
    cmp: (value, threshold) => {
      // default check
      return (parseFloat(value) > threshold);
    }
  }
});

选项：

• mode : threshold, threshold-avg, smart.
• value : 将用于异常检查的值。
• msg : 用于例外情况的字符串。
• action : 可选的。 当达到异常级别时触发函数。
• cmp : 可选的。用于有2个参数的异常检查的函数。
• interval : 可选的，threshold-avg模式。 监控值的采样长度（默认为180秒）。
• timeout : 可选的，threshold-avg模式。 平均值比较开始后的时间（默认30 000毫秒）。

远程操作

直接从Keymetrics远程触发函数。 这些功能可以在自定义操作部分的主Keymetrics控制面板页面中找到。

简单操作

一个简单的操作允许从Keymetrics触发一个函数。 action命令将函数作为参数（在此处答复），并且在作业完成后需要调用该命令。

示例：

const io = require('@pm2/io')
io.action('db:clean', (reply) => {
  clean.db(function() {
    /**
     * reply() must be called at the end of the action
     */
     reply({success : true})
  })
})

作用域操作

作用域操作是高级的远程操作，也可以由Keymetrics触发。

两个参数传递给函数，数据（从Keymetrics发送的选项数据）和res，允许发出日志数据并结束作用域操作。

示例：

io.scopedAction('long running lsof', (data, res) => {
  const child = spawn('lsof', [])
  child.stdout.on('data', (chunk) => {
    chunk.toString().split('\n').forEach((line) => {
      res.send(line); // This sends log to PM2 Plus to be saved (for tracking)
    })
  })
  child.stdout.on('end', (chunk) => {
    res.end('end'); // This ends the scoped action
  })
  child.on('error', (e) => {
    res.error(e);  // This reports an error to PM2 Plus
  })
})

发射事件

发布活动并获得历史记录和统计数据。这在Keymetrics Events 页面中可用。

const io = require('@pm2/io')
io.emit('user:register', {
  user: 'Alex registered',
  email: 'thorustor@gmail.com'
})

问题报告

PM2链接到Keymetrics后，默认情况下会提醒您任何未捕获的异常。这些错误可通过Keymetrics Issue 页面访问。

自定义提醒通知

如果您需要收到任意重要错误的提醒，您可以通过以下编程方式实现：

const io = require('@pm2/io')
io.notify({ success : false })
io.notify('This is an error')
io.notify(new Error('This is an error'))

将赘言添加到提醒：加速错误处理

当未捕获的异常发生时，您可以跟踪它被引发的路由。要做到这一点，您必须在路由安装结束时附加中间件 io.expressErrorHandler。

const io = require('@pm2/io')
// All my routes
app.get('/' ...)
app.post(...)
// All my routes
// Here I attach the middleware to get more verbosity on exception thrown
app.use(io.expressErrorHandler())

原文: https://pm2.io/doc/zh/plus/reference/pmx