use*_*680 7 asynchronous mongoose redis node.js node-promisify
我正在关注一个教程,我创建了一个 cache.js 文件,该文件将 mongoose 查询和 JSON.stringifying 其转换为该查询返回的值的键。我们的目标是缓存,然后追加.cache()内app.js其中mongoose.find()是
当前,如果缓存为空,我让它从数据库中执行 GET,然后将其存储在缓存中。我有一个
console.log("CACHE VALUE #2");
console.log(cacheValue1);
Run Code Online (Sandbox Code Playgroud)
这可确保数据得到存储并成功输出数据。这条线有效。但有了这条线,
console.log("CACHE VALUE #1");
console.log(cacheValue);
Run Code Online (Sandbox Code Playgroud)
在cacheValue为空。
这是为什么?
它存储在底部的值和键永远不会改变所以我不明白为什么它不会返回数据而不是空值。
SoCache Value #1始终为空并Cache Value #2具有正确的数据。
控制台输出:
GRABBING FROM DB
CLIENT CONNECTION STATUS: true
Setting CACHE to True
ABOUT TO RUN A QUERY
{"$and":[{"auctionType":{"$eq":"publicAuction"}},{"auctionEndDateTime":{"$gte":1582903244869}},{"blacklistGroup":{"$ne":"5e52cca7180a7605ac94648f"}},{"startTime":{"$lte":1582903244869}}],"collection":"listings"}
CACHE VALUE #1
null
CACHE VALUE #2
(THIS IS WHERE ALL MY DATA SHOWS UP)
Run Code Online (Sandbox Code Playgroud)
const mongoose = require('mongoose');
const redis = require('redis');
const util = require('util');
var env = require("dotenv").config({ path: './.env' });
const client = redis.createClient(6380, process.env.REDISCACHEHOSTNAME + '.redis.cache.windows.net', {
auth_pass: process.env.REDISCACHEKEY,
tls: { servername: process.env.REDISCACHEHOSTNAME + '.redis.cache.windows.net' }
});
client.get = util.promisify(client.get);
const exec = mongoose.Query.prototype.exec;
mongoose.Query.prototype.cache = function () {
this.useCache = true;
console.log("Setting CACHE to True")
return this;
}
mongoose.Query
.prototype.exec = async function () {
if (!this.useCache) {
console.log("GRABBING FROM DB")
console.log("CLIENT CONNECTION STATUS: " + client.connected);
return exec.apply(this, arguments);
}
console.log("ABOUT TO RUN A QUERY")
const key = JSON.stringify(Object.assign({}, this.getQuery(), {
collection: this.mongooseCollection.name
}));
//See if we have a value for 'key' in redis
console.log(key);
const cacheValue = await client.get(key);
console.log("CACHE VALUE #1");
console.log(cacheValue);
//If we do, return that
if (cacheValue) {
console.log("cacheValue IS TRUE");
const doc = JSON.parse(cacheValue);
return Array.isArray(doc)
? doc.map(d => new this.model(d))
: new this.model(doc);
}
//Otherwise, issue the query and store the result in redis
const result = await exec.apply(this, arguments);
let redisData = JSON.stringify(result);
//stores the mongoose query result in redis
await client.set(key, JSON.stringify(redisData)), function (err) {
console.error(err);
}
const cacheValue1 = await client.get(key);
console.log("CACHE VALUE #2");
console.log(cacheValue1);
return result;
}
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
1841 次 |
| 最近记录: |