我正在编写一个服务,它通过REST API接受一些数据,并将这些数据推送到
worker_thread
202 Accepted
. 正在处理的部分数据包括一个回调url,其思想是当数据被处理后,它将被发布到回调url。我从没用过
worker_threads
在此之前,我是否可以让我的工作线程使用Axios将数据发送回调用方?
我的工人会是这样的。
const { parentPort } = require('worker_threads')
const axios = require('axios')
const analyse = async ({ callbackUrl, ...data }) => {
// ... do analysis of data and create a result object
await axios.post(callbackUrl, { result })
}
parentPort.on("message", analyse)