生产者/消费者+工作者与Node.js / python拱

我们有2个组件1生产者/消费者,2过程

生产者/消费者是I / O激励,并且只需要networking请求,并根据input参数input到mongodb。

进程是从mongodb和group(make pair)处理数据的独立进程(在python中)。

这种配对可以花费很less的时间,一旦配对完成,我们要通知节点,为了给定的连接,“处理完成”,所以节点可以发送数据回客户端。

我不知道“如何通知节点的连接,过程完成,这是输出。”

我将使用消息传递服务(如RabbitMQ甚至ZeroMQ)来通知或让Node.JS进程轮询此通知。

因此,Python进程会处理它然后发送一个消息,Node.JS进程会读取这个消息,然后知道它可以在MongoDB中完成它的工作和处理数据。