首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Twitter Python程序出现连接错误

Twitter Python程序出现连接错误
EN

Stack Overflow用户
提问于 2012-12-04 00:22:58
回答 1查看 603关注 0票数 0

我正在用Python语言开发一个Twitter数据挖掘应用程序,使用模块twitter和redis,基于Matthew A.Russell的“挖掘社交网络”一书。每当我尝试使用redis模块获取好友和关注者的信息时,都会出现以下错误:

代码语言:javascript
复制
raise ConnectionError(self._error_message(e))
ConnectionError: Error 10061 connecting localhost:6379. No connection could be made because the target machine actively refused it.

当我不使用Redis时,我可以获得所有朋友和追随者的I。但我要求Redis对数据进行某些分析。我的源码如下:

代码语言:javascript
复制
import json
import locale
import redis
from prettytable import PrettyTable

# Pretty printing numbers
from twitter__util import pp 

# These functions create consistent keys from 
# screen names and user id values
from twitter__util import getRedisIdByScreenName 
from twitter__util import getRedisIdByUserId

SCREEN_NAME = "timoreilly"

locale.setlocale(locale.LC_ALL, '')

def calculate():
    r = redis.Redis()  # Default connection settings on localhost

    follower_ids = list(r.smembers(getRedisIdByScreenName(SCREEN_NAME,
                        'follower_ids')))

    followers = r.mget([getRedisIdByUserId(follower_id, 'info.json')
                       for follower_id in follower_ids])
    followers = [json.loads(f) for f in followers if f is not None]

    freqs = {}
    for f in followers:
        cnt = f['followers_count']
        if not freqs.has_key(cnt):
            freqs[cnt] = []

        freqs[cnt].append({'screen_name': f['screen_name'], 'user_id': f['id']})

    # It could take a few minutes to calculate freqs, so store a snapshot for later use

    r.set(getRedisIdByScreenName(SCREEN_NAME, 'follower_freqs'),
          json.dumps(freqs))

    keys = freqs.keys()
    keys.sort()

    print 'The top 10 followers from the sample:'

    fields = ['Date', 'Count']
    pt = PrettyTable(fields=fields)
    [pt.set_field_align(f, 'l') for f in fields]

    for (user, freq) in reversed([(user['screen_name'], k) for k in keys[-10:]
                                    for user in freqs[k]]):
        pt.add_row([user, pp(freq)])

    pt.printt()

    all_freqs = [k for k in keys for user in freqs[k]]
    avg = reduce(lambda x, y: x + y, all_freqs) / len(all_freqs)

    print "\nThe average number of followers for %s's followers: %s" \
        % (SCREEN_NAME, pp(avg))

# psyco can only compile functions, so wrap code in a function

try:
    import psyco
    psyco.bind(calculate)
except ImportError, e:
    pass  # psyco not installed

calculate()

任何帮助都将不胜感激。谢谢!

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2012-12-04 00:28:55

这是Redis运行的端口。如果我是你,我会仔细检查Redis服务器是否在正确的端口和接口上运行。要测试这一点,请确保安装了telnet客户端,并执行以下操作:

代码语言:javascript
复制
$ telnet localhost 6379

如果失败,那么Redis服务器实际上并没有在Redis客户端库期望的默认位置运行,在这种情况下,您必须在构造函数参数中为客户端提供正确的详细信息。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/13687450

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档