我想监视查询对我的API的数据库所花费的时间。因此,我使用书架插件bookshelf-signals创建了以下功能。 :
bookshelf.on('fetching', () => {
server.app.fetching = new Date().valueOf();
});
bookshelf.on('counting', () => {
server.app.fetching = new Date().valueOf();
});
bookshelf.on('fetched', () => {
server.statsd.gauge('db_query', new Date().valueOf() - server.app.fetching);
});
...这样我就可以检索提取/计数之前和之后的时间;我对delete-deleted和save-saved进行了相同的操作。
我想我不明白的是何时应该触发获取和获取...当我试图查看何时触发了获取和获取时,基本上它最终是这样的:
'fetching event A'
'fetching event B'
'fetching event C'
'fetched event C'
'fetched event B'
'fetched event A'
结果导致计时器明显返回错误的值,您是否有任何线索/线索?
我还看到有人可以在Knex上触发“查询”事件,并考虑将其用作替代解决方案。但是,似乎只有在我指定查询表的情况下它才有效,即:
knex('whatever_table').on('query', () => {///});
在我想在每个模型上应用事件处理程序的情况下,这变得不切实际。
我认为我应该坚持使用书架,但是如何处理事件呢?
先感谢您!
最佳答案
我只是写了一些小的测试代码,如何使用knex跟踪事务持续时间。
https://runkit.com/embed/679qu91ylu4w
/**
* Calculate transaction durations in knex
*
*/
require('sqlite3');
var knex = require("knex")({
client: 'sqlite',
connection: ':memory:',
pool: { min: 1, max: 10 }
});
function isTransactionStart(querySpec) {
return querySpec.sql === 'BEGIN;';
}
function isTransactionEnd(querySpec) {
return querySpec.sql === 'COMMIT;' || querySpec.sql === 'ROLLBACK;';
}
const transactionDurations = {};
knex.on('query', querySpec => {
console.log('On query', querySpec);
if (isTransactionStart(querySpec)) {
if (transactionDurations[querySpec.__knexUid]) {
console.error('New transaction started, before earlier was ended');
return;
}
transactionDurations[querySpec.__knexUid] = new Date().getTime();
}
if (isTransactionEnd(querySpec)) {
const startTime = transactionDurations[querySpec.__knexUid];
if (!startTime) {
console.error('Transaction end detected, but start time not found');
}
const endTime = new Date().getTime();
transactionDurations[querySpec.__knexUid] = null;
console.log('TRANSACTION DURATION', endTime - startTime);
}
});
// just as an example of other available events to show when they are called
knex.on('query-response', (res, querySpec) => {
// console.log('On query response', res, querySpec);
});
knex.on('query-error', (err, querySpec) => {
// console.log('On query error', err, querySpec);
});
try {
a = await Promise.all([
knex.transaction(trx => {
return trx.raw('select 1');
}),
knex.transaction(trx => {
return trx.raw('select 2');
}),
knex.transaction(trx => {
return trx.raw('error me');
})
]);
} catch (e) {
console.log('Got ERROR:', e);
}
同样的方法也应适用于查询时间。为了防止计时器簿记泄漏内存,您应该添加一些清除代码。
查询持续时间计时器应在
query
事件中启动,并在query-response
或query-error
中停止,具体取决于哪个首先触发。为了能够匹配
query
-query-response
对,可以使用querySpec.__knexQueryUid
属性。关于mysql - 跟踪数据库查询时间-书架/knex,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/45438230/