PROSAGA码农传奇-ONOS/AWS Lambda/Kappa-Lagom将直接的事件流（记录）插入Cassandra

<div class =“post-text”itemprop =“text”>
  <P>
    如果您有一个事件流，那么每个使用它的微服务都可以保留一个维护物化视图的所有事件的副本。可以在搜索服务上看到这种微服务的一个例子
    <a href =“https://github.com/lagom/online-auction-scala/blob/master/search-impl/src/main/scala/com/example/auction/search/impl/BrokerEventConsumer.scala"rel =“nofollow noreferrer”>
      网上拍卖
    </A>
     示例应用。在链接代码中，有一个clas消耗两个不同的流（在本例中为Kafka主题）并将数据存储到ElasticSearch索引中。
使用Cassandra或其他数据库也可以实现同样的目的。
  </p>
  <P>
    如果您尝试在Lagom提供的基础上导入cassandra驱动程序，则可能会遇到更多问题。在这种情况下，我建议你：（1）不依赖任何lagom-persistence-xxx，以便只使用你的驱动程序或（2）使用
     <code>
      CassandraSession
    </code>
     由Lagom提供
     <code>
      lagomScaladslPersistenceCassandra
    </code>
     模块（见
    <a href="https://www.lagomframework.com/documentation/1.3.x/scala/PersistentEntityCassandra.html#Project-dependencies" rel="nofollow noreferrer">
      Lagom持久性文档
    </A>
    ）。
如果选择使用秒选项，则必须添加
     <code>
      CassandraSession
    </code>
     到您的类的构造函数，然后在您的类中的依赖注入
     <code>
      Loader
    </code>
     将确保提供足够的实例。请参阅链接代码中的内容
    <a href =“https://github.com/lagom/online-auction-scala/blob/master/search-impl/src/main/scala/com/example/auction/search/impl/BrokerEventConsumer.scala#L11 -L14“rel =”nofollow noreferrer“>
      构造函数中有3个参数
    </A>
     并且Loader使用
     <code>
      macwire
    </code>
     至
    <a href =“https://github.com/lagom/online-auction-scala/blob/master/search-impl/src/main/scala/com/example/auction/search/SearchApplicationLoader.scala#L24-L36 “rel =”nofollow noreferrer“>
      注入
    </A>
     他们。请注意，你必须混合使用
     <code>
      ReadSideCassandraPersistenceComponents
    </code>
     特质所以
     <code>
      CassandraSession
    </code>
     可以注射。
  </p>
</DIV>