在 django 中启动异步函数的最佳方法？答案

【问题标题】：Best Way to launch an asynchronous function in django?在 django 中启动异步函数的最佳方法？
【发布时间】：2017-02-25 12:21:14
【问题描述】：

我正在使用tweepy 库从twitter streaming API 收集推文并将它们存储在Elasticsearch 服务器中。总的来说，我正在写一个简单的Django application 来在地图上实时显示推文。但是，为此我需要由 Django 服务器不断地实时填充 ElasticSearch 数据库，即最好在 Django 服务器启动后立即开始执行此操作。有什么好的方法来解决它？

调用如下所示：

streamer = tweepy.Stream(twitter_api.auth, listener=stream_listener)
streamer.filter(locations=[-180, -90, 180, 90], languages=['en'], async=True)

【问题讨论】：

标签： python django twitter django-views tweepy

【解决方案1】：

将celery 与celery-haystack 一起使用（希望您已经在使用django-haystack 与Elasticsearch 进行交互）。这不是一个直接的解决方案，但经过一些努力，它是最好的解决方案。

【讨论】：

【解决方案2】：

我使用主管 + custom django command。在命令中，您决定何时运行该异步函数。

【讨论】：