ぷすぅ～ぷすぅ～

micronaut(2.3.2) w/ groovy と GORM を使うアプリで、ローカル環境だと動作するけどLambda上だと以下のようなエラーになった。
Lambdaは、Serverless Function ではく、Applicationとして構築している。

以下のようなエラー


Error starting Micronaut container: No GORM implementations configured. Ensure GORM has been initialized correctly: com.amazonaws.serverless.exceptions.ContainerInitializationException
com.amazonaws.serverless.exceptions.ContainerInitializationException: Error starting Micronaut container: No GORM implementations configured. Ensure GORM has been initialized correctly
	at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.initialize(MicronautLambdaContainerHandler.java:259)
	at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.<init>(MicronautLambdaContainerHandler.java:153)
	at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.<init>(MicronautLambdaContainerHandler.java:128)
	at io.micronaut.function.aws.proxy.MicronautLambdaHandler.<init>(MicronautLambdaHandler.java:45)
	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source)
	at java.base/java.lang.reflect.Constructor.newInstance(Unknown Source)
Caused by: java.lang.IllegalStateException: No GORM implementations configured. Ensure GORM has been initialized correctly
	at org.grails.datastore.gorm.GormEnhancer.findSingleDatastore(GormEnhancer.groovy:378)
	at sdbackend.service.$SdmRoleGormServiceImplementation.getTargetDatastore(SdmRoleGormService.groovy)
	at sdbackend.service.$SdmRoleGormServiceImplementation.list(SdmRoleGormService.groovy)
	at sdbackend.Bootstrap$_onApplicationEvent_lambda3.doCall(Bootstrap.groovy:61)
	at java.base/java.util.Optional.orElseGet(Unknown Source)
	at sdbackend.Bootstrap.onApplicationEvent(Bootstrap.groovy:57)
	at sdbackend.Bootstrap.onApplicationEvent(Bootstrap.groovy)
	at io.micronaut.context.DefaultBeanContext.notifyEventListeners(DefaultBeanContext.java:1307)
	at io.micronaut.context.DefaultBeanContext.publishEvent(DefaultBeanContext.java:1292)
	at io.micronaut.context.DefaultBeanContext.start(DefaultBeanContext.java:248)
	at io.micronaut.context.DefaultApplicationContext.start(DefaultApplicationContext.java:166)
	at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.initialize(MicronautLambdaContainerHandler.java:239)
	... 7 more

Error starting Micronaut container: No GORM implementations configured. Ensure GORM has been initialized correctly: com.amazonaws.serverless.exceptions.ContainerInitializationException

com.amazonaws.serverless.exceptions.ContainerInitializationException: Error starting Micronaut container: No GORM implementations configured. Ensure GORM has been initialized correctly

at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.initialize(MicronautLambdaContainerHandler.java:259)

at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.<init>(MicronautLambdaContainerHandler.java:153)

at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.<init>(MicronautLambdaContainerHandler.java:128)

at io.micronaut.function.aws.proxy.MicronautLambdaHandler.<init>(MicronautLambdaHandler.java:45)

at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)

at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)

at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source)

at java.base/java.lang.reflect.Constructor.newInstance(Unknown Source)

Caused by: java.lang.IllegalStateException: No GORM implementations configured. Ensure GORM has been initialized correctly

at org.grails.datastore.gorm.GormEnhancer.findSingleDatastore(GormEnhancer.groovy:378)

at sdbackend.service.$SdmRoleGormServiceImplementation.getTargetDatastore(SdmRoleGormService.groovy)

at sdbackend.service.$SdmRoleGormServiceImplementation.list(SdmRoleGormService.groovy)

at sdbackend.Bootstrap$_onApplicationEvent_lambda3.doCall(Bootstrap.groovy:61)

at java.base/java.util.Optional.orElseGet(Unknown Source)

at sdbackend.Bootstrap.onApplicationEvent(Bootstrap.groovy:57)

at sdbackend.Bootstrap.onApplicationEvent(Bootstrap.groovy)

at io.micronaut.context.DefaultBeanContext.notifyEventListeners(DefaultBeanContext.java:1307)

at io.micronaut.context.DefaultBeanContext.publishEvent(DefaultBeanContext.java:1292)

at io.micronaut.context.DefaultBeanContext.start(DefaultBeanContext.java:248)

at io.micronaut.context.DefaultApplicationContext.start(DefaultApplicationContext.java:166)

at io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler.initialize(MicronautLambdaContainerHandler.java:239)

... 7 more

solution

Lambda 経由だと、通常のmainがエントリーポイントではなく、Application の場合は MicronautLambdaHandler がエントリーポイントとなる。
Server function だと、MicronautRequestHandler もしくは、MicronautRequestStreamHandler　になる。

MicronautLambdaHandler を拡張したクラスを作成して、GORMのDomain郡があるパッケージを指定してあげる。


class MyLambdaHandler extends MicronautLambdaHandler {

    MyLambdaHandler() throws ContainerInitializationException {
        super(ApplicationContext.build().packages("mypackage.domain"))
    }

}

class MyLambdaHandler extends MicronautLambdaHandler {

MyLambdaHandler() throws ContainerInitializationException {

super(ApplicationContext.build().packages("mypackage.domain"))

}

とうまくいった。

micronaut に限らず、GraphQL Java を利用していればSpring boot や他のフレームワークでも同じことができます。
また、groovy で書いてますが、Java / kotlin でも同様のことは実装できます。

schema

こんな感じのschema


type Query {
  someExample : ReturnType
}
union ReturnType = ReturnTypeA | ReturnTypeB
type ReturnTypeA {
  id: ID!
  name: String
}

type ReturnTypeB {
  id: ID!
  name: String
  extra: String
}

type Query {

someExample : ReturnType

}

union ReturnType = ReturnTypeA | ReturnTypeB

type ReturnTypeA {

id: ID!

name: String

}

type ReturnTypeB {

id: ID!

name: String

extra: String

}

ReturnType が、ReturnTypeA と、ReturnTypeB の二つのどちらかとなる場合。

Groovy側ソース

GraphQL インスタンスの作成


@Factory
@CompileStatic
class GraphQLFactory {

    @Bean
    @Singleton
    GraphQL graphQL(ResourceResolver resourceResolver
                    , SomeExampleFetcher someExampleFetcher) {

        def schemaParser = new SchemaParser()
        def schemaGenerator = new SchemaGenerator()

        // Parse the schema.
        def typeRegistry = new TypeDefinitionRegistry()
        typeRegistry.merge(schemaParser.parse(new BufferedReader(new InputStreamReader(
                resourceResolver.getResourceAsStream("classpath:schema.graphqls").get()))))

        // Unionの型のResolver を作成
        TypeResolver typeResolverReturnType =  new TypeResolver() {
            @Override
            public GraphQLObjectType getType(TypeResolutionEnvironment env) {
                Object javaObject = env.getObject();
                if (javaObject instanceof ReturnTypeAclass) {
                    return env.getSchema().getObjectType("ReturnTypeA");
                } else if (javaObject instanceof ReturnTypeBclass) {
                    return env.getSchema().getObjectType("ReturnTypeB");
                }
            }
        };

        // someExample のFetherと、ReturnType の TypeResolver を指定
        def runtimeWiring = RuntimeWiring.newRuntimeWiring()
                .type("Query", {typeWiring ->
                    typeWiring.dataFetcher("someExample", someExampleFetcher)})
                .type("ReturnType", {typeWiriing ->
                    typeWiriing.typeResolver(typeResolverReturnType)})
                .build()


        // Create the executable schema.
        def graphQLSchema = schemaGenerator.makeExecutableSchema(typeRegistry, runtimeWiring)

        // Return the GraphQL bean.
        return GraphQL.newGraphQL(graphQLSchema).build()
    }
}

@Factory

@CompileStatic

class GraphQLFactory {

@Bean

@Singleton

GraphQL graphQL(ResourceResolver resourceResolver

, SomeExampleFetcher someExampleFetcher) {

def schemaParser = new SchemaParser()

def schemaGenerator = new SchemaGenerator()

// Parse the schema.

def typeRegistry = new TypeDefinitionRegistry()

typeRegistry.merge(schemaParser.parse(new BufferedReader(new InputStreamReader(

resourceResolver.getResourceAsStream("classpath:schema.graphqls").get()))))

// Unionの型のResolver を作成

TypeResolver typeResolverReturnType = new TypeResolver() {

@Override

public GraphQLObjectType getType(TypeResolutionEnvironment env) {

Object javaObject = env.getObject();

if (javaObject instanceof ReturnTypeAclass) {

return env.getSchema().getObjectType("ReturnTypeA");

} else if (javaObject instanceof ReturnTypeBclass) {

return env.getSchema().getObjectType("ReturnTypeB");

}

};

// someExample のFetherと、ReturnType の TypeResolver を指定

def runtimeWiring = RuntimeWiring.newRuntimeWiring()

.type("Query", {typeWiring ->

typeWiring.dataFetcher("someExample", someExampleFetcher)})

.type("ReturnType", {typeWiriing ->

typeWiriing.typeResolver(typeResolverReturnType)})

.build()

// Create the executable schema.

def graphQLSchema = schemaGenerator.makeExecutableSchema(typeRegistry, runtimeWiring)

// Return the GraphQL bean.

return GraphQL.newGraphQL(graphQLSchema).build()

}

それぞれ、schema に合わせた、クラスを作成


class ReturnTypeAclass {
    Integer id
    String name
}
class ReturnTypeBclass {
    String id
    String name
    String extra
}

class ReturnTypeAclass {

Integer id

String name

}

class ReturnTypeBclass {

String id

String name

String extra

}

最後に、DataFetcher


@Factory
@CompileStatic
class SomeExampleFetcher implements DataFetcher{
    @Override
    ReturnTypeAclass get(DataFetchingEnvironment environment) throws Exception {
        // ReturnTypeBclass を返せば、queryの結果もReturnTypeB になる。
        return new ReturnTypeAclass(id:1, name: "aaaaa")
    }
}

@Factory

@CompileStatic

class SomeExampleFetcher implements DataFetcher{

@Override

ReturnTypeAclass get(DataFetchingEnvironment environment) throws Exception {

// ReturnTypeBclass を返せば、queryの結果もReturnTypeB になる。

return new ReturnTypeAclass(id:1, name: "aaaaa")

}

実行

以下のクエリで、


query SomeExample {
  someExample {
    ... on ReturnTypeA {
      name
    }

    ... on ReturnTypeB {
      id
    }
    
  }
}

query SomeExample {

someExample {

... on ReturnTypeA {

name

}

... on ReturnTypeB {

}

結果こんな感じ


{
  "data": {
    "someExample": {
      "name": "aaaaa"
    }
  }
}

{

"data": {

"someExample": {

"name": "aaaaa"

}

[micronaut] AWS LambdaでGORMを使う

solution

[micronaut] graphQL でunionを使う

schema

Groovy側ソース

実行