标签: spring-cloud-function

我正在使用基本示例在 Ubuntu 上构建 lambda。它构建时没有任何错误，但如果我在 aws 上上传并测试它，则会崩溃：

{
  "errorMessage": "RequestId: 7f4d0aca-125c-4032-98dd-9ff387e5252b Error: Runtime exited with error: exit status 1",
  "errorType": "Runtime.ExitError"
}

日志输出为：

START
RequestId: 7f4d0aca-125c-4032-98dd-9ff387e5252b
Version: $LATEST.~.jwtauthorizeraws.jwtauthorizerawsapplication: /lib64/libc.so.6: version `GLIBC_2.32' not found (required by ./~.jwtauthorizerawsapplication)
END 
RequestId: 7f4d0aca-125c-4032-98dd-9ff387e5252b
REPORT
RequestId: 7f4d0aca-125c-4032-98dd-9ff387e5252b
Duration: 56.02 ms
Billed Duration: 57 ms
Memory Size: 128 MB
Max Memory Used: 7 MB   
RequestId: 7f4d0aca-125c-4032-98dd-9ff387e5252b
Error: Runtime exited with error: exit status 1
Runtime.ExitError

我有一个服务，它从不同的消息队列接收不同的结构化消息。我们可以针对@StreamListener conditions每种消息类型选择如何处理该消息。举个例子：

我们收到两种不同类型的消息，它们具有不同的标头字段和值，例如

来自“订单”队列的传入：

Order1: { Header: {catalog:groceries} }\nOrder2: { Header: {catalog:tools} }\n

来自“发货”队列的传入：

Shipment1: { Header: {region:Europe} }\nShipment2: { Header: {region:America} }\n

每个队列都有一个绑定，根据该绑定，@StreamListener我可以按目录和区域以不同的方式处理消息

例如

@StreamListener(target = OrderSink.ORDER_CHANNEL, condition = "headers[\'catalog\'] == \'groceries\'")\npublic void onGroceriesOrder(GroceryOder order){\n...\n}\n

那么问题是，如何使用新的 Spring Cloud Function 方法来实现这一点？

在文档https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.2.RELEASE/reference/html/spring-cloud-stream.html#_event_routing中提到：

Also, for SpEL, the root object of the evaluation context is Message so you can do evaluation on individual headers …

我正在开发一个分布式应用程序项目，其中需要根据在 api 网关上使用服务的客户端进行速率限制和身份验证。我想知道设计网关的最佳解决方案。

我应该使用 Spring Cloud gateway 还是 Spring Cloud function/AWS Lambda 来创建网关服务？

我用 Spring Cloud Function 创建了一个 AWS lamnda，但我认为这种方法在执行 lambda 时很慢。

我的 lambda 非常简单，它只将一个对象保存到数据库中。

对另一种语言或框架使用 Spring Boot 函数是个好主意吗？

例如使用 phyton、nodejs 或其他解决方案。

是否可以使用spring.cloud.function具有多个独立函数/绑定的函数式( ) 样式的反应式 SCS 应用程序？我发现的所有示例总是只注册一个具有默认绑定的功能性 bean input, output。我想注册多个，每个都有自己的绑定。

传统上可以使用spring-cloud-stream-reactive它来完成，但现在不赞成使用功能支持。

嘿，我按照分步指南在 Spring Boot 中设置 kafka。

但现在我无法启动该应用程序。有什么建议 ：）

日志中的错误：

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'functionInitializer' defined in class path resource [org/springframework/cloud/stream/function/FunctionConfiguration.class]: Invocation of init method failed; nested exception is java.lang.IllegalArgumentException: Found more then one function in BeanFactory: [persistentEntities, resourceMappings]. Consider providing 'spring.cloud.function.definition' property.

什么是 spring.cloud.function.definition？以及如何设置呢？引起原因：java.lang.IllegalArgumentException：在 BeanFactory 中发现多个函数：[persistentEntities，resourceMappings]。考虑提供“spring.cloud.function.definition”属性。

我有简单的@Bean（Java 8 函数），它们映射到目的地topic（-out和-in）。

@Bean
public Function<String, String> transform() {
    return payload -> payload.toUpperCase();
}

@Bean
public Consumer<String> receive() {
    return payload -> logger.info("Data received: " + payload);
}

.yml配置：

spring:
  cloud:
    stream:
      function:
        definition: transform;receive
      bindings:
        transform-out-0:
          destination: myTopic
        receive-in-0:
          destination: myTopic

现在，我想transform通过调用来调用该函数REST，以便它的输出转到destination topic（即transform-out-0映射到）并由该目的地（映射到）myTopic拾取。基本上，每个 REST 调用都应该生成一个新的KAFKA实例并关闭它。consumerreceive-in-0myTopic Producer