利用RabbitMQ消息队列架设实时机器学习服务

本章我们将会学习RabbitMQ在实战中的用法，并且应用RabbitMQ搭建消息队列， 整合实时机器学习应用中的各种服务。

下载本章实例程序

下载本章实例程序和数据，只需执行下面操作：

git clone https://github.com/real-time-machine-learning/4-rabbitmq

安装配置软件环境

本章会运用到Docker作为集群配置方法，其余软件均通过Docker配置安装。

• 如需要复习Docker安装配置方法，看这里
• 如需复习Scikit Learn基本操作，看这里
• 如需复习Pandas基本操作，看这里

利用RabbitMQ搭建股价预测集群

完成之后我们的集群的构架如下图：

运行本章节实例

只需在命令行本章节代码目录中运行以下代码，即可启动该集群。

docker-compose up 

可能遇见的问题

本案例使用了Elasticsearch 5.0 的Docker镜像，在有些电脑上（如笔者的）， 需要对系统环境变量进行少许调整，才能正常运行。需要运行以下命令

sudo sysctl -w vm.max_map_count=262144 

---

《实时机器学习实战》 彭河森、汪涵