class RedisClient(object):
    def __init__(self):
        super(RedisClient, self).__init__()
        host = settings[RedisConstant.REDIS_SERVER]
        port = settings[RedisConstant.REDIS_PORT]

        if host is None or port is None:
            raise ValueError

        self.redis = redis.Redis(host, port, db=0)

    def rpush(self, key, value):
        self.redis.rpush(key, value)

    def sadd(self, key, value):
        self.redis.sadd(key, value)

    def lpop(self, key):
        return self.redis.lpop(key)

rpush和lpop為List的操作，sadd為set的操作

item = {
           'market': self.market,
           'country': country,
           'device': device,
           'data': data,
           'date': time.strftime("%Y-%m-%d %X", time.localtime(time.time()))
        }
self.result_client.rpush(Constant.REDIE_TREND, pickle.dumps(item, protocol=2))

此處我們將python字典item序列化之后存進redis