#encoding:utf8

import time

import redis

conn = redis.Redis('localhost',db=1)    #连接诶数据库并使用数据库1

def insert_data():

    while True:

        conn.lpush('key','value')        向key中增加值

        time.sleep(3)

def process_data():

    task = conn.blpop("key",0)[1]    #弹出列表中第一个值

    print task    

insert_data()

process_data()