1

我尝试Spring Cloud Function在 AWS Lambda 中部署一个具有多个功能的函数。

对于 HTTP 访问，我创建了一个HTTP API Gateway (not a REST API). 我想使用这里描述的函数路由：https ://cloud.spring.io/spring-cloud-static/spring-cloud-function/3.0.1.RELEASE/reference/html/spring-cloud-function.html# _function_routing。

使用以下配置，应根据以下配置RoutingFunction将调用委托给正确的函数function HTTP-Header：

spring.cloud.function.routing-expression=headers.function

Lambda 处理程序类是：

org.springframework.cloud.function.adapter.aws.SpringBootApiGatewayRequestHandler

并且配置的函数名称（FUNCTION_NAME）是：functionRouter。

当我向 API-Gateway 发送请求时，FunctionRouter 得到一个 FluxJust 对象而不是 Message 对象，因为 RequestHandler 似乎是一个发布者。所以我得到以下异常：

EL1008E: Property or field 'headers' cannot be found on object of type
'reactor.core.publisher.FluxJust' - maybe not public or not valid?:
org.springframework.expression.spel.SpelEvaluationException

org.springframework.expression.spel.SpelEvaluationException:
EL1008E: Property or field 'headers' cannot be found on object of type
'reactor.core.publisher.FluxJust' - maybe not public or not valid?

我当前的解决方法是在请求被委托给之前拦截请求，RoutingFunction并尝试HashMap使用以下代码从 重构有效负载：

@Autowired
RoutingFunction f;

@Bean
public Function<Message<LinkedHashMap>,?> router() {
    return value -> {
        String json = new JSONObject(value.getPayload()).toString();
        Message<?> m = MessageBuilder.createMessage(json, value.getHeaders());
        Object result = f.apply(m);
        return result;
    };
}

有没有一种方法可以将 HTTP API Gateway 与 in 结合Function Routing使用AWS？

4

1 回答 1

0

在我的项目中，我设置function.definition并function.routing-expression喜欢这样：

spring.cloud.function.definition=functionRouter
spring.cloud.function.routing-expression=headers['pathParameters']['proxy']

这将使用org.springframework.cloud.function.context.config.RoutingFunctionSpring Cloud Function 提供的，表达式将从路径中获取函数名称。

如果您仍想使用标题，您可以这样做： spring.cloud.function.routing-expression=headers['headers']['function']. HTTP 标头添加到headers属性的消息标头中。所以首先我们得到消息头，然后是 HTTP 头，然后是头键。

于 2020-07-05T14:21:14.867 回答