tweepy Streaming API 与 Django 的集成

Question

我正在尝试通过 tweepy.Stream() 函数创建一个利用 Twitter 流 API 的 Django webapp。我在构思正确的实施时遇到了困难。

我想要的最简单的功能是实时计算包含主题标签的推文数量。所以我会打开一个流，按关键字过滤，每次新推文通过连接时，我都会增加一个计数器。然后该计数器会显示在网页上并使用 AJAX 或其他方式进行更新。

问题在于 tweepy.Stream() 函数必须连续运行并连接到 twitter（这就是重点）。如何让这个流在 Django 应用程序的后台运行，同时增加可以（接近）实时显示的计数器？

提前致谢！

Answer 1

有多种方法可以做到这一点，但使用消息传递库 (celery) 可能是最简单的。

1) 保持 python 进程运行 tweepy。找到有趣的消息后，创建一个新的 celery 任务

2) 在这个胡萝卜任务中，将数据保存到数据库（计数器、推文等）。此任务可以很好地运行 django 代码（例如 ORM）。

3) 有一个常规的 django 应用程序显示您的任务持续存在的结果。

作为预防措施，最好在监督下运行 tweepy 进程（supervisord 可能适合您的需要）。如果出现任何问题，它可以自动重新启动。