SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Send a user-agent header with requests to the Lambda Runtime API.

Browse Source 
Adding the author tag.
This commit is contained in:
Mark Sailes
2021-11-11 19:31:35 +00:00
committed by Oleg Zhurakousky
parent 405d38a294
commit 015d253106
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/main/java/org/springframework/cloud/function/adapter/aws/CustomRuntimeEventLoop.java
View File

@@ -45,11 +45,14 @@ import org.springframework.messaging.MessageHeaders;
import org.springframework.util.Assert; import org.springframework.util.Assert;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
import static org.apache.http.HttpHeaders.USER_AGENT;
/** /**
* Event loop and necessary configurations to support AWS Lambda * Event loop and necessary configurations to support AWS Lambda
* Custom Runtime - https://docs.aws.amazon.com/lambda/latest/dg/runtimes-custom.html. * Custom Runtime - https://docs.aws.amazon.com/lambda/latest/dg/runtimes-custom.html.
* *
* @author Oleg Zhurakousky * @author Oleg Zhurakousky
* @author Mark Sailes
* @since 3.1.1 * @since 3.1.1
* *
*/ */
@@ -60,6 +63,10 @@ public final class CustomRuntimeEventLoop implements SmartLifecycle {
static final String LAMBDA_VERSION_DATE = "2018-06-01"; static final String LAMBDA_VERSION_DATE = "2018-06-01";
private static final String LAMBDA_RUNTIME_URL_TEMPLATE = "http://{0}/{1}/runtime/invocation/next"; private static final String LAMBDA_RUNTIME_URL_TEMPLATE = "http://{0}/{1}/runtime/invocation/next";
private static final String LAMBDA_INVOCATION_URL_TEMPLATE = "http://{0}/{1}/runtime/invocation/{2}/response"; private static final String LAMBDA_INVOCATION_URL_TEMPLATE = "http://{0}/{1}/runtime/invocation/{2}/response";
private static final String USER_AGENT_VALUE = String.format(
"spring-cloud-function/%s-%s",
System.getProperty("java.vendor.version"),
CustomRuntimeEventLoop.class.getPackage().getImplementationVersion());
private final ConfigurableApplicationContext applicationContext; private final ConfigurableApplicationContext applicationContext;
@@ -92,7 +99,7 @@ public final class CustomRuntimeEventLoop implements SmartLifecycle {
logger.debug("Event URI: " + eventUri); logger.debug("Event URI: " + eventUri);
} }
RequestEntity<Void> requestEntity = RequestEntity.get(URI.create(eventUri)).build(); RequestEntity<Void> requestEntity = RequestEntity.get(URI.create(eventUri)).header(USER_AGENT, USER_AGENT_VALUE).build();
FunctionCatalog functionCatalog = context.getBean(FunctionCatalog.class); FunctionCatalog functionCatalog = context.getBean(FunctionCatalog.class);
RestTemplate rest = new RestTemplate(); RestTemplate rest = new RestTemplate();
JsonMapper mapper = context.getBean(JsonMapper.class); JsonMapper mapper = context.getBean(JsonMapper.class);
@@ -125,8 +132,9 @@ public final class CustomRuntimeEventLoop implements SmartLifecycle {
} }
byte[] outputBody = AWSLambdaUtils.generateOutput(eventMessage, responseMessage, mapper, function.getOutputType()); byte[] outputBody = AWSLambdaUtils.generateOutput(eventMessage, responseMessage, mapper, function.getOutputType());
ResponseEntity<Object> result = rest ResponseEntity<Object> result = rest.exchange(RequestEntity.post(URI.create(invocationUrl))
.exchange(RequestEntity.post(URI.create(invocationUrl)).body(outputBody), Object.class); .header(USER_AGENT, USER_AGENT_VALUE)
.body(outputBody), Object.class);
if (logger.isInfoEnabled()) { if (logger.isInfoEnabled()) {
logger.info("Result POST status: " + result.getStatusCode()); logger.info("Result POST status: " + result.getStatusCode());