NestJS中使用Axios调用API无法打印完整响应及保存文件如何解决

根因分析 #

@nestjs/axios的HttpService返回的是冷Observable类型，只有被订阅时才会真实发起请求、返回响应数据。NestJS内置了对Observable返回值的自动订阅逻辑，所以前端直接访问接口可以正常拿到数据，但你在Controller中直接打印未订阅的Observable实例、或者在请求未触发时尝试读取响应内容，自然只能拿到空对象。

解决方案 #

方案1：Service层通过pipe加tap操作符处理（推荐） #

不需要修改原有Controller逻辑，直接在Service的流处理中完成日志打印、文件写入的副作用操作，对业务逻辑侵入性最低。

示例代码

1. Service层实现：

import { Injectable } from '@nestjs/common';
import { HttpService } from '@nestjs/axios';
import { map, tap, catchError } from 'rxjs';
import * as fs from 'fs/promises';
import * as path from 'path';

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

  fetchRandomUser() {
    return this.httpService.get('https://randomuser.me/api/').pipe(
      // 提取接口实际返回的data字段，不需要保存完整Axios响应可保留该逻辑
      map(res => res.data),
      // tap专门用于执行副作用操作，不会修改流中的数据
      tap(async (responseData) => {
        // 打印完整响应
        console.log('接口完整响应内容：', JSON.stringify(responseData, null, 2));
        // 写入本地文件，可自定义存储路径
        const savePath = path.join(process.cwd(), 'user-response.json');
        await fs.writeFile(savePath, JSON.stringify(responseData, null, 2), 'utf-8');
      }),
      catchError(err => {
        console.error('请求接口失败：', err);
        throw err;
      })
    )
  }
}

2. Controller层直接返回Observable即可，原有逻辑无需修改：

import { Controller, Get } from '@nestjs/common';
import { UserService } from './user.service';

@Controller('user')
export class UserController {
  constructor(private readonly userService: UserService) {}

  @Get()
  getRandomUser() {
    return this.userService.fetchRandomUser();
  }
}

方案2：Controller层转Promise处理 #

如果需要在Controller层做业务判断再处理日志和存储，可以用firstValueFrom将Observable转为Promise，用async/await获取响应后再操作。

示例代码

1. Service层保持原有返回Observable的逻辑即可：

import { Injectable } from '@nestjs/common';
import { HttpService } from '@nestjs/axios';
import { map, catchError } from 'rxjs';

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

  fetchRandomUser() {
    return this.httpService.get('https://randomuser.me/api/').pipe(
      map(res => res.data),
      catchError(err => {
        throw err;
      })
    )
  }
}

2. Controller层异步获取响应后处理：

import { Controller, Get } from '@nestjs/common';
import { UserService } from './user.service';
import { firstValueFrom } from 'rxjs';
import * as fs from 'fs/promises';
import * as path from 'path';

@Controller('user')
export class UserController {
  constructor(private readonly userService: UserService) {}

  @Get()
  async getRandomUser() {
    // 把Observable转为Promise，等待请求完成拿到响应数据
    const responseData = await firstValueFrom(this.userService.fetchRandomUser());
    // 正常打印日志
    console.log('Controller拿到的完整响应：', responseData);
    // 写入本地文件
    const savePath = path.join(process.cwd(), 'controller-response.json');
    await fs.writeFile(savePath, JSON.stringify(responseData, null, 2), 'utf-8');
    // 返回响应给前端
    return responseData;
  }
}

注意事项 #

• 不要直接在Controller层调用subscribe方法订阅Observable后返回订阅对象，会导致前端无法拿到响应数据
• 生产环境写文件时注意校验路径权限，避免写入失败
• 若需要保存完整的Axios响应头、状态码等信息，去掉Service层的map(res => res.data)逻辑，直接处理整个响应对象即可
• 大体积响应推荐用流式写入，避免占用过多内存

内容的提问来源于stack exchange，提问作者Bat man