Iain Sproat
7b1c46ba9a
* chore(server): addn'l observability around db connections * improvement to logging and metrics * Instrument the knex connection pool
72 lines
2.0 KiB
JavaScript
72 lines
2.0 KiB
JavaScript
/* istanbul ignore file */
|
|
const Sentry = require('@sentry/node')
|
|
const Tracing = require('@sentry/tracing')
|
|
const { getMachineId } = require('./machineId')
|
|
const prometheusClient = require('prom-client')
|
|
const promBundle = require('express-prom-bundle')
|
|
|
|
const { initKnexPrometheusMetrics } = require('@/logging/knexMonitoring')
|
|
const {
|
|
initHighFrequencyMonitoring
|
|
} = require('@/logging/highFrequencyMetrics/highfrequencyMonitoring')
|
|
const knex = require('@/db/knex')
|
|
const {
|
|
highFrequencyMetricsCollectionPeriodMs
|
|
} = require('@/modules/shared/helpers/envHelper')
|
|
const { startupLogger: logger } = require('@/logging/logging')
|
|
|
|
let prometheusInitialized = false
|
|
|
|
module.exports = function (app) {
|
|
const id = getMachineId()
|
|
|
|
if (!prometheusInitialized) {
|
|
prometheusInitialized = true
|
|
prometheusClient.register.clear()
|
|
prometheusClient.register.setDefaultLabels({
|
|
project: 'speckle-server',
|
|
app: 'server'
|
|
})
|
|
prometheusClient.collectDefaultMetrics()
|
|
const highfrequencyMonitoring = initHighFrequencyMonitoring({
|
|
register: prometheusClient.register,
|
|
collectionPeriodMilliseconds: highFrequencyMetricsCollectionPeriodMs(),
|
|
config: {
|
|
knex
|
|
}
|
|
})
|
|
highfrequencyMonitoring.start()
|
|
|
|
initKnexPrometheusMetrics({
|
|
register: prometheusClient.register,
|
|
db: knex,
|
|
logger
|
|
})
|
|
const expressMetricsMiddleware = promBundle({
|
|
includeMethod: true,
|
|
includePath: true,
|
|
httpDurationMetricName: 'speckle_server_request_duration',
|
|
metricType: 'summary',
|
|
autoregister: false
|
|
})
|
|
|
|
app.use(expressMetricsMiddleware)
|
|
}
|
|
|
|
if (process.env.DISABLE_TRACING !== 'true' && process.env.SENTRY_DSN) {
|
|
Sentry.setUser({ id })
|
|
|
|
Sentry.init({
|
|
dsn: process.env.SENTRY_DSN,
|
|
integrations: [
|
|
new Sentry.Integrations.Http({ tracing: true }),
|
|
new Tracing.Integrations.Express({ app })
|
|
],
|
|
tracesSampleRate: 0.1
|
|
})
|
|
|
|
app.use(Sentry.Handlers.requestHandler())
|
|
app.use(Sentry.Handlers.tracingHandler())
|
|
}
|
|
}
|