Я хотел бы использовать родной JS-драйвер MongoDB с bluebird promises. Как я могу использовать Promise.promisifyAll()
в этой библиотеке?
Как я могу пролонгировать собственный драйвер Javascript MongoDB с помощью bluebird?
Ответ 1
В отраслевой документации 2.0 содержится более подробное руководство по продвижению https://github.com/petkaantonov/bluebird/blob/master/API.md#promisification
На самом деле это пример mongodb, который намного проще:
var Promise = require("bluebird");
var MongoDB = require("mongodb");
Promise.promisifyAll(MongoDB);
Ответ 2
При использовании Promise.promisifyAll()
он помогает идентифицировать целевой прототип, если ваш целевой объект должен быть создан. В случае с драйвером JS MongoDB стандартным шаблоном является:
- Получить объект
Db
, используя статический методMongoClient
или конструкторDb
- Вызовите
Db#collection()
, чтобы получить объектCollection
.
Итак, заимствуя fooobar.com/questions/219252/..., вы можете:
var Promise = require('bluebird');
var mongodb = require('mongodb');
var MongoClient = mongodb.MongoClient;
var Collection = mongodb.Collection;
Promise.promisifyAll(Collection.prototype);
Promise.promisifyAll(MongoClient);
Теперь вы можете:
var client = MongoClient.connectAsync('mongodb://localhost:27017/test')
.then(function(db) {
return db.collection("myCollection").findOneAsync({ id: 'someId' })
})
.then(function(item) {
// Use `item`
})
.catch(function(err) {
// An error occurred
});
Это дает вам довольно далеко, за исключением того, что это также поможет убедиться, что объекты Cursor
, возвращаемые Collection#find()
, также являются многообещающими. В драйвере JS MongoDB курсор, возвращаемый Collection#find()
, не построен из прототипа. Таким образом, вы можете обернуть метод и обезопасить курсор каждый раз. Это не обязательно, если вы не используете курсоры или не хотите налагать накладные расходы. Здесь один подход:
Collection.prototype._find = Collection.prototype.find;
Collection.prototype.find = function() {
var cursor = this._find.apply(this, arguments);
cursor.toArrayAsync = Promise.promisify(cursor.toArray, cursor);
cursor.countAsync = Promise.promisify(cursor.count, cursor);
return cursor;
}
Ответ 3
Я знаю, что это ответили несколько раз, но я хотел добавить немного больше информации по этой теме. Для собственной документации BlueBird вы должны использовать "использование" для очистки соединений и предотвращения утечек памяти. Управление ресурсами в Bluebird
Я смотрел повсюду, как это сделать правильно, и информации было мало, поэтому я решил поделиться тем, что нашел после долгих проб и ошибок. Данные, которые я использовал ниже (рестораны), взяты из данных образцов MongoDB. Вы можете получить это здесь: Данные импорта MongoDB
// Using dotenv for environment / connection information
require('dotenv').load();
var Promise = require('bluebird'),
mongodb = Promise.promisifyAll(require('mongodb'))
using = Promise.using;
function getConnectionAsync(){
// process.env.MongoDbUrl stored in my .env file using the require above
return mongodb.MongoClient.connectAsync(process.env.MongoDbUrl)
// .disposer is what handles cleaning up the connection
.disposer(function(connection){
connection.close();
});
}
// The two methods below retrieve the same data and output the same data
// but the difference is the first one does as much as it can asynchronously
// while the 2nd one uses the blocking versions of each
// NOTE: using limitAsync seems to go away to never-never land and never come back!
// Everything is done asynchronously here with promises
using(
getConnectionAsync(),
function(connection) {
// Because we used promisifyAll(), most (if not all) of the
// methods in what was promisified now have an Async sibling
// collection : collectionAsync
// find : findAsync
// etc.
return connection.collectionAsync('restaurants')
.then(function(collection){
return collection.findAsync()
})
.then(function(data){
return data.limit(10).toArrayAsync();
});
}
// Before this ".then" is called, the using statement will now call the
// .dispose() that was set up in the getConnectionAsync method
).then(
function(data){
console.log("end data", data);
}
);
// Here, only the connection is asynchronous - the rest are blocking processes
using(
getConnectionAsync(),
function(connection) {
// Here because I'm not using any of the Async functions, these should
// all be blocking requests unlike the promisified versions above
return connection.collection('restaurants').find().limit(10).toArray();
}
).then(
function(data){
console.log("end data", data);
}
);
Я надеюсь, что это поможет кому-то еще, кто хочет делать что-то в книге Bluebird.
Ответ 4
Версия 1.4.9 of mongodb
теперь должна легко быть прозаичной как таковая:
Promise.promisifyAll(mongo.Cursor.prototype);
Подробнее см. https://github.com/mongodb/node-mongodb-native/pull/1201.
Ответ 5
Мы уже некоторое время используем следующий драйвер в производстве. По сути, это оболочка обещаний над нативным драйвером node.js. Он также добавляет дополнительные вспомогательные функции.
poseidon-mongo
- https://github.com/playlyfe/poseidon-mongo