文件名称：dashboard-with-spark-streaming:基于Spark Streaming的实时仪表板应用程序
文件大小：276KB
文件格式：ZIP
更新时间：2024-05-22 16:19:48
kafka spark protobuf rethinkdb eventbus
概要 基于Spark Streaming的实时仪表板应用程序。 我们收集POST到/api/orders端点的JSON数据，使用protobuf序列化它们并将其推送到Apache Kafka。 接下来，我们使用Apache Spark消耗来自Apache Kafka的事件，按时间窗口（1秒时间窗口）聚合事件，并将其存储到RethinkDB。 最后，我们在仪表板中向用户显示汇总的见解。 第一步，我们创建一个RESTful API端点，在其中我们将接受以下JSON格式的数据： { "userId": "134256", "currencyFrom": "EUR", "currencyTo": "USD", "amountSell": 1000, "amountBuy": 747.1, "rate": 0.7471, "timePlac
【文件预览】：
dashboard-with-spark-streaming-master
----nginx()
--------nginx(545B)
----Jenkinsfile(455B)
----LICENSE(1KB)
----screenshot.png(103KB)
----generate-token.png(17KB)
----.gitignore(676B)
----project()
--------api-server()
--------dashboard()
--------aggregator()
--------common()
----README.md(5KB)
----scripts()
--------start_kafka.sh(2KB)
--------process_monitor.sh(2KB)