问题标签 [lagom]

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

我正在使用 Lagom 创建微服务。我是 lagom 的新手，这就是为什么我遇到了一些疑问。

我不明白将我的数据流（来自多个传感器）发布到微服务然后这个微服务将数据发布到 kafka 主题的最佳方法是什么。

1. 服务描述ServiceCall[ Source[String, NotUsed], Source[String, NotUsed]]中流消息的 Lagom 特性是否 是从数百个 wifi 传感器发布数据流（大数据）的正确方法？它是否有能力处理近乎实时（= 5 秒）接收的大量数据流？

2. 其次，在向 kafka 主题发布数据时，为什么我必须实现持久实体（Lagom 推荐）？因为 Kafka 本身保证了至少一次的消息传递

我的应用程序不是 CRUD 应用程序，它只支持处理流数据。

这是特定于 Lagom 框架的。在更新期间，我没有完整的数据，我还有一些需要更新的备用表，我如何从我的主表中读取，所以我有所有的键来对备用表执行更新。

我正在使用 Lagom 1.3.1 [SCALA]

我正在尝试使用 pom.xml 中的必要配置连接到外部 Cassandra 和 kafka。

当我使用 mvn lagom:runAll 启动服务时，出现以下错误

我没有在我的代码中使用 Guice 模块，而是利用 scala 使用“macwire”连接依赖项的方式。然而，lagom 的“服务注册”模块依赖于使用 guice 进行布线的 javadsl。

关于如何解决这个问题的任何想法？

我父 pom 中的 Maven 依赖项：

Maven Lagom 插件配置：

我对 lagom 框架完全陌生，因此，我今天正在阅读文档并开始修改他们的 hello world 示例。

但是，我无法找到获取所有持久实体的方法（即本例中的所有持久问候语）。

这是默认示例获取人的问候语的方式：

现在，我不想使用给定的 ID 查找实体，而是想获取所有实体，例如类似的东西persistentEntityRegistry.getIds()，然后我可以通过 id 一个一个地获取它们。但是，实体注册中心似乎不存在这样的方法？

我有下面的代码，我使用可变列表缓冲区来存储从 kafka consumer 收到的文件，然后当列表大小达到 15 时，我将它们插入到 cassandra 中。但是他们有什么方法可以使用不可变列表来做同样的事情。

我正在尝试在 Windows 7 机器（代理后面）上创建一个新的 lagom scala 项目，但我收到错误消息“org.eclipse.jgit.api.errors.TransportException: git://github.com/lagom/lagom-scala. g8.git：连接超时”

这是命令：sbt new lagom/lagom-scala.g8

我设置了代理环境变量 http_proxy 但仍然出现此错误。任何想法想法..使这项工作？

我是 Lagom 和持久性实体数据库概念的新手。

我正在构建流分析引擎。我的每个分析都将作为独立的微服务工作，并且根据其设计理念，对于每个单独的微服务，结果将保存在自己的数据库中（我的案例 Cassandra）。我正在使用 Flink 和 Spark 进行流分析，然后使用 Phantom for Flink（Cassandra 的 Scala 驱动程序）将结果发送到 Cassandra。我无法理解 Lagom 框架中的以下挑战。

1. 为了存储分析结果，我仍然需要实现持久性实体（PE）来将记录存储在 Cassandra 中，或者我应该购买它并可以直接存储到 Cassandra？我的应用程序既不支持删除器也不支持更新。仅插入以可视化结果。Flink & Spark 已经支持容错。

2. 如何在没有持久性实体的情况下访问 Cassandra 会话？

3. 如果我在 Lagom 中使用 Phantom 驱动程序，那么它与 Lagom 的嵌入式 Cassandra 有一些冲突；无法在服务定位器中注册服务。

您能否建议我应该如何处理这种情况。也就是说每一个微服务，它的架构都是基于KAPPA 架构的

谢谢

下午好，

我正在尝试遵循lagom 的这个 hello world 教程，但是在运行命令时：

我收到以下错误：

如教程的设置部分所述，我检查了我的 java 版本：

我的 javac 版本：

还有我的 sbt 版本：

我尝试使用我的 sbt 版本作为参数运行命令：

但它仍然抛出没有模板错误，你能指出我做错了什么吗？

符合本教程的先决条件

我正在 Lagom 的微服务实现中编写 Flink CEP 程序。我的 FLINK CEP 程序在简单的 scala 应用程序中运行良好。但是当我在 Lagom 服务实现中使用此代码时，我收到以下异常

Lagom 服务实施

我不明白如何解决这个问题。

过去几天我一直面临一个关于在 Scala 中保存和处理 Futures 数据的问题。我对语言和两者的概念都很陌生。Lagom 在 Cassandra 上的文档说要实现大约 9 个代码文件，我想确保我的数据库代码在将其传播到那么多代码之前可以正常工作。

具体来说，我目前正在尝试实现一个概念证明，以向/从 lagom 为您实现的 cassandra 数据库发送数据。到目前为止，我能够向/从数据库发送和检索数据，但是我无法返回该数据，因为这一切都是异步运行的，并且还返回了成功返回的数据。

我已经玩了一段时间了；检索代码如下所示：

当它运行时，我在 onSuccess 回调中将预期的数据库值设置为“println”。但是，我在 return 语句中使用的同一个变量在回调之外打印为空（并且也返回空数据）。这也发生在我使用的“插入”函数中，它并不总是返回我在回调函数中设置的变量。

如果我尝试将语句放在回调函数中，则会收到“返回单元，期望未来 [字符串]”的错误。所以我被困在无法从回调函数中返回的地方，所以我不能保证我正在返回数据）。

我的目标是向 API 返回一个字符串，以便它显示数据库中所有 s3 存储桶名称的列表。这意味着遍历 Future[Seq[Row]] 数据类型，并将数据保存到连接字符串中。如果有人可以提供帮助，他们将解决我通过 Lagom、Akka、Datastax 和 Cassandra 文档阅读的 2 周的问题。在这一点上我大吃一惊（信息超载），我没有找到明确的指南。

作为参考，这里是 cassandraSession 文档：

LagomTutorial/Documentation Style Information 及其唯一的 cassandra-query 示例 CassandraSession.scala 代码