使用Axios和NestJS从Firebase Realtime Database获取数据报循环结构错误
报错原因
@nestjs/axios提供的HttpService所有请求方法返回值为RxJS Observable类型,本身不支持直接用await调用,你当前代码中await拿到的仍然是Observable对象,该对象内部存在循环引用的结构,NestJS框架尝试将返回值序列化为JSON响应时触发了该报错。- 方法定义的返回类型
Promise<Observable<AxiosResponse<any>>>不符合实际需求,你需要返回的是Firebase接口返回的业务数据,而非原始的Observable对象或完整Axios响应实例。
解决方案
提供两种常用的修复方案,按需选择即可:
方案1:转Promise用async/await写法
适配你原本想用async/await的编码习惯,用RxJS提供的firstValueFrom方法将Observable转为Promise后再等待结果:
import { Injectable } from '@nestjs/common'; import { HttpService } from '@nestjs/axios'; import { firstValueFrom } from 'rxjs'; @Injectable() export class AppService { constructor(private httpService: HttpService) {} async getHello(): Promise<any> { // 将Observable转为Promise,拿到完整Axios响应对象 const axiosResponse = await firstValueFrom( this.httpService.get('[你的Firebase请求URL]') ); // 仅返回响应体内的业务数据,避免返回完整Axios实例带来的额外问题 return axiosResponse.data; } }
如果你使用的是RxJS 6及更旧版本,可临时用
.toPromise()替代firstValueFrom,该方法在RxJS 7中已被废弃,高版本优先用firstValueFrom。
方案2:直接返回Observable(Nest原生支持)
NestJS原生支持控制器/服务返回Observable类型,会自动订阅并提取数据返回给前端,无需手动转Promise:
import { Injectable } from '@nestjs/common'; import { HttpService } from '@nestjs/axios'; import { Observable } from 'rxjs'; import { map } from 'rxjs/operators'; @Injectable() export class AppService { constructor(private httpService: HttpService) {} getHello(): Observable<any> { return this.httpService.get('[你的Firebase请求URL]').pipe( // 用map操作符提取响应体内的业务数据 map(axiosResponse => axiosResponse.data) ); } }
内容的提问来源于stack exchange,提问作者fafafaafa
相关产品推荐
相关产品推荐

