javascript - NodeJS - 如何使用 module.exports 从模型传递异步数据？

Question

我试图从 NodeJS 的 RethinkDB 中的文档中获取数据，并将结果传递到我希望在模板文件中使用的变量中，但是当我尝试打印时它总是 undefined data 变量，如 #{data}(我使用的是 pug/jade)，因为它是一个异步调用(我认为)。

'use strict';

var r = require('rethinkdb');

module.exports = function IndexModel() {
    data: {
        r.connect({host: '127.0.0.1', port: 28015}, function(err, conn) {
            r.db('mydb').table('mytable').run(conn).then(function(cursor) {
                cursor.toArray(function(err, result) {
                    if (err) throw err;
                    return JSON.stringify(result, null, 2);
                });
            });
        });
    }
};

我想这一定是因为 nodejs 希望它成为一个对象，所以我尝试像 JSON.parse(JSON.stringify(result, null, 2)) 那样解析它，但这会抛出同样的错误。

当我执行 console.log(JSON.stringify(result, null, 2)) 时，它会在错误之后 打印此错误。

[
  {
    "id": "307ad5e9-a0db-461b-a564-081d73f9b34f",
    "title": "hello"
  }
]

如果需要的话，这是确切的错误:

Cannot read property 'length' of undefined
    at eval (eval at wrap (C:\Users\Me\Project\node_modules\pug-runtime\wrap.js:6:10), <anonymous>:248:32)
    at eval (eval at wrap (C:\Users\Me\Project\node_modules\pug-runtime\wrap.js:6:10), <anonymous>:379:4)
    at template (eval at wrap (C:\Users\Me\Project\node_modules\pug-runtime\wrap.js:6:10), <anonymous>:389:211)
    at Object.exports.renderFile (C:\Users\Me\Project\node_modules\pug\lib\index.js:427:38)
    at Object.exports.renderFile (C:\Users\Me\Project\node_modules\pug\lib\index.js:417:21)
    at View.exports.__express [as engine] (C:\Users\Me\Project\node_modules\pug\lib\index.js:464:11)
    at C:\Users\Me\Project\node_modules\engine-munger\index.js:133:22
    at C:\Users\Me\Project\node_modules\engine-munger\index.js:154:17
    at C:\Users\Me\Project\node_modules\engine-munger\index.js:87:21
    at C:\Users\Me\Project\node_modules\engine-munger\index.js:189:13
    at FSReqWrap.oncomplete (fs.js:153:5)

知道如何解决这个永恒的问题吗？谢谢!

编辑:

看来我无法从任何 rethinkdb 连接或 promise 中的 data 变量返回任何内容，它必须在它之外才能被检测到。

Answer 1

使用 async/await 可能适合您

mymodule.js

module.exports = async function IndexModel() {
        let conn = await r.connect({host: '127.0.0.1', port: 28015});
        let cursor = await r.db('mydb').table('mytable').run(conn)
        try {
            let arr = await cursor.toArray();
            return arr
        } catch (e) {
            throw e;
        }
}

main.js

let indexModel = require('mymodule.js');

indexModel().then(result => {
    console.log(result.length)
})