справиться с обратным давлением мангусты при получении документов - PullRequest
Новая
       21

справиться с обратным давлением мангусты при получении документов

0 голосов
/ 03 мая 2018

Я использую нагорье, чтобы справиться с обратным давлением. Мой код: 

const pipeline = [{
            $match: { 'published': true, status: 'Approved' }
        }];

        const cursor = UserModel.aggregate(pipeline)
            .cursor().exec();

        // iterating over each hospitality one by one    
        highland(cursor)
            .map((doc) => {
                // some code
                return doc;
            })
            .map((doc) => {
                // some code
                return doc;
            })
            .map((doc) => {
                // some code
                return doc;
            })
            .errors(function (err) {
                winston.error('error', err);
            })
            .done(() => {
                winston.info('JOB: done');
            });

Я хочу, чтобы один документ извлекался, а затем обрабатывался в потоках карты один за другим.

Я не уверен, справится ли это с противодавлением, потому что highland doc говорит:

См. Раздел «Противодавление» в документации по горной местности.

Некоторые потоки (например, основанные на событиях) не могут быть приостановлены. В данные этих случаев буферизуются до тех пор, пока потребитель не будет готов обработать их.

Пожалуйста, предложите другой способ, если это не справляется с противодавлением!

...