现在，我想使用flask来实现一个后端服务，该服务为前端提供一些RESTful-API来查询本地数据库中的数据。并且本地数据库中的所有数据都是从另一个远程数据库中生成和分析的。
我认为必须不断创建异步过程，以从不断生成新数据的远程数据库中获取原始数据，并对这些数据进行分析和转换，然后保存到本地DB（方便REST查询）。
此外，在分析过程中，必须通过Web套接字将某些特殊数据推送到Frontend。
对于上述功能，我如何在flask中创建一个耗时的异步过程来进行数据分析，使用flask-celery或多处理模块或任何其他实现？