我正在尝试让我在本地工作的节点应用程序实现webtask函数。Webtask提供了一个模板,它有一个上下文(ctx)和一个回调(cb)作为两个参数:
module.exports = function(ctx, cb) {
cb(null, { hello: ctx.data.name || 'Anonymous' });
};我有半工作的代码,看起来像这样:
const PDFParser = require('pdf2json@1.1.7')
const request = require('request')
module.exports = function(ctx, cb) {
const pdfParser = new PDFParser();
const pdfUrl = ctx.body.data.url;
const pdfPipe = request({url: pdfUrl, encoding:null}).pipe(pdfParser);
const data = []; //define empty array for response data
pdfPipe.on("pdfParser_dataError", err => console.error(err) );
pdfPipe.on("pdfParser_dataReady", pdf => {
data.push(pdfParser.getAllFieldsTypes()); //push data into array
console.log("data", data); //log the result
});
cb(null, data );
};我需要将更新后的“数据”发送到回调函数,但不知道如何发送。我当前返回的是一个空数组(初始const data = []),但是我的console.log("data", data)返回了期望的结果。
https://stackoverflow.com/questions/44379406
复制相似问题