我需要一个控制器动作:
前两点很简单,我使用AuthGuard然后是class-validator。但我不知道如何返回HTTP响应,然后继续处理。
由于请求由一组(可能是长时间运行的)任务组成,我想使用拦截器来观察任务的状态,并在任务完成后调用外部PI。但是,我没有使用RxJS或拦截器的经验(不是这样),所以我真的不知道如何让拦截器的进程运行,而是立即将控制传递给控制器的操作。
另外,也许还有另外一种更好的方法?没有拦截器,只是把所有的流逻辑放在控制器中?还有别的选择吗?
发布于 2018-11-09 21:02:40
我希望您有一个执行外部API调用(异步)并返回Promise或Observable的服务。
@Injectable()
export class ExternalApiService {
constructor(private readonly httpService: HttpService) {}
makeApiCall(data): Observable<AxiosResponse<any>> {
return this.httpService.post('https://external.api', data);
}
}我还假设有一个PreprocesserService进行异步调用(例如,从数据库获取用户信息)。
控制器
@Post()
@UseGuards(AuthGuard('jwt'))
@HttpCode(HttpStatus.ACCEPTED)
async post(@Body(new ValidationPipe()) myDataDto: MyDataDto) {
// The preprocessing might throw an exception, so we need to wait for the result
const preprocessedData = await this.preprocessService.preprocess(myDataDto);
^^^^^
// We do not need the result to respond to the request, so no await
this.externalApiService.makeApiCall(preprocessedData);
return 'Your data is being processed.';
}当您进行异步调用时,只有通过使用async/await或返回一个Promise / Observable来显式通知控制器方法,控制器方法的执行才会等待。
在本例中,我们希望在发送响应之前等待this.preprocessService.preprocess(myDataDto)的结果。我们使用await (必须将该方法声明为async)来实现这一点。
我们希望向外部API发出请求,但我们不需要响应的结果。因为我们不是这里使用的await,所以它将进行http调用,并立即执行下一行(返回语句),而无需等待结果。
发布于 2018-11-09 15:03:40
如果您的服务返回一个承诺,您可以执行如下操作,则在处理继续时,API将返回202。当然,在“beginProcessing”完成之后,任何带有“那时”的处理都会发生。
@Post()
@HttpCode(HttpStatus.ACCEPTED)
beginProcessing(@Req() request, @Body() data: Data): void {
this.service.process(data).then(...);
}https://stackoverflow.com/questions/53205581
复制相似问题