Асинхронная функция Javascript никогда не возвращается - PullRequest
0 голосов
/ 27 апреля 2018

Я пытаюсь запустить простую программу, которая извлекает данные из 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();
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...