Apollo服务器多个第三方Apis

const { ApolloServer, gql } = require('apollo-server');
const axios = require('axios');

// 定义Schema
const typeDefs = gql`
  type Query {
    getDataFromApi1: String
    getDataFromApi2: String
  }
`;

// 定义Resolvers
const resolvers = {
  Query: {
    getDataFromApi1: async () => {
      const response = await axios.get('https://api.example.com/data1');
      return response.data;
    },
    getDataFromApi2: async () => {
      const response = await axios.get('https://api.example.com/data2');
      return response.data;
    },
  },
};

// 创建Apollo服务器
const server = new ApolloServer({ typeDefs, resolvers });

server.listen().then(({ url }) => {
  console.log(`🚀 Server ready at ${url}`);
});

const DataLoader = require('dataloader');

// 创建数据加载器
const api1Loader = new DataLoader(async (keys) => {
  const responses = await axios.all(keys.map(key => axios.get(`https://api.example.com/data1/${key}`)));
  return responses.map(response => response.data);
});

const api2Loader = new DataLoader(async (keys) => {
  const responses = await axios.all(keys.map(key => axios.get(`https://api.example.com/data2/${key}`)));
  return responses.map(response => response.data);
});

// 在Resolver中使用数据加载器
const resolvers = {
  Query: {
    getDataFromApi1: async (_, { id }) => api1Loader.load(id),
    getDataFromApi2: async (_, { id }) => api2Loader.load(id),
  },
};

// apiService.js
const axios = require('axios');

class ApiService {
  async getDataFromApi1(id) {
    const response = await axios.get(`https://api.example.com/data1/${id}`);
    return response.data;
  }

  async getDataFromApi2(id) {
    const response = await axios.get(`https://api.example.com/data2/${id}`);
    return response.data;
  }
}

module.exports = new ApiService();

// resolvers.js
const apiService = require('./apiService');

const resolvers = {
  Query: {
    getDataFromApi1: async (_, { id }) => apiService.getDataFromApi1(id),
    getDataFromApi2: async (_, { id }) => apiService.getDataFromApi2(id),
  },
};

// apollo-server-plugin-api.js
const axios = require('axios');

class ApiPlugin {
  async getDataFromApi1({ id }) {
    const response = await axios.get(`https://api.example.com/data1/${id}`);
    return response.data;
  }

  async getDataFromApi2({ id }) {
    const response = await axios.get(`https://api.example.com/data2/${id}`);
    return response.data;
  }
}

module.exports = new ApiPlugin();

// server.js
const { ApolloServer, gql } = require('apollo-server');
const apiPlugin = require('./apollo-server-plugin-api');

const typeDefs = gql`
  type Query {
    getDataFromApi1(id: ID!): String
    getDataFromApi2(id: ID!): String
  }
`;

const resolvers = {
  Query: {
    getDataFromApi1: apiPlugin.getDataFromApi1.bind(apiPlugin),
    getDataFromApi2: apiPlugin.getDataFromApi2.bind(apiPlugin),
  },
};

const server = new ApolloServer({
  typeDefs,
  resolvers,
  plugins: [apiPlugin],
});

server.listen().then(({ url }) => {
  console.log(`🚀 Server ready at ${url}`);
});