如何将异步调用转换为bluebird promise：

Question

我正在使用Vogels库与DynamoDb进行交互。下面的AModel是我使用vogels.define()定义的模型，下面是我无法使用的代码片段：

var Promise = require('bluebird')
Promise.promisifyAll(AModel);

var query = AModel
            .query(1)
            .usingIndex('a-index')

Promise.resolve(query.exec()).then(
function(output) {
    console.log(output)
})

输出为：

{
  "_readableState": {
    "highWaterMark": 16384,
    "buffer": [],
    "length": 0,
    "pipes": null,
    "pipesCount": 0,
    "flowing": false,
    "ended": false,
    "endEmitted": false,
    "reading": false,
    "calledRead": false,
    "sync": true,
    "needReadable": false,
    "emittedReadable": false,
    "readableListening": false,
    "objectMode": true,
    "defaultEncoding": "utf8",
    "ranOut": false,
    "awaitDrain": 0,
    "readingMore": false,
    "decoder": null,
    "encoding": null
  },
  "readable": true,
  "domain": null,
  "_events": {},
  "_maxListeners": 10
}

如何将query.exec()转换为蓝鸟承诺？对于Q，我只需要使用

q.ninvoke(query, 'exec').

Answer 1

我是Vogels图书馆的作者。我没有任何使用蓝鸟的经验，但希望能有所帮助。在运行query.exec()时，如果没有传入回调，vogels将切换到流模式。它将向调用者返回一个流，并且仅在读取器附加到流之后才开始从数据库读取。您可以在readme的流媒体部分了解更多信息

对于您的蓝鸟示例，它在没有回调的情况下调用query.exec，而对于q示例，ninvoke很可能是通过回调调用query.exec。我会看看是否有一个等同于ninvoke的bluebird。

Answer 2

编辑:我花了几分钟时间发布了一个npm包vogels-promisified

这应该可以解决所有问题：

var Promise = require("bluebird");
var vogels = require("vogels");

Promise.promisifyAll(require('vogels/lib/table').prototype);
Promise.promisifyAll(require('vogels/lib/item').prototype);
Promise.promisifyAll(require('vogels/lib/query').prototype);
Promise.promisifyAll(require('vogels/lib/scan').prototype);
Promise.promisifyAll(require('vogels/lib/parallelScan').prototype);

var vogels_model = vogels.model;
vogels.model = function(name, model){
  if (model) { Promise.promisifyAll(model); }
  return vogels_model.apply(vogels, arguments);
};

然后你就可以这样做了：

AModel
  .query(1)
  .usingIndex('a-index')
  .execAsync()
  .then( ... )

另请参阅Issue: Add promise support