最佳实践，组合多个rest调用以在apollo服务器中填充1个graphQL类型

Question

我有graphql用户类型，该用户类型需要来自多个REST API和不同服务器的信息。基本示例：从其余域1获取用户名，从其余域2获取用户名。这两个其余域都有一个公共的“ userID”属性。

我的解析器代码atm的简化示例：

user: async (_source, args, { dataSources }) => {
  try {
    const datasource1 = await dataSources.RESTAPI1.getUser(args.id);
    const datasource2 = await dataSources.RESTAPI2.getUser(args.id);

    return { ...datasource1, ...datasource2 };
  } catch (error) {
    console.log("An error occurred.", error);
  }
  return [];
}

此版本适用于此简化版本，但此解决方案有2个问题：首先，IRL有很多逻辑要合并2个json结果。由于某些字段是共享的但具有不同的数据（或为空）。因此，就像樱桃选择两个结果来创建组合结果。

我的第二个问题是，这仍然是瀑布方法。首先从restapi1获取数据，完成后调用restapi2。基本上，阿波罗服务器正在重新引入rest-waterfall-fetch graphql试图解决的问题。

请牢记这两个问题。我可以优化这段代码还是重写，以提高性能或可读性？还是有任何软件包可以帮助解决此问题？

非常感谢！

Answer 1

假设您的user解析器返回type User遗忘...

type User {
  id: ID!
  datasource1: RandomType
  datasource1: RandomType
}

您可以为type User中的每个字段创建单独的解析器，这可以将user查询的复杂度降低到仅请求的字段。

query {
 user {
  id
  datasource1 {
    ...
  }
 }
}

const resolvers = {
    Query: {
        user: () => {
            return { id: "..." };
        }
    },
    User: {
        datasource1: () => { ... },
        datasource2: () => { ... } // i wont execute
    }
};

datasource1和datasource2解析器仅在执行Query.user之后才并行执行。

Answer 2

关于性能，如果两个调用彼此独立，则可以利用Promise.all并行执行它们：

const [dataSource1,dataSource2] = await Promise.all([
  dataSources.RESTAPI1.getUser(args.id),
  dataSources.RESTAPI2.getUser(args.id),
])

通常，我们让GraphQL的默认解析器逻辑来完成繁重的工作，但是如果您发现需要从两个调用中“挑选”数据，则可以在根解析器中返回类似的内容：

return { dataSource1, dataSource2 }

然后为每个字段编写解析器：

const resolvers = {
  User: {
    someField: ({ dataSource1, dataSource2 }) => {
      return dataSource1.a || dataSource2.b
    },
    someOtherField: ({ dataSource1, dataSource2 }) => {
      return someCondition ? dataSource1.foo : dataSource2.bar
    },
  }
}

Answer 3

用于并行呼叫。

const users = async (_source, args, { dataSources }) => {
  try {
    const promises = [
      dataSources.RESTAPI1,
      dataSources.RESTAPI2
    ].map(({ getUser }) => getUser(args.id));
    const data = await Promise.all(promises);
    return Object.assign({}, ...data);
  } catch (error) {
    console.log("An error occurred.", error);
  }
  return [];
};