python - Flask：如何在 Flask、celery 或 python 多处理模块中创建一个或多个耗时的进程

Question

现在我想使用 Flask 来实现一个后端服务，该服务为前端提供一些 RESTful-API 来查询本地数据库中的数据。并且本地数据库中的所有数据都是从另一个远程数据库生成和分析的。

我认为必须不断创建一个异步过程来从远程数据库中获取不断生成新数据的原始数据，并对这些数据进行分析和转换，并保存到本地数据库（方便REST查询）。

此外，在分析过程中，一些特殊数据必须通过 web-socket 推送到前端。

对于上述功能，我如何在 Flask 中创建一个异步耗时的过程来进行数据分析，使用 flask-celery 或 multiprocessing 模块或任何其他实现？

标签： pythonflaskmultiprocessingcelery