我正在开发一个Google Cloud Functions,它可以调用Dataflow作业并在数据存储区中存储数据流作业的ID . 这部分工作完美 .
我的问题在于另一个读取数据存储区的 Cloud 功能(通过HTTP触发) . Cloud 功能似乎完全异步,并在数据存储功能发送一些数据之前结束 .
我从原始节点-js数据存储api https://github.com/googleapis/nodejs-datastore/blob/master/samples/tasks.js获取了数据存储区示例
我的代码:
exports.processJobs = (req, res) => {
jobList = "";
console.log(` INIT processJobs`);
const query = datastore.createQuery('Job').filter('finished', '=', false);
datastore
.runQuery(query)
.then(results => {
const jobs = results[0];
console.log('Jobs:');
jobs.forEach(job => {
const jobKey = job[datastore.KEY];
console.log(jobKey, job);
jobList = jobList + job.jobId;
});
})
.catch(err => {
console.error('ERROR:', err);
});
console.log(` END processJobs`);
res.status(200).send(":" + jobList);
}
如果我按照我的函数生成的日志,我会显示该函数结束,然后它将作业显示在控制台中:
2018-06-25 13:58:00.496 Function execution took 384 ms, finished with status code: 200
2018-06-25 13:59:14.774 Jobs:
2018-06-25 13:59:16.191 undefined { jobId: '2018-06-25_01_07_33-9128665201904101921',
beginTime: 2018-06-25T08:07:34.980Z,
finished: false,
status: 'JOB_STATE_RUNNING' }
UPDATE:
解决方案是根据解决方案中的要求将响应移动到“then”部分:
datastore
.runQuery(query)
.then(results => {
const jobs = results[0];
console.log('Jobs:');
jobs.forEach(job => {
const jobKey = job[datastore.KEY];
console.log(jobKey.id, job);
jobList = jobList + job.jobId;
});
res.status(200).send("Response:_" + jobList );
})
1 回答
这是因为您在收到结果之前发送了回复 . 在执行
res.status().send()
之后, Cloud 功能将限制您的功能上的资源并清理它,可能会杀死正在进行的任何异步工作 .您需要等到所有异步工作完成后再发送响应 . 这意味着您应该将响应移动到数据存储区承诺的
then
和catch
块中,以便仅在工作完成后发送响应 .See the documentation for more information和例子 .