我一直在研究如何在python中打开并行进程，偶然发现并发未来和多处理是最有趣的选择。可悲的是，我没有能够正确地执行它们，因为它们似乎是一个接一个地工作，而不是在同一时间。现在我的过程有点太长了，我想我可以做得更快。
假设我用python编写了一个函数，该函数连接到kafka队列并读取json消息，然后使用请求将每条消息发送到rest服务并获取一些信息，以便完成数据并随后发布；然后我用响应更新我的数据库。我需要能够让这个函数在多个进程中运行，并在执行请求的同时从队列中读取消息，直到消息用完为止。
最好的办法是什么？