func (c *cacheCleaner) cleanPushsumKeys(conn redis.Conn) {
    keys, _ := redis.Strings(conn.Do("KEYS", "keyword:*:subs"))
    for _, key := range keys {
        _, err := conn.Do("DEL", key)
        if err == nil {