ProjectNew

Spark结构化流媒体项目 使用Kafka和Spark结构化流分析实时数据摄取的Python任务。 要运行生产者和kafka服务： install docker and docker-compose on the server docker-compose up -d --build 要从spark-master运行消费者： docker exec spark-master bash scripts/start_consumer.sh 制片人 API数据： 请求：来自发布者类。 { "id": data.get("id"), "first_name": data.get("first_name"), "last_name": data.get("last_name"), "email": data.get("email"), "gender": data.get("gender