Проблемы интеграции Python graphene с Apollo Federation

Решение на самом деле представляет собой небольшой взлом схемы, которая автоматически генерируется через graphene. Я думал, что уже пробовал это, и это все еще работало, но я только что сделал это снова, но оно сломалось.

Так что если в Ариадне я добавлю

schema {
    query: Query
}

в sdl Федерация Аполлона также повышает Type Query must define one or more fields.. Без него работает нормально. Тогда я тоже перешел к графену и в функции resolve_service сделал:

def resolve_service(self, info, **kwargs):
    from config.settings.shared import get_loaded_sdl
    res = get_loaded_sdl()
    res = res.replace("schema {\n  query: Query\n}\n\n", "")
    return _Service(sdl=res)

И теперь графен тоже работает, так что я думаю, проблема была в том, что я упустил из виду, кажется, что Apollo Federation не может обрабатывать грамматику схемы:

schema {
    query: Query
}

Обновление 1

Строка, которую я не заметил на веб-сайте Apollo, заключается в следующем:

This SDL does not include the additions of the federation spec above. Given an input like this:

Это ясно при объединении сервисов вместе в Federation, так как это вызовет ошибку:

GraphQLSchemaValidationError: Field "_Service.sdl" can only be defined once.

Таким образом, несмотря на то, что в полной схеме для микросервиса с определением _Service.sdl мы хотим, чтобы эта информация исчезла для строки полной схемы, возвращаемой в качестве возвращаемой строки для _Service.sdl

Обновление 2

Федерация Apollo теперь работает нормально, убедившись, что строка, возвращаемая полем sdl, не содержит спецификаций федерации.

Я думаю, что в графене каждая реализация может отличаться, но в целом вы хотите заменить следующее:

res = get_loaded_sdl()
res = res.replace("schema {\n  query: Query\n}\n\n", "")
res = res.replace("type _Service {\n  sdl: String\n}", "")
res = res.replace("\n  _service: _Service!", "")

А в Ariadne просто нужно определить два sdl, один из которых содержит спецификации федерации (для схемы, возвращаемой службой), а другой без спецификаций федерации (тот, который возвращается полем sdl)

Вы на правильном пути к другому ответу, но похоже, что вам нужно будет кое-что вырезать из печатной версии.

вот как я использовал в проблема с гитхабом

я резюмирую свой код здесь:

schema = ""
class ServiceField(graphene.ObjectType):
    sdl = String()

    def resolve_sdl(parent, _):
        string_schema = str(schema)
        string_schema = string_schema.replace("\n", " ")
        string_schema = string_schema.replace("type Query", "extend type Query")
        string_schema = string_schema.replace("schema {   query: Query   mutation: MutationQuery }", "")
        return string_schema


class Service:
    _service = graphene.Field(ServiceField, name = "_service", resolver=lambda x, _: {})

class Query(
    # ...
    Service,
    graphene.ObjectType,
):
    pass

schema = graphene.Schema(query=Query, types=CUSTOM_ATTRIBUTES_TYPES)

Эта библиотека пипов может помочь https://pypi.org/project/graphene-federation/

Просто используйте build_schema, и он добавит для вас _service{sdl}:

import graphene
from graphene_federation import build_schema


class Query(graphene.ObjectType):
    ...
    pass

schema = build_schema(Query)  # add _service{sdl} field in Query

Если кому-то интересно, это потому, что графен v2 использует запятые вместо амперсандов в интерфейсах.

interface x implements y, z {
   ...
}

и этот синтаксис больше не работает, обходным путем является обезьяний патч get_sdl

import re

from myproject import Query, Mutation
from graphene_federation import service, build_schema


# monkey patch old get_sdl
old_get_sdl = service.get_sdl

def get_sdl(schema, custom_entities):
    string_schema = old_get_sdl(schema, custom_entities)
    string_schema = string_schema.replace('\n', ' ')

    pattern_types_interfaces = r'type [A-Za-z]* implements ([A-Za-z]+\s*,?\s*)+'
    pattern = re.compile(pattern_types_interfaces)

    string_schema = pattern.sub(lambda matchObj: matchObj.group().replace(',', ' &'), string_schema)
    return string_schema

service.get_sdl = get_sdl
schema = build_schema(Query, mutation=Mutation)

и это работает.