从nestjs中的可观察grpc服务中获取数据，

import { Module } from '@nestjs/common';
import { ClientsModule, Transport } from '@nestjs/microservices';

@Module({
  imports: [
    ClientsModule.register([
      {
        name: 'GRPC_SERVICE',
        transport: Transport.GRPC,
        options: {
          url: 'localhost:5000', // gRPC服务的地址
          package: 'your_package_name', // gRPC服务的包名
          protoPath: 'path_to_your_proto_file', // gRPC服务的proto文件路径
        },
      },
    ]),
  ],
})
export class YourModule {}

import { Injectable, Inject } from '@nestjs/common';
import { ClientGrpc } from '@nestjs/microservices';

@Injectable()
export class YourService {
  constructor(@Inject('GRPC_SERVICE') private readonly grpcClient: ClientGrpc) {}

  async getData(): Promise<any> {
    const grpcService = this.grpcClient.getService<any>('YourService');
    return grpcService.getData().toPromise();
  }
}

import { Controller, Get } from '@nestjs/common';
import { YourService } from './your.service';

@Controller('your')
export class YourController {
  constructor(private readonly yourService: YourService) {}

  @Get('data')
  async getData(): Promise<any> {
    return this.yourService.getData();
  }
}