io.micronaut.function.aws

Class MicronautRequestHandler<I,O>

java.lang.Object

io.micronaut.function.executor.AbstractExecutor<C>

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
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 class io.micronaut.function.executor.AbstractExecutor

applicationContext

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

ENVIRONMENT_LAMBDA

Constructor Summary

Constructors

Constructor and Description
MicronautRequestHandler() Default constructor; will initialize a suitable ApplicationContext for Lambda deployment.
MicronautRequestHandler(io.micronaut.context.ApplicationContext applicationContext) Constructor used to inject a preexisting ApplicationContext.

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.

Methods inherited from class io.micronaut.function.executor.AbstractExecutor

close, getApplicationContext, resolveFunction, resolveFunctionName, startEnvironment

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

Constructor Detail

MicronautRequestHandler

public MicronautRequestHandler()

Default constructor; will initialize a suitable ApplicationContext for Lambda deployment.

MicronautRequestHandler

public MicronautRequestHandler(io.micronaut.context.ApplicationContext applicationContext)

Constructor used to inject a preexisting ApplicationContext.

Parameters:

applicationContext - the application context

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)

Overrides:

buildApplicationContext in class io.micronaut.function.executor.AbstractExecutor<com.amazonaws.services.lambda.runtime.Context>

newApplicationContextBuilder

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

Overrides:

newApplicationContextBuilder in class io.micronaut.function.executor.AbstractExecutor<com.amazonaws.services.lambda.runtime.Context>