如何在python中运行连续工人实时数据传输?

2024-06-13 13:36:07 发布

您现在位置:Python中文网/ 问答频道 /正文

我有两个不同的python应用程序,它们适合producer-consumer模型。在

  1. 一个生产者,用flask框架编写
  2. 消费者,openerp v-8.0 (odoo)

我希望制作者继续将数据推送到队列中。然后,消费者不断地从队列中提取数据并进行相应的操作。在

为了提供更详细的信息,生产者不断检查orders表中是否有新订单,并将所有必需的数据推送到队列中,以便在消费者中创建相应的订单。在

我想把这个模型扩展到每分钟1000个订单。在

由于其可靠性和长轮询特性,我计划将Amazon的SQS用于queue(我不知道如何实现长轮询,但愿意学习)。在

所以,我的问题是:

  1. 如何添加一个在我的flask应用程序中继续运行的worker,并在创建订单后立即推送数据?在
  2. 如何在openerp中运行一个连续的工作线程,它不断地从队列中拉出?在
  3. 有比我建议的更好的方法吗?在

谢谢


Tags: producer数据odoo订单模型框架信息应用程序