首先,一点背景。
我的 Python 处于中级水平。我对 MongoDB/Redis/Flask 很陌生。
为了有效地回答这个问题,我认为你必须愿意花时间从博客作者那里了解这个热图是如何工作的。
我正在使用这个博客的代码库: http:
//blog.comsysto.com/2012/07/10/real-time-twitter-heat-map-with-mongodb/#comment-770
可在 Git 上的此链接上找到:
https ://github.com/comsysto/twitter-realtime-heatmap
我开始了redis。
在 MongoDB 中,我在数据库 tstream 下创建了一个名为 tweets_tail 的封顶集合。tstream.tweets_tail.isCapped() 实际上返回 true。
当我运行 tstream.py 时,我在 StreamListener 类的每个函数中都放置了打印语句。这些函数在执行时都没有被实际调用过。
当我运行 tweet_service.py 时,我得到以下信息:
avon:heatmap kalil$ python tweet_service.py
* 正在运行http://0.0.0.0:5000/
* 重新启动,重新加载器
开始拖尾...
1
127.0.0.1 - - [24/Jul/2012 14:57:54] "GET /tweets?callback=loomit HTTP/ 1.1" 200 -
似乎在 tweet_service.py 中,它正在打印它在 pubsub.listen() 函数的第一次迭代中。
但是,除此之外,我没有收到任何新推文,因为对集合的查询:
db.tweets_tail.count()
0
我怀疑这与 Tweepy 臭名昭著的 Streaming API 损坏有关(正如我实验室中所说的那样),实际上没有任何推文被接收并保存在 MongoDB 中。事实上,我一点头绪都没有。
任何帮助将不胜感激 - 如果您需要更多信息,请告诉我。