Я пытаюсь запустить простую программу, которая извлекает данные из Redis и вставляет их в базу данных. Эта программа никогда не выходит из системы, может кто-то направить меня в правильном направлении?
require('newrelic')
const client = require('./config/redis')
const models = require('./models')
const sequelize = require('sequelize')
async function flushTweets() {
try {
var tweets = await client.lrangeAsync('writer', 0, 100)
client.ltrim('writer', 0, 100)
if (tweets && tweets.length > 0) {
tweets = tweets.map(tweet => JSON.parse(tweet))
models.Tweet.bulkCreate(tweets, { returning: true });
for (var i = 0; i < tweets.length; ++i) {
models.User.update(
{ numTweets: sequelize.literal(`"Users"."numTweets" + 1`) },
{ where: { id: tweets[i].user.id }
});
}
}
} catch (e) {
}
}
flushTweets();