#coding=utf-8 import redis class RedisUtil(object): def __init__(self, host="127.0.0.1", port="6379", db=0): self.redis = redis.Redis(host=host, port=port, db=db) def push(self, queue_name, str_data): self.redis.lpush(queue_name, str_data) def rpush(self, queue_name, str_data): self.redis.rpush(queue_name, str_data) def get_size(self, queue_name): return self.redis.llen(queue_name) def check_key_exists(self, key_name): return self.redis.exists(key_name) def delete_by_key(self, key_name): return self.redis.delete(key_name) if __name__ == '__main__': print RedisUtil().get_size("someone")