问题标签 [spring-cloud-function]

参数google函数

eu quero passar 参数 para 查询

模板文件：

功能谷歌云：blob.upload_from_string（时间戳）

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

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

从“订单”队列传入：

从“装运”队列传入：

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

例如

所以问题是，如何使用新的 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 (or message) as well …​.routing-expression=headers['type']

是否可以将路由表达式添加到绑定中，例如 (in application.yml)

?

第一次回答后编辑 如果在这个位置上面的表达式是不可能的，第一个答案意味着什么，我的问题如下：

据我了解，routing-expression: headers['catalog']必须全局设置类似的表达式，因为结果映射到某些（消费者）函数。

我如何控制每个队列上的 2 条不同消息将被转发到它们自己的消费者函数，例如

使用 很容易@StreamListener，因为每个方法都有自己的@StreamListener注释，具有不同的条件。新设置如何实现这一点routing-expression？?

我正在使用 spring cloud 功能来处理来自带有 Flux 的 kafka 的数据。默认情况下，它在消费者线程（消费消息的地方）中处理数据。我将为并行数据处理和节流实现线程池，并且在 Spring Cloud Integration 中有一个很棒的实现，称为 executorChannel ( https://docs.spring.io/spring-integration/api/org/springframework/integration/channel/ ExecutorChannel.html )

功能实现示例：

所以我发现没有简单的方法来连接通过 executorChannel 实现的功能。

Mb 有没有办法定义 inputChannel 类型？

UPD：阅读奥列格回答下的评论。它们非常有用。

鉴于：

和：

聚甲醛：

为什么我会收到以下异常？

[payload=org.springframework.messaging.MessageDeliveryException：Dispatcher 没有频道“apollo-lookup-service-1.inboundApolloLookupVehicleChannel”的订阅者。; 嵌套异常是 org.springframework.integration.MessageDispatchingException: Dispatcher 没有订阅者，failedMessage=GenericMessage [payload=byte[439]

我只是想使用该队列中的消息。

任何帮助将不胜感激，谢谢。

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

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

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

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

我有一个简单的 SCDF 流，如下所示：

http --port=12346 | mvmn-transform | file --name=tmp.txt --directory=/tmp

mvmn-transform 是一个简单的自定义转换器，如下所示：

这工作正常。

但是我读过 Spring Cloud Function 应该允许我实现这样的应用程序，而无需指定绑定和转换器注释，所以我将其更改为：

现在我遇到了一个问题 - Spring-Cloud-Function 显然忽略了 SCDF 源和目标主题名称，而是创建了主题transform-in-0和主题。transform-out-0

SCDF 创建具有类似名称的主题，<stream-name>.<app-name>例如TestStream123.http和TestStream123.mvmn-transform

以前它们被用于转换器 - 应该如此，因为它是 SCDF 流的一部分。但是现在它们被 Spring-Cloud-Function 忽略并被transform-in-0创建transform-out-0。

因此，我的转换器不再接收任何输入，因为它期望它出现在错误的 Kafka 主题上。并且可能也不会对流产生任何输出，因为它也会输出到错误的 Kafka 主题。

PS 以防万一，GitHub 上的完整项目代码：https ://github.com/mvmn/scdftest-transformer/tree/scfunc

为了在本地运行启动 Kafka、Skipper、SCDF 和 SCDF 控制台，mvn clean install在 app 文件夹中执行，然后app register --name mvmn-transform-1 --type processor --uri maven://x.mvmn.study.scdf.scdftest:scdftest-transformer:0.1.1-SNAPSHOT --metadata-uri maven://x.mvmn.study.scdf.scdftest:scdftest-transformer:0.1.1-SNAPSHOT在控制台中执行。然后您可以使用定义部署流http --port=12346 | mvmn-transform | file --name=tmp.txt --directory=/tmp

我很难理解我应该如何去测试一个使用 Kafka Binder 同时还使用 Spring Cloud 功能的应用程序。

让我们使用这个非常简单的例子：

在我的 application.yaml 上：

我将如何进行测试？如果我使用 @StreamListener 和 Channels 列表，我会这样做：

但是，对于 Spring Cloud Function，情况并非如此。非常欢迎任何帮助，因为我在官方文档或示例中找不到任何内容！

我已经开始涉足 Spring Cloud Stream 和它的云功能支持。

我在这里上传了一个示例项目来阐明这个问题-> https://github.com/nmarquesantos/spring-cloud-function-kafka

我有一个项目以反应方式公开一些功能，使用 kafka 作为消息代理。

该函数接收一个 Flux 并继续通过 Reactive Mongo 库保存元素。然后它通过另一个通量返回更新的资源。

playerUpdate 函数是错误发生的地方。playerFeeder 只是我创建的一个函数，用于发送数据以重现问题。在现实生活中，这将来自不同的服务。

通过运行我上面提到的示例项目，这是错误的片段：

我很难理解我做错了什么，在我的搜索中找不到太多信息。

假设我将这些函数映射到端口 8080 上的 web：

我可以使用以下方法从他们那里获取数据：

现在我使用网关创建了一个路由来映射：

但是当我像上面那样运行 curl 时（将端口更改为 8081，因为网关在 8081 上），它不会给我返回请求的信息。我也试过了/uppercase|toChars。这是我正在使用的定义：

我尝试了不同的组合，Path但都没有奏效。有什么帮助吗？

我使用 Spring 云函数方法传输 Flux 创建了 3 个简单的 Spring 云流应用程序（源/处理器/接收器）。

源应用程序：

处理器应用程序：

接收器应用程序：

我添加的依赖项是：

我已经在 Spring Cloud Data Flow 中注册了这些应用程序并部署在流中。

我能够将数据传输到这些应用程序，并分别通过 HTTP 和 RabbitMQ 接收输出。但是，消息不会在应用程序之间进行通信（源->处理器->接收器）。我是否缺少任何依赖项、注释或应用程序属性。

目前我的应用程序属性文件是完全空的。