Spark 流式传输到 MongoDB

Question

我正在通过 Apache Spark Streaming 从 Apache Kafka 访问数据，因此我想将数据存储在 MongoDB 中，那么我如何将其存储在 mongoDB 中？

Answer 1

输出操作非常有限，但您始终可以使用foreachRDD()，您可以在此时间范围内访问任何已处理的 RDD。因此，任何自定义逻辑都可以放在此处，即与 MongoDB 的连接显式执行简单的插入/更新操作。