我是Node的新手,这是我第一次尝试使用Promise库。话虽如此,这是我要遵循的简单示例:http://zpalexander.com/blog/javascript-promises-node-js/
这是执行没有错误的代码,但是正如预期的那样,它在完成文件读取和遍历数组之前记录为“完成”。
var Promise = require('bluebird');
var Converter = Promise.promisifyAll(require("csvtojson")).Converter;
var converter = new Converter({});
var Client = Promise.promisifyAll(require('node-rest-client')).Client;
var client = new Client();
var responseArray = [];
converter.fromFile("./ToterFeed.csv", function(err,result){
for (var i = 0, len = result.length; i < len; i++) {
var args = {
data: JSON.stringify(result[i]),
headers: { "Content-Type": "application/json" }
};
client.post("http://192.168.1.102:8080/api/ToterFeed/v1", args, function (data, response) {
responseArray.push(data.responses);
console.log(data.responses[0]);
});
}
})
console.log("done");
这是根据我的解释更新的代码。我收到“然后不是函数”错误。
var Promise = require('bluebird');
var Converter = Promise.promisifyAll(require("csvtojson")).Converter;
var converter = new Converter({});
var Client = Promise.promisifyAll(require('node-rest-client')).Client;
var client = new Client();
var responseArray = [];
converter.fromFile("./ToterFeed.csv").then(function(err,result){
for (var i = 0, len = result.length; i < len; i++) {
var args = {
data: JSON.stringify(result[i]),
headers: { "Content-Type": "application/json" }
};
client.post("http://192.168.1.102:8080/api/ToterFeed/v1", args, function (data, response) {
responseArray.push(data.responses);
console.log(data.responses[0]);
});
}
}).then(console.log("done"));
我的目标是运行填充读取和数组迭代以完成操作,然后打印“完成”。非常感谢任何见解!谢谢。
最佳答案
您几乎已经到了,需要做一些小的更改-HTTP帖子也将是异步的,因此,当您使用promisifyAll对其进行包装时,您可以从第一个回调中返回它(这意味着随后对.then的调用将等待它完成)。另请注意promisifyAll creates extra functions with a suffix of Async,因此您需要调用这些版本以重新获得承诺。
当您遍历数组并创建多个帖子时,需要使用Promise.all等待所创建的所有诺言的完成。
最后,最终的console.log
需要包装在函数中(.then()
始终将函数作为参数)。这样的事情应该起作用:
var Promise = require('bluebird');
var Converter = Promise.promisifyAll(require("csvtojson")).Converter;
var converter = new Converter({});
var Client = Promise.promisifyAll(require('node-rest-client').Client);
var responseArray = [];
converter.fromFileAsync("./ToterFeed.csv").then(function(result){
var promises = [];
for (var i = 0, len = result.length; i < len; i++) {
var args = {
data: JSON.stringify(result[i]),
headers: { "Content-Type": "application/json" }
};
// Add a promise to the array of promises - this
// will call the post then process the result.
promises.push(
Client.postAsync(
"http://192.168.1.102:8080/api/ToterFeed/v1",
args
).then(function (data) {
responseArray.push(data.responses);
}));
}
// Return Promise.all on all of our posts and
// their response handlers
return Promise.all(promises);
}).then(function () {
console.log("done");
});