如何返回202 Accepted,然后在Nest.js中继续处理请求

Promise Observable :

@Injectable()
export class ExternalApiService {
  constructor(private readonly httpService: HttpService) {}

  makeApiCall(data): Observable<AxiosResponse<any>> {
    return this.httpService.post('https://external.api', data);
  }
}

我还假设有一个进行异步调用的预处理服务(例如从数据库获取用户信息)。

控制器

@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 或返回 承诺 可观察的 .

在本例中,我们希望等待 this.preprocessService.preprocess(myDataDto) 在我们发送回复之前。我们通过使用 await (方法必须声明为 async ).

等待

如果您的服务返回一个承诺,您可以执行如下操作,那么在处理过程继续时,API将返回202。当然,“then”的任何处理都是在“beginProcessing”完成之后进行的。

@Post()
@HttpCode(HttpStatus.ACCEPTED)
beginProcessing(@Req() request, @Body() data: Data): void {
    this.service.process(data).then(...);
}