io.micronaut.function.aws

Class MicronautRequestHandler<I,O>

java.lang.Object

io.micronaut.function.executor.AbstractFunctionExecutor<I,O,com.amazonaws.services.lambda.runtime.Context>

io.micronaut.function.aws.MicronautRequestHandler<I,O>

Type Parameters:

I - The request body type

O - The response body type

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestHandler<I,O>, io.micronaut.context.ApplicationContextProvider, MicronautLambdaContext, io.micronaut.function.executor.FunctionExecutor<I,O>, java.io.Closeable, java.lang.AutoCloseable

public abstract class MicronautRequestHandler<I,O>
extends io.micronaut.function.executor.AbstractFunctionExecutor<I,O,com.amazonaws.services.lambda.runtime.Context>
implements com.amazonaws.services.lambda.runtime.RequestHandler<I,O>, MicronautLambdaContext

An Amazon Lambda RequestHandler implementation for Micronaut FunctionBean

.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field and Description
protected io.micronaut.context.ApplicationContext	applicationContext
static java.lang.String	ENV_X_AMZN_TRACE_ID
static java.lang.String	MDC_DEFAULT_AWS_REQUEST_ID
static java.lang.String	MDC_DEFAULT_FUNCTION_ARN
static java.lang.String	MDC_DEFAULT_FUNCTION_MEMORY_SIZE
static java.lang.String	MDC_DEFAULT_FUNCTION_NAME
static java.lang.String	MDC_DEFAULT_FUNCTION_REMAINING_TIME
static java.lang.String	MDC_DEFAULT_FUNCTION_VERSION
static java.lang.String	MDC_DEFAULT_XRAY_TRACE_ID

Fields inherited from interface io.micronaut.function.aws.MicronautLambdaContext

ENVIRONMENT_LAMBDA

Constructor Summary

Constructors

Constructor and Description
MicronautRequestHandler() Constructor.

Method Summary

Modifier and Type	Method and Description
protected io.micronaut.context.ApplicationContext	buildApplicationContext(com.amazonaws.services.lambda.runtime.Context context)
protected I	convertInput(java.lang.Object input) Converts the input the required type.
O	handleRequest(I input, com.amazonaws.services.lambda.runtime.Context context)
protected void	mdcput(java.lang.String key, java.lang.String val) Put a diagnostic context value.
protected io.micronaut.context.ApplicationContextBuilder	newApplicationContextBuilder()
protected static java.util.Optional<java.lang.String>	parseXrayTraceId() Parses XRay Trace ID from _X_AMZN_TRACE_ID environment variable.
protected void	populateMappingDiagnosticContextValues(com.amazonaws.services.lambda.runtime.Context context)
protected void	populateMappingDiagnosticContextWithXrayTraceId() Populate MDC with XRay Trace ID if is able to parse it.
protected io.micronaut.inject.ExecutableMethod<java.lang.Object,java.lang.Object>	resolveFunction(io.micronaut.function.LocalFunctionRegistry arg0, java.lang.String arg1)
protected java.lang.String	resolveFunctionName(io.micronaut.context.env.Environment arg0)
protected io.micronaut.context.env.Environment	startEnvironment(io.micronaut.context.ApplicationContext arg0)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.function.executor.FunctionExecutor

execute

Field Detail

ENV_X_AMZN_TRACE_ID

public static final java.lang.String ENV_X_AMZN_TRACE_ID

See Also:

Constant Field Values

MDC_DEFAULT_AWS_REQUEST_ID

public static final java.lang.String MDC_DEFAULT_AWS_REQUEST_ID

See Also:

Constant Field Values

MDC_DEFAULT_FUNCTION_NAME

public static final java.lang.String MDC_DEFAULT_FUNCTION_NAME

See Also:

Constant Field Values

MDC_DEFAULT_FUNCTION_VERSION

public static final java.lang.String MDC_DEFAULT_FUNCTION_VERSION

See Also:

Constant Field Values

MDC_DEFAULT_FUNCTION_ARN

public static final java.lang.String MDC_DEFAULT_FUNCTION_ARN

See Also:

Constant Field Values

MDC_DEFAULT_FUNCTION_MEMORY_SIZE

public static final java.lang.String MDC_DEFAULT_FUNCTION_MEMORY_SIZE

See Also:

Constant Field Values

MDC_DEFAULT_FUNCTION_REMAINING_TIME

public static final java.lang.String MDC_DEFAULT_FUNCTION_REMAINING_TIME

See Also:

Constant Field Values

MDC_DEFAULT_XRAY_TRACE_ID

public static final java.lang.String MDC_DEFAULT_XRAY_TRACE_ID

See Also:

Constant Field Values

applicationContext

protected io.micronaut.context.ApplicationContext applicationContext

Constructor Detail

MicronautRequestHandler

public MicronautRequestHandler()

Constructor.

Method Detail

handleRequest

public final O handleRequest(I input,
                             com.amazonaws.services.lambda.runtime.Context context)

Specified by:

handleRequest in interface com.amazonaws.services.lambda.runtime.RequestHandler<I,O>

populateMappingDiagnosticContextValues

protected void populateMappingDiagnosticContextValues(@NonNull
                                                      com.amazonaws.services.lambda.runtime.Context context)

Parameters:

context - The Lambda execution environment context object.

See Also:

AWS Lambda function logging in Java

mdcput

protected void mdcput(@NonNull
                      java.lang.String key,
                      @NonNull
                      java.lang.String val)
               throws java.lang.IllegalArgumentException

Put a diagnostic context value.

Parameters:

key - non-null key

val - value to put in the map

Throws:

java.lang.IllegalArgumentException - in case the "key" parameter is null

populateMappingDiagnosticContextWithXrayTraceId

protected void populateMappingDiagnosticContextWithXrayTraceId()

Populate MDC with XRay Trace ID if is able to parse it.

parseXrayTraceId

@NonNull
protected static java.util.Optional<java.lang.String> parseXrayTraceId()

Parses XRay Trace ID from _X_AMZN_TRACE_ID environment variable.

Returns:

Trace id or empty if not found

See Also:

Trace ID injection into logs

convertInput

protected I convertInput(java.lang.Object input)

Converts the input the required type. Subclasses can override to provide custom conversion.

Parameters:

input - The input

Returns:

The converted input

Throws:

java.lang.IllegalArgumentException - If input cannot be converted

buildApplicationContext

protected io.micronaut.context.ApplicationContext buildApplicationContext(com.amazonaws.services.lambda.runtime.Context context)

newApplicationContextBuilder

@Nonnull
protected io.micronaut.context.ApplicationContextBuilder newApplicationContextBuilder()

resolveFunction

protected io.micronaut.inject.ExecutableMethod<java.lang.Object,java.lang.Object> resolveFunction(io.micronaut.function.LocalFunctionRegistry arg0,
                                                                                                  java.lang.String arg1)

resolveFunctionName

protected java.lang.String resolveFunctionName(io.micronaut.context.env.Environment arg0)

startEnvironment

protected io.micronaut.context.env.Environment startEnvironment(io.micronaut.context.ApplicationContext arg0)