问题标签 [lagom]

我正在使用 Spark、Flink 和 Kafka 创建流分析应用程序。每个分析/功能都将实现为微服务，以便该分析能够在以后用于不同的项目中。

我在 Simple Scala 应用程序中完美地运行了我的 Spark/Flink 作业，并分别通过 Spark 和 Flink 集群提交了该作业。但是当 REST POST startJob() 请求调用我的 Web 服务时，我必须启动/运行这项工作。

如何将我的 Spark 和 Flink 数据处理功能集成到面向 Web 服务的应用程序中？

直到现在我尝试了 Lagom Microservice但我发现了很多你可以检查的问题

1. 在 Lagom 微服务中摄取流数据的最佳方法
2. java.io.NotSerializableException 使用 Apache Flink 和 Lagom

我认为我没有为流处理微服务应用程序采取正确的方向。寻找通过 REST 服务实施此分析的正确方向。

我对 Lagom 框架非常陌生，我完全不知道自己在做什么。我有一个可以正常工作的简单 CRUD lagom 应用程序，但我不知道如何检索列表。

所以这就是我现在所拥有的，但我得到了

但我在线[Java] Type mismatch: cannot convert from Stream<Object> to Source<Movie,?>上遇到错误rows.stream()。

任何帮助，将不胜感激。

提前致谢。

我们有一个基于 Lagom 的项目，其中包含多个微服务，每个（当然）都有自己的 Cassandra 密钥空间。我们需要将生产数据复制到我们的 QA 和开发环境中。在传统数据库中，我们只需导出所有生产数据并将其导入其他环境。这是如何使用 Akka Persistence 完成的？我可以做同样的事情吗（即删除所有开发/质量保证数据并从生产备份中导入？或者这不起作用？

Lagom文档没有提到任何关于 MongoDB 支持的内容，但 Lagom 似乎支持 JPA 和 JDBC。

Hibernate OGM可以用作 MongoDB 和 Lagom 之间的 JPA 接口吗？

ReactiveMongo驱动程序是一个很好的候选者，它甚至可以与 Playframework 一起使用。有可能将它与 Lagom 一起使用吗？

有没有其他方法可以达到同样的效果？

我正在努力解决一个特定的依赖注入问题，但我似乎无法弄清楚。仅供参考：我是 guice 新手，但我有其他 DI 框架的经验——这就是为什么我认为这不应该太复杂来实现。

我在做什么：我正在开发 Lagom 多模块项目并使用 Guice 作为 DI。

我想要实现的目标：向我的服务注入一些接口实现的多个命名实例（我们称之为发布者，因为它会将消息发布到 kafka 主题）。这个“发布者”已经注入了一些 Lagom 和 Akka 相关的服务（ServiceLocator、ActorSystem、Materializer 等）。

现在我想要两个这样的发布者实例，每个实例都会将消息发布到不同的主题（所以每个主题一个发布者实例）。

我将如何实现这一目标？我对同一主题的一个或多个实例没有问题，但是如果我想为每个实例注入不同的主题名称，我就有问题了。

所以我的发布者实现构造函数如下所示：

如果我想创建一个实例，我会在我的 ServiceModule 中这样做：

我将如何为自己的主题绑定多个发布者？

我正在玩实现另一个私有模块：

但这让我无处可去，因为您无法在模块配置方法中获得注入器：

唯一简单且有效的解决方案是我将 PublisherImpl 更改为抽象，添加他抽象的“getTopic()”方法并添加另外两个具有主题覆盖的实现。

但这个解决方案是蹩脚的。为代码重用添加额外的继承并不是最佳实践。我也相信 Guice 肯定必须支持这样的功能。

欢迎任何建议。韩国，NEJC

我正在实现一个 Lagom 服务，该服务使用 Swift Stack 的 Joss 客户端调用外部服务。如何缓存此信息以便在每次调用我的服务时不调用外部服务？

有什么办法得到LagomApplicationContext吗？我想使用播放配置对象play.api.Configuration形式playContext- 组合：

任何想法或建议如何做到这一点？Exist 是否存在一些 DI？

我需要使用 application.conf 中的值，就像在这个例子中一样： https ://www.webkj.com/play-framework/play-scala-2.5-reading-config-using-di

期间

异常或错误导致运行中止：没有启动的应用程序 java.lang.RuntimeException：没有启动的应用程序

Well, I am stuck in this scenario that I want to use Swagger API to validate response of my Lagom Service API. Here is some sample code:

When This code runs It seems that it goes into the service(as it prints some logs of the service.) but not invokes the method which will the database with the given values.

I need to do something here that it invokes the method of the service and validates the response on the basis of this swagger spec.

I saw this link but didn't get the solution How to validate API in tests with Swagger?

在 Lagom 中，当命令处理程序必须执行一些异步操作时，您会怎么做？例如：

这样的代码的问题是编译器期望命令处理程序返回Persist，而不是Future[Persist]。

这是故意这样做的，以确保事件以正确的顺序保存（即，先前命令生成的事件必须在后面命令生成的事件之前保存）？但是，这不能通过对事件偏移量的适当管理来处理，以便日志总是正确地对它们进行排序，而不管它们何时实际保存？

当命令处理复杂到需要从命令处理程序进行异步调用时，在这种情况下该怎么办？