问题标签 [spring-cloud-function]

这个问题与https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/455几乎相同，但对于Functional方法

当产生正确的 'Foo' (json) 时，调用 fooConsumer。但是，当产生“空”有效负载/墓碑时，永远不会调用使用者函数。

解决方法我尝试使用有效的自定义“转换器”方法：

然后fooConsumer可以检查payload.isDeleted()处理null情况。但这是冗长的，会污染 pojo/model 类，并且必须为每个消费者重复。

我知道 spring-integration 不能与 null 一起使用。但是有没有更好/标准的方法来处理使用功能方法的“墓碑”用例？

版本：3.0.4.RELEASE

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

.yml 配置：

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

我怎样才能做到这一点，请使用spring-cloud-stream？

谢谢

昂舒曼

I am using maven 3.6 in Ubuntu. My pom.xml:-

I get error as:-

Error:(7,8) java: cannot access org.springframework.cloud.function.context.AbstractSpringFunctionAdapterInitializer

What is wrong here? How do I fix it?

我目前正在尝试将现有的 Spring Cloud Stream 应用程序移植到使用 Spring Cloud Function 来代替。运行应用程序时，我们使用绑定从输入队列（Kafka 或 IBMMQ）进行映射。在队列上发送的消息通过自定义 MessageConverter 传递，然后传递给我们的自定义路由函数。

例如，在 Spring Cloud Stream 中，绑定允许直接访问测试队列（通过调用 input()），并且可以简单地在该队列上发送一条消息以启动流程滚动。

我试图找到的是一种类似的机制，用于将消息发送到 Spring Cloud Function 绑定的队列。问题是我似乎无法弄清楚如何做到这一点。

我已经看到如何通过 HTTP 访问 routingFunction，但不幸的是，这绕过了我的 MessageConverter，所以我仍然无法真正进行端到端测试。

有没有人对我如何让它与 Cloud Function 一起工作有任何想法或指示？

在用户点击触发我的Spring 云功能的 URL 之后（稍后将部署为 Amazon Lambda），并且正在完成一些逻辑......我想将用户重定向到某个 URL。

这是我到目前为止所拥有的：

当点击触发上述函数的 URL 时，它返回以下 json 对象（用 Postman 测试）：

但它实际上并没有重定向用户......所以这里缺少什么？

我在我的 Spring Cloud Function 项目中定义了一个函数，但是在将函数 ( ScanQrCode) 执行为 AS Lambda 之后，我得到：

这里奇怪的是我已经注释掉了consume,supplier和function函数......我不知道为什么 Spring 或 AWS Lambda 会考虑它们......

这是我的课程：

Spring Boot 应用程序

函数类

我错过了什么？

我正在尝试在 Google Cloud Functions 上运行 Spring Cloud Functions。为此，我想在 GitHub 上部署示例应用程序。我按照说明进行操作，但是当我想部署该功能时，Google 说：

构建失败：从 JAR 函数目录构建用户函数应包含 pom.xml 或单个 *.jar 文件。

我的问题是：

1. 这是有效的示例项目吗？我找不到任何其他教程。
2. 我究竟做错了什么。还有什么需要注意的吗？

我知道 Java11 处于 BETA 阶段，但也许有人可以提供帮助。

谢谢

我目前正在使用 Spring Cloud 函数 3.07.RELEASE 和 AWS Adapter for lambda。

我们使用的是有限范围的功能 Bean 注册，并且理解这不包括完整的 Spring Boot 自动配置。我们对此表示同意，因为我们重视速度和显着减少冷启动时间。

但是，我们确实有想要使用的配置类，并假设这需要手动完成。导入这些类的最佳做法是什么？

我们尝试搜索，但未能找到有关有限范围上下文与 Spring Boot 应用程序上下文的行为差异的文档。

有没有人尝试同时使用 Spring Cloud Function 和 Spring Cloud Stream？有什么理由不应该这样做吗？我们目前使用 Spring Cloud Function，但在某些情况下我们需要同步 Kafka 发布，似乎唯一的方法就是使用 Spring Cloud Stream。

谢谢，安妮

我正在尝试运行此处给出的 Azure 函数示例。给出的示例应用程序没有进行任何更改，并运行了文档中给出的所有说明（安装 Azure CLI、Azure 核心工具 3）。但它给出了以下错误。

我已经提到了关于 stackoverflow 和 github 的所有问题。这里似乎没有什么可以作为解决方案。我在这里创建了一个问题，并提供了所有信息。

我已经多次卸载并安装了 nodejs（核心工具所需）、核心工具和 CLI，并尝试解决此问题，但我无法解决。

我的问题是这里的“提供者”是什么意思。如何解决这个问题。任何指针都会很棒。