如何在GraphQL服务器中连接两个REST数据源？

在GraphQL服务器中连接两个REST数据源通常涉及到数据获取、转换和合并的过程。以下是实现这一目标的基本步骤和相关概念：

基础概念

GraphQL: 一种用于API的查询语言，允许客户端请求所需的数据结构。
REST API: 一种基于HTTP协议的网络应用程序接口设计风格，用于构建分布式系统。
数据连接器: 用于从不同的数据源获取数据并将其整合到GraphQL服务器中的工具或库。

类型

数据获取器（Data Fetchers）: 负责从REST API获取数据的函数。
数据转换器（Data Transformers）: 将获取的数据转换为GraphQL所需的格式。
数据合并器（Data Merger）: 将来自不同数据源的数据合并为一个统一的响应。

应用场景

当你需要从多个外部服务获取数据并整合到一个GraphQL接口中时。
当你需要提供一个统一的API接口，但数据分布在多个REST服务中时。

实现步骤

定义GraphQL Schema: 定义GraphQL的类型和查询，描述客户端可以请求的数据结构。
创建数据获取器: 编写函数从REST API获取数据。
创建数据转换器: 将获取的REST数据转换为GraphQL所需的格式。
创建数据合并器: 将转换后的数据合并为一个响应。
集成到GraphQL服务器: 将数据获取器、转换器和合并器集成到GraphQL的解析器中。

示例代码

以下是一个简单的示例，展示如何在Node.js中使用apollo-server和axios来实现这一过程。

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

// 定义GraphQL Schema
const typeDefs = gql`
  type Query {
    combinedData: CombinedDataType
  }

  type CombinedDataType {
    data1: Data1Type
    data2: Data2Type
  }

  type Data1Type {
    id: ID
    name: String
  }

  type Data2Type {
    id: ID
    value: Int
  }
`;

// 创建数据获取器
async function fetchData1() {
  const response = await axios.get('https://api.example.com/data1');
  return response.data;
}

async function fetchData2() {
  const response = await axios.get('https://api.example.com/data2');
  return response.data;
}

// 创建数据合并器
async function getCombinedData() {
  const data1 = await fetchData1();
  const data2 = await fetchData2();
  return { data1, data2 };
}

// 创建解析器
const resolvers = {
  Query: {
    combinedData: async () => {
      return getCombinedData();
    },
  },
};

// 创建Apollo Server实例
const server = new ApolloServer({ typeDefs, resolvers });

// 启动服务器
server.listen().then(({ url }) => {
  console.log(`🚀 Server ready at ${url}`);
});