Micronauts Обработчик потока запросов AWS не вводит службу

Question

У меня есть простой лямбда-запрос Micronaut AWS, обработанный с использованием функции micronaut-function-aws.

Сервис, который я внедряю, кажется, не создается, когда он запускается в AWS.

Если я выполняю весь обработчик функций groovy script и использую @Field @Singleton TestService testService, то, кажется, он работает нормально при локальном запуске.

Есть идеи, что я делаю не так?

Обслуживание:

package testtest

import groovy.transform.CompileStatic

@CompileStatic
@Singleton
class TestService {
    String test = "Test"
}

обработчик:

package testtest

import com.amazonaws.services.lambda.runtime.Context
import io.micronaut.function.aws.MicronautRequestStreamHandler

import javax.inject.Inject

class TestHandler extends MicronautRequestStreamHandler {

    @Inject TestService testService

    @Override
    protected void execute(InputStream input, OutputStream output, Context context) throws IOException {
        output << testService.test
    }
}

Трассировка стека от AWS лямбда

Cannot get property 'test' on null object: java.lang.NullPointerException
java.lang.NullPointerException: Cannot get property 'test' on null object
    at org.codehaus.groovy.runtime.NullObject.getProperty(NullObject.java:60)
    at org.codehaus.groovy.runtime.InvokerHelper.getProperty(InvokerHelper.java:190)
    at org.codehaus.groovy.runtime.callsite.AbstractCallSite.callGroovyObjectGetProperty(AbstractCallSite.java:304)
    at testtest.TestHandler.execute(TestHandler.groovy:14)
    at testtest.TestHandler.execute(TestHandler.groovy)
    at io.micronaut.function.aws.MicronautRequestStreamHandler.handleRequest(MicronautRequestStreamHandler.java:40)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)

Answer 1

Так что я не уверен в правильном способе использования MicronautRequestStreamHandler, но я нашел способ обойти это (или просто правильный способ сделать это).

Я создал новый Function @FunctionBean и затем возвращаю имя функции из переопределения метода MicronautRequestStreamHandler resolFunctionName.

class AuthHandler  extends MicronautRequestStreamHandler {

@Override
protected String resolveFunctionName(Environment environment) {
    return "auth"
}

}

@FunctionBean('auth')
class AuthFunction implements Function<InputStream, AuthResponse> {

  @Inject
  AuthService authService

  @Override
  AuthResponse  apply(InputStream input) {
    // stuff etc
  }
}

Функция внедряет сервис правильно.

Действительно просто копирование того, как они тестируют MicronautRequestStreamHandler MicronautRequestStreamHandlerSpec.groovy

Надеюсь, что это помогает другим...